From d259d7c5e74b7576d17cdbb95cc742eaaa6487b5 Mon Sep 17 00:00:00 2001
From: andrea <andrea@samarcanda>
Date: Thu, 26 Dec 2013 11:46:34 +0100
Subject: [PATCH] Missed in 2 commits ago

---
 .../mqtt/moquette/messaging/spi/impl/SimpleMessaging.java    | 5 ++++-
 1 file changed, 4 insertions(+), 1 deletion(-)

diff --git a/broker/src/main/java/org/dna/mqtt/moquette/messaging/spi/impl/SimpleMessaging.java b/broker/src/main/java/org/dna/mqtt/moquette/messaging/spi/impl/SimpleMessaging.java
index c0e39d87..b0f8c2d6 100644
--- a/broker/src/main/java/org/dna/mqtt/moquette/messaging/spi/impl/SimpleMessaging.java
+++ b/broker/src/main/java/org/dna/mqtt/moquette/messaging/spi/impl/SimpleMessaging.java
@@ -29,7 +29,7 @@ public class SimpleMessaging implements IMessaging, EventHandler<ValueEvent> {
 
     private static final Logger LOG = LoggerFactory.getLogger(SimpleMessaging.class);
     
-    private SubscriptionsStore subscriptions = new SubscriptionsStore();
+    private SubscriptionsStore subscriptions;
     
     private RingBuffer<ValueEvent> m_ringBuffer;
 
@@ -53,6 +53,7 @@ public class SimpleMessaging implements IMessaging, EventHandler<ValueEvent> {
     }
 
     public void init() {
+        subscriptions = new SubscriptionsStore();
         m_executor = Executors.newFixedThreadPool(1);
 
         m_ringBuffer = new RingBuffer<ValueEvent>(ValueEvent.EVENT_FACTORY, 1024 * 32);
@@ -179,5 +180,7 @@ public class SimpleMessaging implements IMessaging, EventHandler<ValueEvent> {
 
 //        m_eventProcessor.halt();
         m_executor.shutdown();
+        
+        subscriptions = null;
     }
 }