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
        }
    }
}