MqttFixedHeader() — netty Function Reference

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

Function java Buffer Allocators

Entity Profile

Buffer→ Allocators→ MqttFixedHeader() — netty Function Reference

Dependency Diagram

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

Relationship Graph

Source Code

codec-mqtt/src/main/java/io/netty/handler/codec/mqtt/MqttCodecUtil.java lines 72–89

    static MqttFixedHeader validateFixedHeader(ChannelHandlerContext ctx, MqttFixedHeader mqttFixedHeader) {
        switch (mqttFixedHeader.messageType()) {
            case PUBREL:
            case SUBSCRIBE:
            case UNSUBSCRIBE:
                if (mqttFixedHeader.qosLevel() != MqttQoS.AT_LEAST_ONCE) {
                    throw new DecoderException(mqttFixedHeader.messageType().name() + " message must have QoS 1");
                }
                return mqttFixedHeader;
            case AUTH:
                if (MqttCodecUtil.getMqttVersion(ctx) != MqttVersion.MQTT_5) {
                    throw new DecoderException("AUTH message requires at least MQTT 5");
                }
                return mqttFixedHeader;
            default:
                return mqttFixedHeader;
        }
    }