AMQP Sub¶
AMQP Sub 节点让用户订阅 AMQP 的消息队列。
节点类型¶
Input。
输入和输出能力¶
该节点没有入口点,仅有 1 个出口点。输出为客户端从所订阅的消息队列检索到的消息,可以是任何格式。
节点属性¶
名称
该节点的名称。
Host
主机地址或域名。
端口
端口号,默认为 5672。
Topic
AMQP topic exchange 名称。
用户名
用于鉴权的用户名。
密码
用于鉴权的 用户名 对应的密码。
消息队列
订阅的消息队列。
描述
该节点的描述。
使用限制 ¶
由于 AMQP 并非 EnOS 管理,EnOS 不保证每次连接都能成功,连接问题可能是由于服务器停机或其他 EnOS 无法控制的因素造成。
示例¶
输入示例¶
该节点不接收任何输入消息。
输出示例¶
{
"MetaData": {
"rabbitmq.EXCHANGE_NAME": "lorem",
"enos-apm-tracing-tags": "{}",
"rabbitmq.DELIVERY_TAG": "5",
"sw8-x": "0",
"rabbitmq.REDELIVERY_TAG": "false",
"sw8": "1-NWM0NDhhNjdjYWZmNDQyYmFiMDQ0ODZhMGQzNzM1ZDUuMTI2LjE2MjQzNTA3NDA3OTI=-NzQ4NmJmNTkwYjM5NDZlN2I5YzYxMTg2YTc0ZGE2MzAuMTI2LjE2MjQzNTA3NDA3OTI=-0-aW90LW9yY2gtbGF1bmNoZXI=-ZDVmM2U2OTgzODliNDMwOTgzMTgwZjYyNDg3Y2YwMjhAMTAuNS40MC4yOA==-UmFiYml0TVEvVG9waWMvanN0ZXN0UXVldWUvanN0ZXN0L1Byb2R1Y2Vy-MTAuNS4zOC4xNTg6NTY3Mg==",
"sw8-correlation": "",
"rabbitmq.ROUTING_KEY": "lorem"
},
"Body": {
"externalId":"externalId",
"timestamp":24214324324,
"measurepoints":{
"speed":32,
"heat":40
}
}
}