当前位置: 首页 > 知识库问答 >
问题:

在多主题字符串上发布消息(IBM Integration Bus)

丁雅惠
2023-03-14

我有一个场景,我将使用MQ输入节点接收消息,并且基于消息中存在的源系统的值,我需要形成主题字符串并发布消息。这就是我的流的样子:

设置OutputRoot.Properties.Topic='topic/'sourceName2;

感谢任何建议。

共有1个答案

柴昆杰
2023-03-14

您应该使用不同的主题字符串从Compute节点传播两个独立的消息。

可以使用propagate ESQL语句传播消息而不返回。因此您的代码应该如下所示:

<Create message in OutputRoot>

SET OutputRoot.Properties.Topic = 'TopicName/' || sourceName1;
PROPAGATE DELETE NONE;

SET OutputRoot.Properties.Topic = 'TopicName/' || sourceName2;
RETURN TRUE;
 类似资料:
  • 我正在尝试以avro格式对kafka消息进行解密我使用了以下代码:https://github.com/ivangfr/springboot-kafka-debezium-ksql/blob/master/kafka-research-consumer/src/main/java/com/mycompany/kafkaResearchconsumer/kafka/reviewsconsumerco

  • 我有一个运行DCOS的小集群。我能够成功安装Kafka遵循本指南。跑步 谢谢 AJ

  • 物联网有很多设备,通过这条指令可以向某个特定的物联网设备发送特定的消息内容。 请求方式: "|4|1|3|topic|message|" 参数: topic 设置订阅的topic,获取设备topic可参考教程 message 发布消息的内容 返回值: "|4|1|3|1|\r" 消息发送成功 "|4|1|3|2|\r" 消息发送失败 Arduino样例: softSerial.print("|4|

  • 我是老学校窗户蔚蓝建筑师。使用服务总线主题将消息传递给工作者角色。

  • ActiveMQ中的持久主题(这似乎是JMS本身的一个障碍)似乎是一个订阅服务器上只能有一个使用者活动。 也就是说,在ActiveMQ文档中: 使用唯一的JMS clientID和持久订阅服务器名称创建JMS持久订阅服务器MessageConsumer。为了符合JMS,对于一个JMS clientID,在任何时间点只能有一个JMS连接处于活动状态,对于一个clientID和订阅者名称,只能有一个使

  • 每当我试图将消息从esb发布到消息代理的主题时,我都会收到此错误 我的代理代码是 我的jndi配置和axis 2配置配置正确。我的MB在端口9444上运行,Publisher_esb在端口9443上运行,subscriber esb在端口9446上运行。当我使我的订阅者保持活动状态时,如果我从我的发布者发布一条消息,该消息会反映到订阅者。 从订户获取消息的代码是 当我第一次运行订阅者时,它给了我结