Fixed API used by test calls

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

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"));
     }