업데이트 'src/main/python/kr/co/swh/lecture/opensource/rabbitmq/receiveTopic.py'

src/main/python/kr/co/swh/lecture/opensource/rabbitmq/receiveTopic.py

@@ -4,19 +4,20 @@ import sys
 connection = pika.BlockingConnection(pika.ConnectionParameters(host='183.99.87.90'))
 channel = connection.channel()
 
-channel.exchange_declare(exchange='topic_logs', exchange_type='topic')
+exchange_name = 'topic_logs'
+channel.exchange_declare(exchange=exchange_name, exchange_type='topic')
 
-result = channel.queue_declare(queue='', exclusive=True)
+result = channel.queue_declare(queue='')
 queue_name = result.method.queue
 
-channel.queue_bind(exchange='topic_logs',
+channel.queue_bind(exchange=exchange_name,
                        queue=queue_name,
                        routing_key="key")
 
 def callback(ch, method, properties, body):
-    print(" [x] %r:%r" % (method.routing_key, body))
+    print(" [x] %s:%s" % (method.routing_key, body))
 
 channel.basic_consume(
-        queue=queue_name, on_message_callback=callback, auto_ack=True)
+        queue=queue_name, on_message_callback=callback)
 
 channel.start_consuming()