From 6659ceff5c56aec16aec787aefcccc6101cb2343 Mon Sep 17 00:00:00 2001
From: Ernest Okot <okot08@gmail.com>
Date: Tue, 1 May 2018 19:30:24 +0300
Subject: [PATCH] fix: changed subscription callback signature

---
 src/topic/consumer.js | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git a/src/topic/consumer.js b/src/topic/consumer.js
index e235224..abeaf4f 100644
--- 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