MqttSubAckPayload() — netty Function Reference

Architecture documentation for the MqttSubAckPayload() function in MqttDecoder.java from the netty codebase.

Function java Buffer Allocators calls 1

Entity Profile

Buffer→ Allocators→ MqttSubAckPayload() — netty Function Reference

Dependency Diagram

graph TD
  dc3a2f86_91ed_a0d4_d490_c9537ada32a2["MqttSubAckPayload()"]
  c4faa729_e212_a3dd_9d90_3e8fd908d755["MqttDecoder"]
  dc3a2f86_91ed_a0d4_d490_c9537ada32a2 -->|defined in| c4faa729_e212_a3dd_9d90_3e8fd908d755
  2c20bb71_3f3e_3411_a7de_3f584e47d79f["validateNoBytesRemain()"]
  dc3a2f86_91ed_a0d4_d490_c9537ada32a2 -->|calls| 2c20bb71_3f3e_3411_a7de_3f584e47d79f
  style dc3a2f86_91ed_a0d4_d490_c9537ada32a2 fill:#6366f1,stroke:#818cf8,color:#fff

Relationship Graph

Source Code

codec-mqtt/src/main/java/io/netty/handler/codec/mqtt/MqttDecoder.java lines 614–626

    private MqttSubAckPayload decodeSubackPayload(
            ByteBuf buffer) {
        int bytesRemainingInVariablePart = this.bytesRemainingInVariablePart;
        final List<Integer> grantedQos = new ArrayList<Integer>(bytesRemainingInVariablePart);
        int numberOfBytesConsumed = 0;
        while (numberOfBytesConsumed < bytesRemainingInVariablePart) {
            int reasonCode = buffer.readUnsignedByte();
            numberOfBytesConsumed++;
            grantedQos.add(reasonCode);
        }
        validateNoBytesRemain(numberOfBytesConsumed);
        return new MqttSubAckPayload(grantedQos);
    }