MqttPropertyType Type — netty Architecture

Source Code

codec-mqtt/src/main/java/io/netty/handler/codec/mqtt/MqttProperties.java lines 69–141

    @Deprecated
    public enum MqttPropertyType {
        // single byte properties
        PAYLOAD_FORMAT_INDICATOR(MqttProperties.PAYLOAD_FORMAT_INDICATOR),
        REQUEST_PROBLEM_INFORMATION(MqttProperties.REQUEST_PROBLEM_INFORMATION),
        REQUEST_RESPONSE_INFORMATION(MqttProperties.REQUEST_RESPONSE_INFORMATION),
        MAXIMUM_QOS(MqttProperties.MAXIMUM_QOS),
        RETAIN_AVAILABLE(MqttProperties.RETAIN_AVAILABLE),
        WILDCARD_SUBSCRIPTION_AVAILABLE(MqttProperties.WILDCARD_SUBSCRIPTION_AVAILABLE),
        SUBSCRIPTION_IDENTIFIER_AVAILABLE(MqttProperties.SUBSCRIPTION_IDENTIFIER_AVAILABLE),
        SHARED_SUBSCRIPTION_AVAILABLE(MqttProperties.SHARED_SUBSCRIPTION_AVAILABLE),

        // two bytes properties
        SERVER_KEEP_ALIVE(MqttProperties.SERVER_KEEP_ALIVE),
        RECEIVE_MAXIMUM(MqttProperties.RECEIVE_MAXIMUM),
        TOPIC_ALIAS_MAXIMUM(MqttProperties.TOPIC_ALIAS_MAXIMUM),
        TOPIC_ALIAS(MqttProperties.TOPIC_ALIAS),

        // four bytes properties
        PUBLICATION_EXPIRY_INTERVAL(MqttProperties.PUBLICATION_EXPIRY_INTERVAL),
        SESSION_EXPIRY_INTERVAL(MqttProperties.SESSION_EXPIRY_INTERVAL),
        WILL_DELAY_INTERVAL(MqttProperties.WILL_DELAY_INTERVAL),
        MAXIMUM_PACKET_SIZE(MqttProperties.MAXIMUM_PACKET_SIZE),

        // Variable Byte Integer
        SUBSCRIPTION_IDENTIFIER(MqttProperties.SUBSCRIPTION_IDENTIFIER),

        // UTF-8 Encoded String properties
        CONTENT_TYPE(MqttProperties.CONTENT_TYPE),
        RESPONSE_TOPIC(MqttProperties.RESPONSE_TOPIC),
        ASSIGNED_CLIENT_IDENTIFIER(MqttProperties.ASSIGNED_CLIENT_IDENTIFIER),
        AUTHENTICATION_METHOD(MqttProperties.AUTHENTICATION_METHOD),
        RESPONSE_INFORMATION(MqttProperties.RESPONSE_INFORMATION),
        SERVER_REFERENCE(MqttProperties.SERVER_REFERENCE),
        REASON_STRING(MqttProperties.REASON_STRING),
        USER_PROPERTY(MqttProperties.USER_PROPERTY),

        // Binary Data
        CORRELATION_DATA(MqttProperties.CORRELATION_DATA),
        AUTHENTICATION_DATA(MqttProperties.AUTHENTICATION_DATA);

        private static final MqttPropertyType[] VALUES;

        static {
            VALUES = new MqttPropertyType[43];
            for (MqttPropertyType v : values()) {
                VALUES[v.value] = v;
            }
        }

        private final int value;

        MqttPropertyType(int value) {
            this.value = value;
        }

        public int value() {
            return value;
        }

        public static MqttPropertyType valueOf(int type) {
            MqttPropertyType t = null;
            try {
                t = VALUES[type];
            } catch (ArrayIndexOutOfBoundsException ignored) {
                // nop
            }
            if (t == null) {
                throw new IllegalArgumentException("unknown property type: " + type);
            }
            return t;
        }
    }