From 1bb7c1bd0a5c9ff6c119b5388ca26f2d4d692555 Mon Sep 17 00:00:00 2001 From: Steve Nyemba Date: Mon, 2 Mar 2020 11:33:35 -0600 Subject: [PATCH] Bug fix with queueReader --- setup.py | 2 +- transport/queue.py | 4 ++-- 2 files changed, 3 insertions(+), 3 deletions(-) diff --git a/setup.py b/setup.py index b95c6d2..cc1bb64 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.0.9", + "version":"1.1.0", "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 f88fcd0..dcc2b57 100644 --- a/transport/queue.py +++ b/transport/queue.py @@ -172,7 +172,7 @@ class QueueReader(MessageQueue,Reader): r = stream - qid = self.info.method.queue + qid = self.qhandler.method.queue if qid not in self.data : self.data[qid] = [] @@ -202,7 +202,7 @@ class QueueReader(MessageQueue,Reader): self.init(qid) # r[qid] = [] - if self.info.method.message_count > 0: + if self.qhandler.method.message_count > 0: self.channel.basic_consume(self.callback,queue=qid,no_ack=False); self.channel.start_consuming()