From b0ef8114b67f72f2bf10d79909d6647f8edf0069 Mon Sep 17 00:00:00 2001 From: "selva.andre" Date: Sat, 2 Aug 2014 10:56:34 +0200 Subject: [PATCH] Minor change, simulated a client connect to avoid staktrace in log --- .../moquette/messaging/spi/impl/ProtocolProcessorTest.java | 5 +++-- 1 file changed, 3 insertions(+), 2 deletions(-) diff --git a/broker/src/test/java/org/dna/mqtt/moquette/messaging/spi/impl/ProtocolProcessorTest.java b/broker/src/test/java/org/dna/mqtt/moquette/messaging/spi/impl/ProtocolProcessorTest.java index c7c6f635..f17fb0d9 100644 --- a/broker/src/test/java/org/dna/mqtt/moquette/messaging/spi/impl/ProtocolProcessorTest.java +++ b/broker/src/test/java/org/dna/mqtt/moquette/messaging/spi/impl/ProtocolProcessorTest.java @@ -517,6 +517,9 @@ public class ProtocolProcessorTest { */ @Test public void testCleanRetainedStoreAfterAQoS0AndRetainedTrue() { + //force a connect + connMsg.setClientID("Publisher"); + m_processor.processConnect(m_session, connMsg); //prepare and existing retained store ByteBuffer payload = ByteBuffer.allocate(5).put("Hello".getBytes()); PublishEvent pubEvt = new PublishEvent(FAKE_TOPIC, AbstractMessage.QOSType.LEAST_ONE, payload, true, "Publisher"); @@ -527,8 +530,6 @@ public class ProtocolProcessorTest { m_processor.processPublish(cleanPubEvt); //Verify -// List retainedPublishes = m_storageService.retrievePersistedPublishes("Publisher"); - Collection messages = m_storageService.searchMatching(new IMatchingCondition() { public boolean match(String key) { return SubscriptionsStore.matchTopics(key, FAKE_TOPIC);