集成有效负载路由器问题

Question

我正在尝试配置有效负载路由器以将消息路由到Rabbitmq，ibmq和Kafka MOM。 在某些情况下，有效负载必须路由到多个 MOM，这是代码

@ServiceActivator(inputChannel = "routerChannel", outputChannel = "outputChannel")
public PayloadTypeRouter router(Log message) {
PayloadTypeRouter router = new PayloadTypeRouter();
for (Platform platform : new MessageConfig().getConfig(message.getClientKey())) {
System.out.println("platform type=" + platform.getRouter());
if (platform.getRouter().equals(BridgeType.Bridge.rabbitmq.toString())) {
router.setChannelMapping(String.class.getName(), "rabbitChannel");
} else if (platform.getRouter().equals(BridgeType.Bridge.ibmmq.toString())) {
router.setChannelMapping(String.class.getName(), "ibmmqChannel");
} else if (platform.getRouter().equals(BridgeType.Bridge.kafka.toString())) {
router.setChannelMapping(String.class.getName(), "kafkaChannel");
}
}
return router;
}

早些时候我有以下代码，它工作正常(发送给单个 MOM，但不能同时发送给两个(

@Router(inputChannel = "routerChannel")
public String route(Log message) {
log.info("message in the router='{}'", message.getClientKey());
for (Platform platform : new MessageConfig().getConfig(message.getClientKey())) {
System.out.println("platform type=" + platform.getRouter());
if (platform.getRouter().equals(BridgeType.Bridge.rabbitmq.toString())) {
return "rabbitChannel";
} else if (platform.getRouter().equals(BridgeType.Bridge.ibmmq.toString())) {
return "ibmmqChannel";
} else if (platform.getRouter().equals(BridgeType.Bridge.kafka.toString())) {
return "kafkaChannel";
}
}
return "errorChannel";
}

不知道我做错了什么，感谢这里的任何帮助

Answer 1

PayloadTypeRouter和MethodInvokingRouter仅支持一个目的地。

如果要路由到多个目标，请使用带RecipientsMessageSelectors 的RecipientListRouter。

实际上，我错了;你可以简单地从第二个例子中返回List<String>。