From 33bc23b4e100ff26b5fd2a8fdb35b228f584423e Mon Sep 17 00:00:00 2001
From: andsel <selva.andre@gmail.com>
Date: Tue, 22 Sep 2015 15:55:52 +0200
Subject: [PATCH] Added null check to fix issue #93

---
 .../org/eclipse/moquette/spi/impl/MemoryStorageService.java    | 3 +++
 1 file changed, 3 insertions(+)

diff --git a/broker/src/main/java/org/eclipse/moquette/spi/impl/MemoryStorageService.java b/broker/src/main/java/org/eclipse/moquette/spi/impl/MemoryStorageService.java
index 0448dde7..6f9a9a0b 100644
--- a/broker/src/main/java/org/eclipse/moquette/spi/impl/MemoryStorageService.java
+++ b/broker/src/main/java/org/eclipse/moquette/spi/impl/MemoryStorageService.java
@@ -104,6 +104,9 @@ public class MemoryStorageService implements IMessagesStore, ISessionsStore {
     @Override
     public void removeMessageInSession(String clientID, Integer messageID) {
         List<PublishEvent> events = m_persistentMessageStore.get(clientID);
+        if (events == null) {
+            return;
+        }
         PublishEvent toRemoveEvt = null;
         for (PublishEvent evt : events) {
             if (evt.getMessageID() == null && messageID == null) {