应用与数据集成平台 ROMA Connect-RabbitMqProducer类说明:方法详情

时间:2025-02-12 14:55:44

方法详情

  • public void produceWithDirectExchange(String routingKey, String props, String message)

    用direct交换器生产消息,把消息路由到bindingKey与routingKey完全匹配的Queue中。

    输入参数

    • routingKey:消息路由键
    • props:消息持久化设置,非必填
    • message:消息内容
  • public void produceWithTopicExchange(String bindingKey, String routingKey, String props, String message)

    用topic交换器生产消息,把消息路由到bindingKey与routingKey模糊匹配的Queue中。

    输入参数

    • bindingKey:队列绑定键
    • routingKey:消息路由键
    • props:消息持久化设置,非必填
    • message:消息内容
  • produceWithFanoutExchange(String props, String message)

    用fanout交换器生产消息,把所有发送到该Exchange的消息路由到所有与它绑定的Queue中。

    输入参数

    • props:消息持久化设置,非必填
    • message:消息内容
support.huaweicloud.com/devg-roma/apic-dev-190603069.html