testUnknownMessageType() — netty Function Reference

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

Function java Buffer Allocators

Entity Profile

Buffer→ Allocators→ testUnknownMessageType() — netty Function Reference

Dependency Diagram

graph TD
  06a41263_bbf6_ecc7_687c_362a9a81e045["testUnknownMessageType()"]
  f4aba1d9_6b30_ec96_9eaa_4c5557b5796d["MqttCodecTest"]
  06a41263_bbf6_ecc7_687c_362a9a81e045 -->|defined in| f4aba1d9_6b30_ec96_9eaa_4c5557b5796d
  style 06a41263_bbf6_ecc7_687c_362a9a81e045 fill:#6366f1,stroke:#818cf8,color:#fff

Relationship Graph

Source Code

codec-mqtt/src/test/java/io/netty/handler/codec/mqtt/MqttCodecTest.java lines 411–428

    @Test
    public void testUnknownMessageType() throws Exception {

        final MqttMessage message = createMessageWithFixedHeader(MqttMessageType.PINGREQ);
        ByteBuf byteBuf = MqttEncoder.doEncode(ctx, message);

        // setting an invalid message type (15, reserved and forbidden by MQTT 3.1.1 spec)
        byteBuf.setByte(0, 0xF0);
        mqttDecoder.channelRead(ctx, byteBuf);

        assertEquals(1, out.size());

        final MqttMessage decodedMessage = (MqttMessage) out.get(0);
        assertTrue(decodedMessage.decoderResult().isFailure());
        Throwable cause = decodedMessage.decoderResult().cause();
        assertInstanceOf(DecoderException.class, cause);
        assertEquals("AUTH message requires at least MQTT 5", cause.getMessage());
    }