createUnsubAckV5() — netty Function Reference

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

Function java Buffer Allocators

Entity Profile

Buffer→ Allocators→ createUnsubAckV5() — netty Function Reference

Dependency Diagram

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

Relationship Graph

Source Code

codec-mqtt/src/test/java/io/netty/handler/codec/mqtt/MqttMessageFactoryTest.java lines 54–76

    @Test
    public void createUnsubAckV5() {
        MqttFixedHeader fixedHeader =
                new MqttFixedHeader(MqttMessageType.UNSUBACK, false, MqttQoS.AT_MOST_ONCE, false, 0);
        MqttProperties properties = new MqttProperties();
        String reasonString = "All right";
        properties.add(new MqttProperties.StringProperty(
                MqttProperties.REASON_STRING,
                reasonString));
        MqttMessageIdAndPropertiesVariableHeader variableHeader =
                new MqttMessageIdAndPropertiesVariableHeader(SAMPLE_MESSAGE_ID, properties);
        MqttUnsubAckPayload payload = new MqttUnsubAckPayload((short) 0x80 /*unspecified error*/);

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

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