netty Architecture Docs
Home / Function/ ByteBuf() — netty Function Reference

ByteBuf() — netty Function Reference

Architecture documentation for the ByteBuf() function in MqttEncoder.java from the netty codebase.

Function java Buffer Allocators calls 7

Entity Profile

Dependency Diagram

graph TD
  a7b9925d_5111_9e2c_2e13_04e1c42819fc["ByteBuf()"]
  13c11c97_f8b9_b829_dd75_63846e7fcd55["MqttEncoder"]
  a7b9925d_5111_9e2c_2e13_04e1c42819fc -->|defined in| 13c11c97_f8b9_b829_dd75_63846e7fcd55
  cc9333fe_a8bc_cfd6_337e_a856ba011d3a["nullableUtf8Bytes()"]
  a7b9925d_5111_9e2c_2e13_04e1c42819fc -->|calls| cc9333fe_a8bc_cfd6_337e_a856ba011d3a
  dbd748c5_b782_d0cd_6ae1_be4b563dd617["getVariableLengthInt()"]
  a7b9925d_5111_9e2c_2e13_04e1c42819fc -->|calls| dbd748c5_b782_d0cd_6ae1_be4b563dd617
  0c2943f5_5e56_9055_be1d_2258275f171e["getFixedHeaderByte1()"]
  a7b9925d_5111_9e2c_2e13_04e1c42819fc -->|calls| 0c2943f5_5e56_9055_be1d_2258275f171e
  3def4f1c_67d0_f2da_6583_29577090a0e8["writeVariableLengthInt()"]
  a7b9925d_5111_9e2c_2e13_04e1c42819fc -->|calls| 3def4f1c_67d0_f2da_6583_29577090a0e8
  ccba0eb6_25da_af9a_b7d6_926ed2ffd985["getConnVariableHeaderFlag()"]
  a7b9925d_5111_9e2c_2e13_04e1c42819fc -->|calls| ccba0eb6_25da_af9a_b7d6_926ed2ffd985
  a3c98376_ea30_7539_2753_8e79ba77e186["writeExactUTF8String()"]
  a7b9925d_5111_9e2c_2e13_04e1c42819fc -->|calls| a3c98376_ea30_7539_2753_8e79ba77e186
  f74bb6b2_2564_0b6f_d854_438c7e723c1a["writeEagerUTF8String()"]
  a7b9925d_5111_9e2c_2e13_04e1c42819fc -->|calls| f74bb6b2_2564_0b6f_d854_438c7e723c1a
  style a7b9925d_5111_9e2c_2e13_04e1c42819fc fill:#6366f1,stroke:#818cf8,color:#fff

Relationship Graph

Source Code

codec-mqtt/src/main/java/io/netty/handler/codec/mqtt/MqttEncoder.java lines 90–136

    static ByteBuf doEncode(ChannelHandlerContext ctx,
                     MqttMessage message) {

        switch (message.fixedHeader().messageType()) {
            case CONNECT:
                return encodeConnectMessage(ctx, (MqttConnectMessage) message);

            case CONNACK:
                return encodeConnAckMessage(ctx, (MqttConnAckMessage) message);

            case PUBLISH:
                return encodePublishMessage(ctx, (MqttPublishMessage) message);

            case SUBSCRIBE:
                return encodeSubscribeMessage(ctx, (MqttSubscribeMessage) message);

            case UNSUBSCRIBE:
                return encodeUnsubscribeMessage(ctx,  (MqttUnsubscribeMessage) message);

            case SUBACK:
                return encodeSubAckMessage(ctx, (MqttSubAckMessage) message);

            case UNSUBACK:
                if (message instanceof MqttUnsubAckMessage) {
                    return encodeUnsubAckMessage(ctx, (MqttUnsubAckMessage) message);
                }
                return encodeMessageWithOnlySingleByteFixedHeaderAndMessageId(ctx.alloc(), message);

            case PUBACK:
            case PUBREC:
            case PUBREL:
            case PUBCOMP:
                return encodePubReplyMessage(ctx, message);

            case DISCONNECT:
            case AUTH:
                return encodeReasonCodePlusPropertiesMessage(ctx, message);

            case PINGREQ:
            case PINGRESP:
                return encodeMessageWithOnlySingleByteFixedHeader(ctx.alloc(), message);

            default:
                throw new IllegalArgumentException(
                        "Unknown message type: " + message.fixedHeader().messageType().value());
        }
    }

Domain

Subdomains

Defined In

Calls

Source

Frequently Asked Questions

What does ByteBuf() do?
ByteBuf() is a function in the netty codebase, defined in codec-mqtt/src/main/java/io/netty/handler/codec/mqtt/MqttEncoder.java.
Where is ByteBuf() defined?
ByteBuf() is defined in codec-mqtt/src/main/java/io/netty/handler/codec/mqtt/MqttEncoder.java at line 90.
What does ByteBuf() call?
ByteBuf() calls 7 function(s): getConnVariableHeaderFlag, getFixedHeaderByte1, getVariableLengthInt, nullableUtf8Bytes, writeEagerUTF8String, writeExactUTF8String, writeVariableLengthInt.

Analyze Your Own Codebase

Get architecture documentation, dependency graphs, and domain analysis for your codebase in minutes.

Try Supermodel Free