From d567d08591493688ce1fcadd1b416ad1c78cb9f6 Mon Sep 17 00:00:00 2001
From: Wolfgang Hottgenroth <wolfgang.hottgenroth@icloud.com>
Date: Mon, 11 Jun 2018 17:31:14 +0200
Subject: [PATCH] start with mqtt output support

---
 measurementCollector.props                                    | 2 +-
 .../de/hottis/measurementCollector/MeasurementCollector.java  | 4 +++-
 2 files changed, 4 insertions(+), 2 deletions(-)

diff --git a/measurementCollector.props b/measurementCollector.props
index e2873f2..b2dfde6 100644
--- a/measurementCollector.props
+++ b/measurementCollector.props
@@ -1,4 +1,4 @@
-mqtt.broker = tcp://172.16.2.15:1883
+mqtt.broker = tcp://127.0.0.1
 ;mqtt.broker = tcp://eupenstrasse20.dynamic.hottis.de:2883
 ;mqtt.username = tron
 ;mqtt.password = geheim123
diff --git a/src/main/java/de/hottis/measurementCollector/MeasurementCollector.java b/src/main/java/de/hottis/measurementCollector/MeasurementCollector.java
index 2a48a7c..c89e1f4 100644
--- a/src/main/java/de/hottis/measurementCollector/MeasurementCollector.java
+++ b/src/main/java/de/hottis/measurementCollector/MeasurementCollector.java
@@ -1,6 +1,7 @@
 package de.hottis.measurementCollector;
 
 import de.hottis.common.JmsTopic;
+import de.hottis.common.ConsoleQueue;
 import de.hottis.smarthomelib.ADataObject;
 import java.io.FileInputStream;
 import java.util.Properties;
@@ -26,7 +27,8 @@ public class MeasurementCollector {
 		MqttReceiver mqttReceiver = new MqttReceiver(config);
 		logger.debug("MqttReceiver started");
 		
-		JmsTopic<ADataObject> queue = new JmsTopic<>(config, JmsTopic.Mode.PRODUCER); 
+		// JmsTopic<ADataObject> queue = new JmsTopic<>(config, JmsTopic.Mode.PRODUCER); 
+                ConsoleQueue<ADataObject> queue = new ConsoleQueue<>(config);
 		queue.init();
 		
 		MBusParser mbusParser = new MBusParser(config, queue);