From 94475d2b043f52fc0642c50bab8f00de1a43bd01 Mon Sep 17 00:00:00 2001
From: Andreas Mager <ama@qsc.de>
Date: Thu, 26 Jan 2017 17:19:12 +0100
Subject: [PATCH] 
 ProtocolProcessorTest#testCleanRetainedStoreAfterAQoS0AndRetainedTrue: check
 added if test is in the correct state

---
 .../io/moquette/spi/impl/ProtocolProcessorTest.java   | 11 +++++++++--
 1 file changed, 9 insertions(+), 2 deletions(-)

diff --git a/broker/src/test/java/io/moquette/spi/impl/ProtocolProcessorTest.java b/broker/src/test/java/io/moquette/spi/impl/ProtocolProcessorTest.java
index 95a27cf4..825661b6 100644
--- a/broker/src/test/java/io/moquette/spi/impl/ProtocolProcessorTest.java
+++ b/broker/src/test/java/io/moquette/spi/impl/ProtocolProcessorTest.java
@@ -461,7 +461,14 @@ public class ProtocolProcessorTest {
                 .messageId(100)
                 .build();
         m_processor.processPublish(m_channel, msg);
-        
+
+        Collection<IMessagesStore.StoredMessage> messages = m_messagesStore.searchMatching(new IMatchingCondition() {
+            public boolean match(String key) {
+                return  SubscriptionsStore.matchTopics(key, FAKE_TOPIC);
+            }
+        });
+        assertFalse(messages.isEmpty());
+
         //Exercise
         MqttPublishMessage cleanPubMsg = MessageBuilder.publish()
                 .topicName(FAKE_TOPIC)
@@ -473,7 +480,7 @@ public class ProtocolProcessorTest {
         m_processor.processPublish(m_channel, cleanPubMsg);
         
         //Verify
-        Collection<IMessagesStore.StoredMessage> messages = m_messagesStore.searchMatching(new IMatchingCondition() {
+        messages = m_messagesStore.searchMatching(new IMatchingCondition() {
             public boolean match(String key) {
                 return  SubscriptionsStore.matchTopics(key, FAKE_TOPIC);
             }