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

testSubAckMessageWithFailureInPayload() — netty Function Reference

Architecture documentation for the testSubAckMessageWithFailureInPayload() function in MqttCodecTest.java from the netty codebase.

Function java Buffer Allocators calls 4

Entity Profile

Dependency Diagram

graph TD
  1d680dc9_3520_0515_df6e_1187c28ed5a8["testSubAckMessageWithFailureInPayload()"]
  f4aba1d9_6b30_ec96_9eaa_4c5557b5796d["MqttCodecTest"]
  1d680dc9_3520_0515_df6e_1187c28ed5a8 -->|defined in| f4aba1d9_6b30_ec96_9eaa_4c5557b5796d
  197bd55c_5609_1d4e_0766_1c162f70b9a8["MqttSubAckMessage()"]
  1d680dc9_3520_0515_df6e_1187c28ed5a8 -->|calls| 197bd55c_5609_1d4e_0766_1c162f70b9a8
  25a0f3b3_7f7d_acef_16ff_03dee5be358c["validateFixedHeaders()"]
  1d680dc9_3520_0515_df6e_1187c28ed5a8 -->|calls| 25a0f3b3_7f7d_acef_16ff_03dee5be358c
  94a38f3e_2e39_bc51_ecb9_6dd1536b3dec["validateMessageIdVariableHeader()"]
  1d680dc9_3520_0515_df6e_1187c28ed5a8 -->|calls| 94a38f3e_2e39_bc51_ecb9_6dd1536b3dec
  33e39df4_bd01_3937_3c05_b2d4e5d48492["validateSubAckPayload()"]
  1d680dc9_3520_0515_df6e_1187c28ed5a8 -->|calls| 33e39df4_bd01_3937_3c05_b2d4e5d48492
  style 1d680dc9_3520_0515_df6e_1187c28ed5a8 fill:#6366f1,stroke:#818cf8,color:#fff

Relationship Graph

Source Code

codec-mqtt/src/test/java/io/netty/handler/codec/mqtt/MqttCodecTest.java lines 352–373

    @Test
    public void testSubAckMessageWithFailureInPayload() throws Exception {
        MqttFixedHeader mqttFixedHeader =
                new MqttFixedHeader(MqttMessageType.SUBACK, false, MqttQoS.AT_MOST_ONCE, false, 0);
        MqttMessageIdVariableHeader mqttMessageIdVariableHeader = MqttMessageIdVariableHeader.from(12345);
        MqttSubAckPayload mqttSubAckPayload = new MqttSubAckPayload(MqttQoS.FAILURE.value());
        MqttSubAckMessage message =
                new MqttSubAckMessage(mqttFixedHeader, mqttMessageIdVariableHeader, mqttSubAckPayload);

        ByteBuf byteBuf = MqttEncoder.doEncode(ctx, message);

        mqttDecoder.channelRead(ctx, byteBuf);

        assertEquals(1, out.size());

        MqttSubAckMessage decodedMessage = (MqttSubAckMessage) out.get(0);
        validateFixedHeaders(message.fixedHeader(), decodedMessage.fixedHeader());
        validateMessageIdVariableHeader(message.variableHeader(), decodedMessage.variableHeader());
        validateSubAckPayload(message.payload(), decodedMessage.payload());
        assertEquals(1, decodedMessage.payload().grantedQoSLevels().size());
        assertEquals(MqttQoS.FAILURE, MqttQoS.valueOf(decodedMessage.payload().grantedQoSLevels().get(0)));
    }

Domain

Subdomains

Defined In

Calls

Source

Frequently Asked Questions

What does testSubAckMessageWithFailureInPayload() do?
testSubAckMessageWithFailureInPayload() is a function in the netty codebase, defined in codec-mqtt/src/test/java/io/netty/handler/codec/mqtt/MqttCodecTest.java.
Where is testSubAckMessageWithFailureInPayload() defined?
testSubAckMessageWithFailureInPayload() is defined in codec-mqtt/src/test/java/io/netty/handler/codec/mqtt/MqttCodecTest.java at line 352.
What does testSubAckMessageWithFailureInPayload() call?
testSubAckMessageWithFailureInPayload() calls 4 function(s): MqttSubAckMessage, validateFixedHeaders, validateMessageIdVariableHeader, validateSubAckPayload.

Analyze Your Own Codebase

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

Try Supermodel Free