MqttSubscribeMessage() — netty Function Reference

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

Function java Buffer Allocators

Entity Profile

Buffer→ Allocators→ MqttSubscribeMessage() — netty Function Reference

Dependency Diagram

graph TD
  66531d70_0f4a_bde5_4ec5_3b5c5b48d760["MqttSubscribeMessage()"]
  9d11ed7c_1463_74bc_8170_f2188d677e32["SubscribeBuilder"]
  66531d70_0f4a_bde5_4ec5_3b5c5b48d760 -->|defined in| 9d11ed7c_1463_74bc_8170_f2188d677e32
  style 66531d70_0f4a_bde5_4ec5_3b5c5b48d760 fill:#6366f1,stroke:#818cf8,color:#fff

Relationship Graph

Source Code

codec-mqtt/src/main/java/io/netty/handler/codec/mqtt/MqttMessageBuilders.java lines 247–254

        public MqttSubscribeMessage build() {
            MqttFixedHeader mqttFixedHeader =
                    new MqttFixedHeader(MqttMessageType.SUBSCRIBE, false, MqttQoS.AT_LEAST_ONCE, false, 0);
            MqttMessageIdAndPropertiesVariableHeader mqttVariableHeader =
                    new MqttMessageIdAndPropertiesVariableHeader(messageId, properties);
            MqttSubscribePayload mqttSubscribePayload = new MqttSubscribePayload(subscriptions);
            return new MqttSubscribeMessage(mqttFixedHeader, mqttVariableHeader, mqttSubscribePayload);
        }