rabbitmq_publish_message
Publish messages to a RabbitMQ exchange with a routing key and JSON serialization. Configure delivery mode, priority, expiration, and headers for message delivery.
Instructions
向指定交换机与路由键发布消息,支持 JSON 自动序列化与持久化配置.
受全局写保护门禁 (--allow-write) 约束。
@param exchange 目标交换机名称 @param routing_key 路由寻址键,默认为空 @param payload 消息载荷,支持 dict, list, str 或 bytes @param delivery_mode 投递模式,1=非持久化,2=持久化(默认 2) @param priority 消息优先级(0-255) @param expiration 消息过期时间(毫秒数字或字符串) @param headers 自定义消息属性头字典 @param connection 目标连接别名,默认为 'default' @return 消息投递确认报告
Input Schema
| Name | Required | Description | Default |
|---|---|---|---|
| headers | No | ||
| payload | No | ||
| exchange | Yes | ||
| priority | No | ||
| connection | No | default | |
| expiration | No | ||
| routing_key | No | ||
| delivery_mode | No |
Output Schema
| Name | Required | Description | Default |
|---|---|---|---|
No arguments | |||