diff --git a/broker/src/main/java/io/moquette/broker/NettyUtils.java b/broker/src/main/java/io/moquette/broker/NettyUtils.java index bbbb8cfa7..a8183cbfd 100644 --- a/broker/src/main/java/io/moquette/broker/NettyUtils.java +++ b/broker/src/main/java/io/moquette/broker/NettyUtils.java @@ -83,7 +83,7 @@ public static String userName(Channel channel) { public static MqttMessage validateMessage(Object message) throws IOException, ClassCastException { MqttMessage msg = (MqttMessage) message; if (msg.decoderResult() != null && msg.decoderResult().isFailure()) { - throw new IOException("invalid massage", msg.decoderResult().cause()); + throw new IOException("Invalid message", msg.decoderResult().cause()); } if (msg.fixedHeader() == null) { throw new IOException("Unknown packet, no fixedHeader present, no cause provided");