MqttSubscribeMessage() — netty Function Reference

Architecture documentation for the MqttSubscribeMessage() function in MqttCodecTest.java from the netty codebase.

Function java Buffer Allocators

Entity Profile

Buffer→ Allocators→ MqttSubscribeMessage() — netty Function Reference

Dependency Diagram

graph TD
  2efa8f0a_87b7_f7e8_e085_57d08e82ae9e["MqttSubscribeMessage()"]
  f4aba1d9_6b30_ec96_9eaa_4c5557b5796d["MqttCodecTest"]
  2efa8f0a_87b7_f7e8_e085_57d08e82ae9e -->|defined in| f4aba1d9_6b30_ec96_9eaa_4c5557b5796d
  style 2efa8f0a_87b7_f7e8_e085_57d08e82ae9e fill:#6366f1,stroke:#818cf8,color:#fff

Relationship Graph

Source Code

codec-mqtt/src/test/java/io/netty/handler/codec/mqtt/MqttCodecTest.java lines 988–1000

    private static MqttSubscribeMessage createSubscribeMessage() {
        MqttFixedHeader mqttFixedHeader =
                new MqttFixedHeader(MqttMessageType.SUBSCRIBE, false, MqttQoS.AT_LEAST_ONCE, false, 0);
        MqttMessageIdVariableHeader mqttMessageIdVariableHeader = MqttMessageIdVariableHeader.from(12345);

        List<MqttTopicSubscription> topicSubscriptions = new LinkedList<>();
        topicSubscriptions.add(new MqttTopicSubscription("/abc", MqttQoS.AT_LEAST_ONCE));
        topicSubscriptions.add(new MqttTopicSubscription("/def", MqttQoS.AT_LEAST_ONCE));
        topicSubscriptions.add(new MqttTopicSubscription("/xyz", MqttQoS.EXACTLY_ONCE));

        MqttSubscribePayload mqttSubscribePayload = new MqttSubscribePayload(topicSubscriptions);
        return new MqttSubscribeMessage(mqttFixedHeader, mqttMessageIdVariableHeader, mqttSubscribePayload);
    }