From 376140cab8f9be96be4b40c30c283cecf83f74fe Mon Sep 17 00:00:00 2001 From: "selva.andre" Date: Fri, 31 Aug 2012 17:07:49 +0200 Subject: [PATCH] Fixed API used by test calls --- .../mqtt/moquette/messaging/spi/impl/SimpleMessagingTest.java | 2 +- .../test/java/org/dna/mqtt/moquette/server/MQTTHandlerTest.java | 2 +- 2 files changed, 2 insertions(+), 2 deletions(-) diff --git a/parser/src/test/java/org/dna/mqtt/moquette/messaging/spi/impl/SimpleMessagingTest.java b/parser/src/test/java/org/dna/mqtt/moquette/messaging/spi/impl/SimpleMessagingTest.java index fe19a9af..811ce739 100644 --- a/parser/src/test/java/org/dna/mqtt/moquette/messaging/spi/impl/SimpleMessagingTest.java +++ b/parser/src/test/java/org/dna/mqtt/moquette/messaging/spi/impl/SimpleMessagingTest.java @@ -57,7 +57,7 @@ public class SimpleMessagingTest { // messaging.setNotifier(notifier); //Exercise - PublishEvent pubEvt = new PublishEvent(FAKE_TOPIC, QOSType.MOST_ONE, "Hello".getBytes(), false); + PublishEvent pubEvt = new PublishEvent(FAKE_TOPIC, QOSType.MOST_ONE, "Hello".getBytes(), false, "FakeCLI"); messaging.processPublish(pubEvt); //Verify diff --git a/parser/src/test/java/org/dna/mqtt/moquette/server/MQTTHandlerTest.java b/parser/src/test/java/org/dna/mqtt/moquette/server/MQTTHandlerTest.java index 22a59916..22c79781 100644 --- a/parser/src/test/java/org/dna/mqtt/moquette/server/MQTTHandlerTest.java +++ b/parser/src/test/java/org/dna/mqtt/moquette/server/MQTTHandlerTest.java @@ -86,7 +86,7 @@ public class MQTTHandlerTest { //Verify assertEquals(ConnAckMessage.CONNECTION_ACCEPTED, m_returnCode); verify(mockedMessaging).publish(eq("topic"), eq("Topic message".getBytes()), - any(AbstractMessage.QOSType.class), anyBoolean()); + any(AbstractMessage.QOSType.class), anyBoolean(), eq("123")); }