decodeMessageId() — netty Function Reference

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

Function java Buffer Allocators calls 1 called by 3

Entity Profile

Buffer→ Allocators→ decodeMessageId() — netty Function Reference

Dependency Diagram

graph TD
  ffabaaa2_4dc4_d6a0_6031_2c831eb098b0["decodeMessageId()"]
  c4faa729_e212_a3dd_9d90_3e8fd908d755["MqttDecoder"]
  ffabaaa2_4dc4_d6a0_6031_2c831eb098b0 -->|defined in| c4faa729_e212_a3dd_9d90_3e8fd908d755
  56e49442_12c5_b9e5_14d7_23d73dd802d2["MqttMessageIdAndPropertiesVariableHeader()"]
  56e49442_12c5_b9e5_14d7_23d73dd802d2 -->|calls| ffabaaa2_4dc4_d6a0_6031_2c831eb098b0
  8b19608c_9ee3_40f3_5402_e745fcea4448["MqttPubReplyMessageVariableHeader()"]
  8b19608c_9ee3_40f3_5402_e745fcea4448 -->|calls| ffabaaa2_4dc4_d6a0_6031_2c831eb098b0
  c4f45191_2a53_efcc_39c7_8365c184d7db["MqttPublishVariableHeader()"]
  c4f45191_2a53_efcc_39c7_8365c184d7db -->|calls| ffabaaa2_4dc4_d6a0_6031_2c831eb098b0
  c329612b_da71_6e39_b716_e4f7dc59569d["decodeMsbLsb()"]
  ffabaaa2_4dc4_d6a0_6031_2c831eb098b0 -->|calls| c329612b_da71_6e39_b716_e4f7dc59569d
  style ffabaaa2_4dc4_d6a0_6031_2c831eb098b0 fill:#6366f1,stroke:#818cf8,color:#fff

Relationship Graph

Source Code

codec-mqtt/src/main/java/io/netty/handler/codec/mqtt/MqttDecoder.java lines 487–493

    private static int decodeMessageId(ByteBuf buffer) {
        final int messageId = decodeMsbLsb(buffer);
        if (!isValidMessageId(messageId)) {
            throw new DecoderException("invalid messageId: " + messageId);
        }
        return messageId;
    }