Commit 0e8f1af5 authored by Federico Sismondi's avatar Federico Sismondi
Browse files

fix amqp exchange env var issue

parent 73539a20
......@@ -417,11 +417,11 @@ if __name__ == '__main__':
channel = connection.channel()
logging.info("AMQP connection established")
# in case its not declared
connection.channel().exchange_declare(exchange=AMQP_EXCHANGE,
type='topic',
durable=True,
)
# # in case its not declared
# connection.channel().exchange_declare(exchange=AMQP_EXCHANGE,
# type='topic',
# durable=True,
# )
def quitCallback():
......
......@@ -43,7 +43,7 @@ VERSION = '0.0.3'
# defaults vars
AMQP_URL = 'amqp://guest:guest@localhost'
AMQP_EXCHANGE = 'amq.default'
AMQP_EXCHANGE = 'amq.topic'
try:
AMQP_URL = str(os.environ['AMQP_URL'])
......
Supports Markdown
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