Fixed bug, missed insertion into flight zone of QOS1 messages

2016-06-18 12:21:21 +02:00
parent 0c4f7fa393
commit 693a9a454f
1 changed files with 3 additions and 1 deletions
@@ -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());