MqttUnsubscribeMessage() — netty Function Reference

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

Function java Buffer Allocators

Entity Profile

Buffer→ Allocators→ MqttUnsubscribeMessage() — netty Function Reference

Dependency Diagram

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

Relationship Graph

Source Code

codec-mqtt/src/test/java/io/netty/handler/codec/mqtt/MqttCodecTest.java lines 1014–1026

    private static MqttUnsubscribeMessage createUnsubscribeMessage() {
        MqttFixedHeader mqttFixedHeader =
                new MqttFixedHeader(MqttMessageType.UNSUBSCRIBE, false, MqttQoS.AT_LEAST_ONCE, false, 0);
        MqttMessageIdVariableHeader mqttMessageIdVariableHeader = MqttMessageIdVariableHeader.from(12345);

        List<String> topics = new LinkedList<>();
        topics.add("/abc");
        topics.add("/def");
        topics.add("/xyz");

        MqttUnsubscribePayload mqttUnsubscribePayload = new MqttUnsubscribePayload(topics);
        return new MqttUnsubscribeMessage(mqttFixedHeader, mqttMessageIdVariableHeader, mqttUnsubscribePayload);
    }