MqttPublishMessage() — netty Function Reference

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

Function java Buffer Allocators

Entity Profile

Buffer→ Allocators→ MqttPublishMessage() — netty Function Reference

Dependency Diagram

graph TD
  2c594df1_6683_662f_6682_f83f971b644f["MqttPublishMessage()"]
  7b11dc39_c611_e444_7e88_f65296ae7b8c["PublishBuilder"]
  2c594df1_6683_662f_6682_f83f971b644f -->|defined in| 7b11dc39_c611_e444_7e88_f65296ae7b8c
  style 2c594df1_6683_662f_6682_f83f971b644f fill:#6366f1,stroke:#818cf8,color:#fff

Relationship Graph

Source Code

codec-mqtt/src/main/java/io/netty/handler/codec/mqtt/MqttMessageBuilders.java lines 71–76

        public MqttPublishMessage build() {
            MqttFixedHeader mqttFixedHeader = new MqttFixedHeader(MqttMessageType.PUBLISH, false, qos, retained, 0);
            MqttPublishVariableHeader mqttVariableHeader =
                    new MqttPublishVariableHeader(topic, messageId, mqttProperties);
            return new MqttPublishMessage(mqttFixedHeader, mqttVariableHeader, Unpooled.buffer().writeBytes(payload));
        }