Add TtnListenerTest

ttnhabbridge/src/main/java/nl/sikken/bertrik/hab/ttn/TtnListener.java

@@ -77,7 +77,7 @@ public final class TtnListener {
      * @param mqttMessage the message
      * @throws Exception who knows?
      */
-    private void messageArrived(String topic, MqttMessage mqttMessage) throws Exception {
+    void messageArrived(String topic, MqttMessage mqttMessage) throws Exception {
         String message = new String(mqttMessage.getPayload(), StandardCharsets.US_ASCII);
         LOG.info("Message arrived on topic '{}': {}", topic, message);
         // forward it to our user

ttnhabbridge/src/test/java/nl/sikken/bertrik/hab/ttn/TtnListenerTest.java

@@ -0,0 +1,22 @@
+package nl.sikken.bertrik.hab.ttn;
+
+import java.nio.charset.StandardCharsets;
+
+import org.eclipse.paho.client.mqttv3.MqttMessage;
+import org.junit.Test;
+import org.mockito.Mockito;
+
+public final class TtnListenerTest {
+
+	@Test
+	public void testListener() throws Exception {
+		IMessageReceived listener = Mockito.mock(IMessageReceived.class);
+		TtnListener ttnListener = new TtnListener(listener, "tcp://localhost", "appId", "appKey");
+		String msg = "message";
+		ttnListener.messageArrived("topic", new MqttMessage(msg.getBytes(StandardCharsets.US_ASCII)));
+		
+		// verify that the message is forwarded to the listener
+		Mockito.verify(listener).messageReceived(Mockito.eq("topic"), Mockito.eq("message"));
+	}
+	
+}