MqttSubAckMessage() — netty Function Reference

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

Function java Buffer Allocators

Entity Profile

Buffer→ Allocators→ MqttSubAckMessage() — netty Function Reference

Dependency Diagram

graph TD
  2fd42d22_42c3_0edf_632a_3b70cfe140c7["MqttSubAckMessage()"]
  40944937_069e_dc2c_7a3b_710d4b8a9a49["SubAckBuilder"]
  2fd42d22_42c3_0edf_632a_3b70cfe140c7 -->|defined in| 40944937_069e_dc2c_7a3b_710d4b8a9a49
  style 2fd42d22_42c3_0edf_632a_3b70cfe140c7 fill:#6366f1,stroke:#818cf8,color:#fff

Relationship Graph

Source Code

codec-mqtt/src/main/java/io/netty/handler/codec/mqtt/MqttMessageBuilders.java lines 599–614

        public MqttSubAckMessage build() {
            MqttFixedHeader mqttFixedHeader =
                    new MqttFixedHeader(MqttMessageType.SUBACK, false, MqttQoS.AT_MOST_ONCE, false, 0);
            MqttMessageIdAndPropertiesVariableHeader mqttSubAckVariableHeader =
                    new MqttMessageIdAndPropertiesVariableHeader(packetId, properties);

            //transform to primitive types
            int[] grantedQoses = new int[this.grantedQoses.size()];
            int i = 0;
            for (MqttQoS grantedQos : this.grantedQoses) {
                grantedQoses[i++] = grantedQos.value();
            }

            MqttSubAckPayload subAckPayload = new MqttSubAckPayload(grantedQoses);
            return new MqttSubAckMessage(mqttFixedHeader, mqttSubAckVariableHeader, subAckPayload);
        }