AMQP Sub


AMQP Sub 节点让用户订阅 AMQP 的消息队列。

节点类型


Input。

输入和输出能力


该节点没有入口点,仅有 1 个出口点。输出为客户端从所订阅的消息队列检索到的消息,可以是任何格式。

节点属性


../../_images/amqp_sub.png


名称

该节点的名称。


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

相关节点


AMQP Pub