anna/IM-server-new
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

ProtocolProcessorTest#testCleanRetainedStoreAfterAQoS0AndRetainedTrue:

Browse Source 
check added if test is in the correct state
This commit is contained in:
Andreas Mager
2017-01-30 16:07:16 +01:00
parent 1c64186a00
commit 94475d2b04
1 changed files with 9 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files
broker/src/test/java/io/moquette/spi/impl/ProtocolProcessorTest.java
+9 -2
View File
@@ -461,7 +461,14 @@ public class ProtocolProcessorTest {
.messageId(100) .messageId(100)
.build(); .build();
m_processor.processPublish(m_channel, msg); 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 //Exercise
MqttPublishMessage cleanPubMsg = MessageBuilder.publish() MqttPublishMessage cleanPubMsg = MessageBuilder.publish()
.topicName(FAKE_TOPIC) .topicName(FAKE_TOPIC)
@@ -473,7 +480,7 @@ public class ProtocolProcessorTest {
m_processor.processPublish(m_channel, cleanPubMsg); m_processor.processPublish(m_channel, cleanPubMsg);
//Verify //Verify
Collection<IMessagesStore.StoredMessage> messages = m_messagesStore.searchMatching(new IMatchingCondition() { messages = m_messagesStore.searchMatching(new IMatchingCondition() {
public boolean match(String key) { public boolean match(String key) {
return SubscriptionsStore.matchTopics(key, FAKE_TOPIC); return SubscriptionsStore.matchTopics(key, FAKE_TOPIC);
} }