diff --git a/broker/src/main/java/io/moquette/spi/impl/ProtocolProcessor.java b/broker/src/main/java/io/moquette/spi/impl/ProtocolProcessor.java index 5f020e4b..3718e133 100644 --- a/broker/src/main/java/io/moquette/spi/impl/ProtocolProcessor.java +++ b/broker/src/main/java/io/moquette/spi/impl/ProtocolProcessor.java @@ -100,9 +100,9 @@ public class ProtocolProcessor { final String clientID; final long packetId; - RunningSubscription(String clientID, long packeId) { + RunningSubscription(String clientID, long packetId) { this.clientID = clientID; - this.packetId = packeId; + this.packetId = packetId; } @Override