createSubscribeV3() — netty Function Reference

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

Function java Buffer Allocators

Entity Profile

Buffer→ Allocators→ createSubscribeV3() — netty Function Reference

Dependency Diagram

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

Relationship Graph

Source Code

codec-mqtt/src/test/java/io/netty/handler/codec/mqtt/MqttMessageFactoryTest.java lines 78–97

    @Test
    public void createSubscribeV3() {
        MqttFixedHeader fixedHeader = new MqttFixedHeader(MqttMessageType.SUBSCRIBE, false, AT_LEAST_ONCE, false, 0);

        MqttMessageIdVariableHeader variableHeader = MqttMessageIdVariableHeader.from(SAMPLE_MESSAGE_ID);
        List<MqttTopicSubscription> subscriptions = new ArrayList<MqttTopicSubscription>();
        subscriptions.add(new MqttTopicSubscription(SAMPLE_TOPIC, MqttQoS.AT_MOST_ONCE));

        MqttSubscribePayload payload = new MqttSubscribePayload(subscriptions);

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

        assertEquals(MqttMessageType.SUBSCRIBE, subscribe.fixedHeader().messageType());
        MqttMessageIdAndPropertiesVariableHeader actualVariableHeader =
                (MqttMessageIdAndPropertiesVariableHeader) subscribe.variableHeader();
        assertEquals(SAMPLE_MESSAGE_ID, actualVariableHeader.messageId());
        validateProperties(MqttProperties.NO_PROPERTIES, actualVariableHeader.properties());
        MqttSubscribePayload actualPayload = (MqttSubscribePayload) subscribe.payload();
        validateSubscribePayload(payload, actualPayload);
    }