MqttConnectMessage() — netty Function Reference

Architecture documentation for the MqttConnectMessage() function in MqttMessageBuilders.java from the netty codebase.

Function java Buffer Allocators

Entity Profile

Buffer→ Allocators→ MqttConnectMessage() — netty Function Reference

Dependency Diagram

graph TD
  4645052b_d55c_7966_e5d6_740d15433c94["MqttConnectMessage()"]
  3ed16f43_4cd1_d842_60f0_78f21b76aaeb["ConnectBuilder"]
  4645052b_d55c_7966_e5d6_740d15433c94 -->|defined in| 3ed16f43_4cd1_d842_60f0_78f21b76aaeb
  style 4645052b_d55c_7966_e5d6_740d15433c94 fill:#6366f1,stroke:#818cf8,color:#fff

Relationship Graph

Source Code

codec-mqtt/src/main/java/io/netty/handler/codec/mqtt/MqttMessageBuilders.java lines 195–213

        public MqttConnectMessage build() {
            MqttFixedHeader mqttFixedHeader =
                    new MqttFixedHeader(MqttMessageType.CONNECT, false, MqttQoS.AT_MOST_ONCE, false, 0);
            MqttConnectVariableHeader mqttConnectVariableHeader =
                    new MqttConnectVariableHeader(
                            version.protocolName(),
                            version.protocolLevel(),
                            hasUser,
                            hasPassword,
                            willRetain,
                            willQos.value(),
                            willFlag,
                            cleanSession,
                            keepAliveSecs,
                            properties);
            MqttConnectPayload mqttConnectPayload =
                    new MqttConnectPayload(clientId, willProperties, willTopic, willMessage, username, password);
            return new MqttConnectMessage(mqttFixedHeader, mqttConnectVariableHeader, mqttConnectPayload);
        }