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 77487772..92f935b5 100644 --- a/broker/src/main/java/io/moquette/spi/impl/ProtocolProcessor.java +++ b/broker/src/main/java/io/moquette/spi/impl/ProtocolProcessor.java @@ -284,7 +284,9 @@ public class ProtocolProcessor { LOG.info("republishing stored messages to client <{}>", clientSession.clientID); for (IMessagesStore.StoredMessage pubEvt : publishedEvents) { - //TODO put in flight zone + //put in flight zone + LOG.trace("Adding to inflight <{}>", pubEvt.getMessageID()); + clientSession.inFlightAckWaiting(pubEvt.getGuid(), pubEvt.getMessageID()); directSend(clientSession, pubEvt.getTopic(), pubEvt.getQos(), pubEvt.getMessage(), false, pubEvt.getMessageID()); clientSession.removeEnqueued(pubEvt.getGuid());