1 files changed, 16 insertions, 2 deletions
diff --git a/diller-mqtt.js b/diller-mqtt.js
index db6fc2b..e528bb4 100644
--- a/diller-mqtt.js
+++ b/diller-mqtt.js
@@ -4,5 +4,19 @@ var injector = new di.Injector();
 var config = injector.get(require('./src/DillerConfig'));
 config.configureLogging('mqtt');
 
-var dillerMqtt = injector.get(require('./src/mqtt/DillerMqtt'));
-dillerMqtt.run();
+/**
+ * @type {function(function(PgTx, DillerDao, Diller))} tx
+ */
+var tx = injector.get(require('./src/DillerTx'));
+
+/**
+ * @type DillerMqttClient
+ */
+var dillerMqttClient = injector.get(require('./src/mqtt/DillerMqttClient'));
+dillerMqttClient.run('mqtt');
+
+dillerMqttClient.on('message', function (topic, message, payload) {
+  tx(function (pg, dao, diller) {
+    return diller.onMessage(topic, message, payload);
+  });
+});