fix: changed subscription callback signature

freelyformd · May 1, 2018 · 6659cef · 6659cef
1 parent be4d785
commit 6659cef
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/src/topic/consumer.js b/src/topic/consumer.js
@@ -71,7 +71,7 @@ class TopicConsumer {
       }
 
       try {
-        await callback(JSON.parse(msg.content.toString()), topic);
+        await callback(topic, JSON.parse(msg.content.toString()));
         this.channel.ack(msg);
       } catch (error) {
         // Catch error