MqttVersion() — netty Function Reference

Architecture documentation for the MqttVersion() function in MqttCodecUtil.java from the netty codebase.

Function java Buffer Allocators

Entity Profile

Buffer→ Allocators→ MqttVersion() — netty Function Reference

Dependency Diagram

graph TD
  01a072b3_9c32_18fc_dea0_1beb8e00503a["MqttVersion()"]
  8cc4b5f5_1c6e_ed7b_93cd_8de978fc304c["MqttCodecUtil"]
  01a072b3_9c32_18fc_dea0_1beb8e00503a -->|defined in| 8cc4b5f5_1c6e_ed7b_93cd_8de978fc304c
  style 01a072b3_9c32_18fc_dea0_1beb8e00503a fill:#6366f1,stroke:#818cf8,color:#fff

Relationship Graph

Source Code

codec-mqtt/src/main/java/io/netty/handler/codec/mqtt/MqttCodecUtil.java lines 30–37

    static MqttVersion getMqttVersion(ChannelHandlerContext ctx) {
        Attribute<MqttVersion> attr = ctx.channel().attr(MQTT_VERSION_KEY);
        MqttVersion version = attr.get();
        if (version == null) {
            return MqttVersion.MQTT_3_1_1;
        }
        return version;
    }