浏览代码

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

tobby48 1年前
父节点
当前提交
20d6b036f1
共有 1 个文件被更改,包括 2 次插入1 次删除
  1. 2
    1
      src/main/python/kr/co/swh/lecture/opensource/rabbitmq/sendTopic.py

+ 2
- 1
src/main/python/kr/co/swh/lecture/opensource/rabbitmq/sendTopic.py 查看文件

@@ -1,10 +1,11 @@
1 1
 import pika
2 2
 
3
+exchange_name = 'topic_logs'
3 4
 connection = pika.BlockingConnection(
4 5
     pika.ConnectionParameters(host='183.99.87.90'))
5 6
 channel = connection.channel()
6 7
 
7
-channel.basic_publish(exchange='topic_logs', routing_key='key', body='Hello World!')
8
+channel.basic_publish(exchange=exchange_name, routing_key='key', body='Hello World!')
8 9
 
9 10
 print(" [x] Sent 'Hello World!'")
10 11
 connection.close()