From 6f88060ffe3ff43329bf0c66282011ceabb7d917 Mon Sep 17 00:00:00 2001
From: "selva.andre" <selva.andre@gmail.com>
Date: Sat, 1 Sep 2012 16:44:47 +0200
Subject: [PATCH] Missed initialization in previous commit

---
 .../mqtt/moquette/messaging/spi/impl/HawtDBStorageService.java   | 1 +
 1 file changed, 1 insertion(+)

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() {