diff --git a/parser/src/main/java/org/dna/mqtt/moquette/messaging/spi/impl/HawtDBStorageService.java b/parser/src/main/java/org/dna/mqtt/moquette/messaging/spi/impl/HawtDBStorageService.java
index 27e592dc..4f9d52d2 100644
--- a/parser/src/main/java/org/dna/mqtt/moquette/messaging/spi/impl/HawtDBStorageService.java
+++ b/parser/src/main/java/org/dna/mqtt/moquette/messaging/spi/impl/HawtDBStorageService.java
@@ -48,6 +48,7 @@ public class HawtDBStorageService implements IStorageService {
         initRetainedStore();
         //init the message store for QoS 1/2 messages in clean sessions
         initPersistentMessageStore();
+        initInflightMessageStore();
     }
 
     private void initRetainedStore() {