aboutsummaryrefslogtreecommitdiffstats
path: root/rmq.py
diff options
context:
space:
mode:
authorGravatar Chris Goes <[email protected]>2019-04-29 21:12:58 -0600
committerGravatar GitHub <[email protected]>2019-04-29 21:12:58 -0600
commit40d4972a3420a1f772a9d0464a4369575c11cb5f (patch)
treed30421204a84a104da5411981e5b49c63ede5f18 /rmq.py
parentMerge pull request #19 from python-discord/urllib3-vuln-fix (diff)
parentRemove space between ignored flake8 rules (diff)
Merge pull request #21 from python-discord/docstring-lint-change
Docstring lint change
Diffstat (limited to 'rmq.py')
-rw-r--r--rmq.py2
1 files changed, 0 insertions, 2 deletions
diff --git a/rmq.py b/rmq.py
index 919ef19..29fc448 100644
--- a/rmq.py
+++ b/rmq.py
@@ -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)