From 834dc80e794de6693406c80e053d28075f63f493 Mon Sep 17 00:00:00 2001
From: Steve Nyemba <steve@the-phi.com>
Date: Wed, 4 Mar 2020 02:23:21 -0600
Subject: [PATCH] bug fix (updating pika interface)

---
 setup.py           | 2 +-
 transport/queue.py | 5 +++--
 2 files changed, 4 insertions(+), 3 deletions(-)

diff --git a/setup.py b/setup.py
index cc1bb64..af06eda 100644
--- a/setup.py
+++ b/setup.py
@@ -8,7 +8,7 @@ def read(fname):
     return open(os.path.join(os.path.dirname(__file__), fname)).read() 
 args    = {
     "name":"data-transport",
-    "version":"1.1.0",
+    "version":"1.1.2",
     "author":"The Phi Technology LLC","author_email":"info@the-phi.com",
     "license":"MIT",
     "packages":["transport"]}
diff --git a/transport/queue.py b/transport/queue.py
index dcc2b57..485b771 100644
--- a/transport/queue.py
+++ b/transport/queue.py
@@ -142,7 +142,7 @@ class QueueReader(MessageQueue,Reader):
 		#self.exchange = params['uid']
 		#self.queue = params['qid']
 		MessageQueue.__init__(self,**params);
-		self.init()
+		# self.init()
 		if 'durable' in params :
 			self.durable = True
 		else:
@@ -198,13 +198,14 @@ class QueueReader(MessageQueue,Reader):
 		#
 		if isinstance(self.queue,str) :
 					self.queue = [self.queue]
+		
 		for qid in self.queue:
 			self.init(qid)
 			# r[qid] = []
 			
 			if self.qhandler.method.message_count > 0:
 				
-				self.channel.basic_consume(self.callback,queue=qid,no_ack=False);
+				self.channel.basic_consume(queue=qid,on_message_callback=self.callback,auto_ack=False);
 				self.channel.start_consuming()
 			else: