我正在使用pika向rabbitmq发送消息。 我需要发送其他属性,所以我使用pika.BasicProperties,但当我在Wireshark中看到此消息时,没有添加任何属性
我的代码:
import pika, uuid
connection = pika.BlockingConnection(
pika.ConnectionParameters(host='localhost'))
channel = connection.channel()
channel.queue_declare(queue='test_60', durable=True, arguments={'x-message-ttl' : 21600000})
routingKey = "test_server"
message = '{"test_int":268,"Timestamp":1610022012203}'
correlation_id = str(uuid.uuid4())
reply_to = "test_60"
message_type = "SendRequest"
channel.basic_publish(exchange='',routing_key=routingKey,
body=message,properties=pika.BasicProperties(
headers={"testId": "60"},
delivery_mode=2,
correlation_id = correlation_id,
reply_to = reply_to,
type = message_type))
print('message sent')
print(correlation_id)
在Wireshark中,这个消息看起来像这样,所以没有属性,我也不知道这个示例有什么问题
用户界面:
Wireshark:
相关问题 更多 >
编程相关推荐