MqttUnsubAckPayload() — netty Function Reference

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

Function java Buffer Allocators calls 1

Entity Profile

Buffer→ Allocators→ MqttUnsubAckPayload() — netty Function Reference

Dependency Diagram

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

Relationship Graph

Source Code

codec-mqtt/src/main/java/io/netty/handler/codec/mqtt/MqttDecoder.java lines 628–641

    private MqttUnsubAckPayload decodeUnsubAckPayload(
        ChannelHandlerContext ctx,
        ByteBuf buffer) {
        int bytesRemainingInVariablePart = this.bytesRemainingInVariablePart;
        final List<Short> reasonCodes = new ArrayList<Short>(bytesRemainingInVariablePart);
        int numberOfBytesConsumed = 0;
        while (numberOfBytesConsumed < bytesRemainingInVariablePart) {
            short reasonCode = buffer.readUnsignedByte();
            numberOfBytesConsumed++;
            reasonCodes.add(reasonCode);
        }
        validateNoBytesRemain(numberOfBytesConsumed);
        return new MqttUnsubAckPayload(reasonCodes);
    }