Now emitting data

elasticio · Dec 16, 2016 · 5a85209 · 5a85209
1 parent 1e50e4a
commit 5a85209
Showing 1 changed file with 4 additions and 3 deletions.
diff --git a/lib/triggers/consume.js b/lib/triggers/consume.js
@@ -17,9 +17,10 @@ function processAction(msg, cfg) {
   const amqpURI = cfg.amqpURI;
   const amqpExchange = cfg.topic;
   const queueName = `eio_consumer_${process.env.ELASTICIO_TASK_ID}_${process.env.ELASTICIO_USER_ID}`;
-  const keys = (cfg.bindingKeys || '#').split(',').map((s)=>s.trim());
+  const keys = (cfg.bindingKeys || '#').split(',').map((s) => s.trim());
   const consumer = (msg) => {
-      console.log('consuming message %s in generator', JSON.stringify(msg.content.toString()));
+    console.log('Have got message %s', JSON.stringify(msg.content.toString()));
+    this.emit('data', eioUtils.newMessageWithBody({}));
   };
   co(function*() {
     console.log('Connecting to amqpURI=%s', amqpURI);
@@ -38,7 +39,7 @@ function processAction(msg, cfg) {
       autoDelete: true
     });
 
-    for(let key of keys) {
+    for (let key of keys) {
       console.log(`Binding queue to exchange queue=${queueName} exchange=${amqpExchange} bindingKey=${key}`);
       yield channel.bindQueue(queueName, amqpExchange, key);
     }