MqttConnAckVariableHeader() — netty Function Reference

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

Function java Buffer Allocators calls 1

Entity Profile

Buffer→ Allocators→ MqttConnAckVariableHeader() — netty Function Reference

Dependency Diagram

graph TD
  ce7a49f3_246f_2440_f1c6_01af3e368c37["MqttConnAckVariableHeader()"]
  c4faa729_e212_a3dd_9d90_3e8fd908d755["MqttDecoder"]
  ce7a49f3_246f_2440_f1c6_01af3e368c37 -->|defined in| c4faa729_e212_a3dd_9d90_3e8fd908d755
  8cad50bc_08ed_5075_a0f7_de30f00ba977["decodeProperties()"]
  ce7a49f3_246f_2440_f1c6_01af3e368c37 -->|calls| 8cad50bc_08ed_5075_a0f7_de30f00ba977
  style ce7a49f3_246f_2440_f1c6_01af3e368c37 fill:#6366f1,stroke:#818cf8,color:#fff

Relationship Graph

Source Code

codec-mqtt/src/main/java/io/netty/handler/codec/mqtt/MqttDecoder.java lines 371–389

    private MqttConnAckVariableHeader decodeConnAckVariableHeader(
            ChannelHandlerContext ctx,
            ByteBuf buffer) {
        final MqttVersion mqttVersion = MqttCodecUtil.getMqttVersion(ctx);
        final boolean sessionPresent = (buffer.readUnsignedByte() & 0x01) == 0x01;
        byte returnCode = buffer.readByte();

        final MqttProperties properties;
        if (mqttVersion == MqttVersion.MQTT_5) {
            final Result<MqttProperties> propertiesResult = decodeProperties(buffer);
            properties = propertiesResult.value;
            bytesRemainingInVariablePart -= 2 + propertiesResult.numberOfBytesConsumed;
        } else {
            properties = MqttProperties.NO_PROPERTIES;
            bytesRemainingInVariablePart -= 2;
        }

        return new MqttConnAckVariableHeader(MqttConnectReturnCode.valueOf(returnCode), sessionPresent, properties);
    }