createUnsubAckV3() — netty Function Reference

Architecture documentation for the createUnsubAckV3() function in MqttMessageFactoryTest.java from the netty codebase.

Function java Buffer Allocators

Entity Profile

Buffer→ Allocators→ createUnsubAckV3() — netty Function Reference

Dependency Diagram

graph TD
  b06723f8_e9b8_c601_d193_dc52b0f7d6bd["createUnsubAckV3()"]
  dd84b5fc_9604_d2f3_86c2_0f14e387b4da["MqttMessageFactoryTest"]
  b06723f8_e9b8_c601_d193_dc52b0f7d6bd -->|defined in| dd84b5fc_9604_d2f3_86c2_0f14e387b4da
  style b06723f8_e9b8_c601_d193_dc52b0f7d6bd fill:#6366f1,stroke:#818cf8,color:#fff

Relationship Graph

Source Code

codec-mqtt/src/test/java/io/netty/handler/codec/mqtt/MqttMessageFactoryTest.java lines 35–52

    @Test
    public void createUnsubAckV3() {
        MqttFixedHeader fixedHeader =
                new MqttFixedHeader(MqttMessageType.UNSUBACK, false, MqttQoS.AT_MOST_ONCE, false, 0);
        MqttMessageIdVariableHeader variableHeader =
                MqttMessageIdVariableHeader.from(SAMPLE_MESSAGE_ID);

        MqttMessage unsuback = MqttMessageFactory.newMessage(fixedHeader, variableHeader, null);

        assertEquals(MqttMessageType.UNSUBACK, unsuback.fixedHeader().messageType());
        MqttMessageIdAndPropertiesVariableHeader actualVariableHeader =
                (MqttMessageIdAndPropertiesVariableHeader) unsuback.variableHeader();
        assertEquals(SAMPLE_MESSAGE_ID, actualVariableHeader.messageId());
        validateProperties(MqttProperties.NO_PROPERTIES, actualVariableHeader.properties());
        MqttUnsubAckPayload actualPayload = (MqttUnsubAckPayload) unsuback.payload();
        assertNotNull(actualPayload);
        assertEquals(0, actualPayload.unsubscribeReasonCodes().size());
    }