Commit 659ac3c7 authored by Dan Jones's avatar Dan Jones
Browse files

Merge branch '38-fix-log-write-in-rmq-subscribe' into 'dev'

Resolve "Fix log write in rmq subscribe"

Closes #38

See merge request !18
parents 429b5413 218fd4fd
Pipeline #109195 passed with stages
in 1 minute and 2 seconds
...@@ -193,7 +193,9 @@ def publish(queue_name, exchange_name): ...@@ -193,7 +193,9 @@ def publish(queue_name, exchange_name):
def subscribe(queue_name, exchange_name, topic=None): def subscribe(queue_name, exchange_name, topic=None):
logging.debug(f"Subscribe queue: {queue_name} to {exchange} with topic {topic}") logging.debug(
f"Subscribe queue: {queue_name} to {exchange_name} with topic {topic}"
)
# setup bindings between queue and exchange, # setup bindings between queue and exchange,
# exchange_type is either 'fanout' or 'topic' based on if the topic arg is passed # exchange_type is either 'fanout' or 'topic' based on if the topic arg is passed
connection, channel = pika_connect(host=host) connection, channel = pika_connect(host=host)
......
Markdown is supported
0% or .
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment