MqttMessage() — netty Function Reference

Architecture documentation for the MqttMessage() function in MqttDecoder.java from the netty codebase.

Function java Buffer Allocators

Entity Profile

Buffer→ Allocators→ MqttMessage() — netty Function Reference

Dependency Diagram

graph TD
  aadf437a_1f0b_b0d0_59f0_96569761a7d4["MqttMessage()"]
  c4faa729_e212_a3dd_9d90_3e8fd908d755["MqttDecoder"]
  aadf437a_1f0b_b0d0_59f0_96569761a7d4 -->|defined in| c4faa729_e212_a3dd_9d90_3e8fd908d755
  style aadf437a_1f0b_b0d0_59f0_96569761a7d4 fill:#6366f1,stroke:#818cf8,color:#fff

Relationship Graph

Source Code

codec-mqtt/src/main/java/io/netty/handler/codec/mqtt/MqttDecoder.java lines 170–173

    private MqttMessage invalidMessage(Throwable cause) {
      checkpoint(DecoderState.BAD_MESSAGE);
      return MqttMessageFactory.newInvalidMessage(mqttFixedHeader, variableHeader, cause);
    }