diff options
Diffstat (limited to 'rmq.py')
| -rw-r--r-- | rmq.py | 2 | 
1 files changed, 0 insertions, 2 deletions
| @@ -25,7 +25,6 @@ class Rmq:      def consume(self, queue=QUEUE, callback=None, thread_ws=None, run_once=False):          """Subscribe to read from a RMQ channel.""" -          while True:              try:                  connection = pika.BlockingConnection(self.con_params) @@ -72,7 +71,6 @@ class Rmq:      def publish(self, message, queue=QUEUE, routingkey=ROUTING_KEY, exchange=EXCHANGE):          """Open a connection to publish (write) to a RMQ channel.""" -          try:              connection = pika.BlockingConnection(self.con_params) | 
