Skip to content
Snippets Groups Projects
Commit ab4dd08f authored by Bo-Chun Chen's avatar Bo-Chun Chen
Browse files

Separate queue binding from connect function

Since publish doesn't have to do binding,
 separate binding make it cleaner and less trouble
parent 4a402dff
No related branches found
No related tags found
1 merge request!18Redesign RabbitMQ
......@@ -65,11 +65,11 @@ class RCRMQ(object):
exchange_type=self.EXCHANGE_TYPE,
durable=True)
if self.QUEUE is not None:
self._channel.queue_declare(queue=self.QUEUE, durable=self.DURABLE)
self._channel.queue_bind(exchange=self.EXCHANGE,
queue=self.QUEUE,
routing_key=self.ROUTING_KEY)
def bind_queue(self):
self._channel.queue_declare(queue=self.QUEUE, durable=self.DURABLE)
self._channel.queue_bind(exchange=self.EXCHANGE,
queue=self.QUEUE,
routing_key=self.ROUTING_KEY)
def disconnect(self):
self._channel.close()
......@@ -103,6 +103,8 @@ class RCRMQ(object):
if self._connection is None:
self.connect()
self.bind_queue()
self._consumer_tag = self._channel.basic_consume(self.QUEUE,obj['cb'])
self._consuming = True
try:
......
0% Loading or .
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment