您可以通过AMQP连接实现从AMQP代理获取消息或将消息发布到AMQP代理。
参数说明
参数 |
描述 |
类型 |
是否必须 |
默认值 |
连接URI |
发送数据或获取数据的位置。 |
String |
是 |
无 |
用户名 |
使用此用户的授权凭据访问代理。 |
String |
否 |
无 |
密码 |
指定用户账号的密码。 |
String |
否 |
无 |
客户端ID |
在连接关闭和重新打开而不丢失消息时需要,连接目标必须是主题。 |
String |
否 |
无 |
检查证书 |
为安全的生产环境启用证书检查。仅在开发环境中为了方便而禁用。 |
String |
否 |
Enable |
代理证书 |
AMQP代理X.509 PEM证书。 |
String |
否 |
无 |
客户端证书 |
AMQP客户端X.509 PEM证书。 |
String |
否 |
无 |
从指定的目标接收数据
参数 |
描述 |
类型 |
是否必须 |
默认值 |
目标名称 |
要从中接收数据的队列或主题的名称。 |
String |
是 |
无 |
目标类型 |
从队列或者主题接收数据。 |
String |
否 |
Queue |
消息选择器 |
指定筛选器表达式,只接收符合特定条件的数据。 |
String |
否 |
无 |
持久订阅ID |
设置允许连接关闭和重新打开而不丢失消息的ID,目标类型必须是主题。 |
String |
否 |
无 |
将消息发布到指定的主题或者队列
参数 |
描述 |
类型 |
是否必须 |
默认值 |
是否持久化 |
当选择了持久化时,可以保证消息传递,即AMQP服务端重启时队列和消息仍然存在。 |
Boolean |
否 |
False |
目标名 |
要发送数据的队列或主题的名称。 |
String |
是 |
无 |
目标类型 |
消息发送目标。 |
String |
否 |
Queue |