netty Architecture Docs
Home / Function/ MqttPubReplyMessageVariableHeader() — netty Function Reference

MqttPubReplyMessageVariableHeader() — netty Function Reference

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

Function java Buffer Allocators calls 2

Entity Profile

Dependency Diagram

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

Relationship Graph

Source Code

codec-mqtt/src/main/java/io/netty/handler/codec/mqtt/MqttDecoder.java lines 408–431

    private MqttPubReplyMessageVariableHeader decodePubReplyMessage(ByteBuf buffer) {
        final int packetId = decodeMessageId(buffer);

        final int packetIdNumberOfBytesConsumed = 2;
        if (bytesRemainingInVariablePart > 3) {
            final byte reasonCode = buffer.readByte();
            final Result<MqttProperties> properties = decodeProperties(buffer);
            bytesRemainingInVariablePart -= packetIdNumberOfBytesConsumed + 1 + properties.numberOfBytesConsumed;
            return new MqttPubReplyMessageVariableHeader(packetId,
                    reasonCode,
                    properties.value);
        } else if (bytesRemainingInVariablePart > 2) {
            final byte reasonCode = buffer.readByte();
            bytesRemainingInVariablePart -= packetIdNumberOfBytesConsumed + 1;
            return new MqttPubReplyMessageVariableHeader(packetId,
                    reasonCode,
                    MqttProperties.NO_PROPERTIES);
        } else {
            bytesRemainingInVariablePart -= packetIdNumberOfBytesConsumed;
            return new MqttPubReplyMessageVariableHeader(packetId,
                    (byte) 0,
                    MqttProperties.NO_PROPERTIES);
        }
    }

Domain

Subdomains

Defined In

Calls

Source

Frequently Asked Questions

What does MqttPubReplyMessageVariableHeader() do?
MqttPubReplyMessageVariableHeader() is a function in the netty codebase, defined in codec-mqtt/src/main/java/io/netty/handler/codec/mqtt/MqttDecoder.java.
Where is MqttPubReplyMessageVariableHeader() defined?
MqttPubReplyMessageVariableHeader() is defined in codec-mqtt/src/main/java/io/netty/handler/codec/mqtt/MqttDecoder.java at line 408.
What does MqttPubReplyMessageVariableHeader() call?
MqttPubReplyMessageVariableHeader() calls 2 function(s): decodeMessageId, decodeProperties.

Analyze Your Own Codebase

Get architecture documentation, dependency graphs, and domain analysis for your codebase in minutes.

Try Supermodel Free