From 76fb5cee72b9c6aaab8b97454067af991b79090d Mon Sep 17 00:00:00 2001
From: Frederic Beister <frederic.beister@dedrone.com>
Date: Tue, 21 Mar 2017 14:26:13 +0100
Subject: [PATCH] Prevent usage of MsgId 0 when wrapping around

---
 .../java/io/moquette/spi/persistence/MapDBSessionsStore.java    | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git a/broker/src/main/java/io/moquette/spi/persistence/MapDBSessionsStore.java b/broker/src/main/java/io/moquette/spi/persistence/MapDBSessionsStore.java
index e1318041..2f3b9c8a 100644
--- a/broker/src/main/java/io/moquette/spi/persistence/MapDBSessionsStore.java
+++ b/broker/src/main/java/io/moquette/spi/persistence/MapDBSessionsStore.java
@@ -212,7 +212,7 @@ class MapDBSessionsStore implements ISessionsStore {
         }
 
         int maxId = inFlightForClient.isEmpty() ? 0 : Collections.max(inFlightForClient);
-        int nextPacketId = (maxId + 1) % 0xFFFF;
+        int nextPacketId = (maxId % 0xFFFF) + 1;
         inFlightForClient.add(nextPacketId);
         if (LOG.isDebugEnabled()) {
             LOG.debug("The next packet ID has been generated. CId= {}, result = {}.", clientID, nextPacketId);