我有这样的场景:
ADDRESS1:
-ADDRESS1.QUEUE1
-ADDRESS1.QUEUE2
ADDRESS2:
-ADDRESS2.QUEUE1
-ADDRESS2.QUEUE2
具有多个任播队列的两个地址。我需要将消息路由到指定队列的地址中。
示例:
Messages on ADDRESS1::ADDRESS1.QUEUE1 goes to -> ADDRESS2::ADDRESS2.QUEUE1
Messages on ADDRESS1::ADDRESS1.QUEUE2 goes to -> ADDRESS2::ADDRESS2.QUEUE2
这是我的代码:
CamelContext context = new DefaultCamelContext();
ConnectionFactory factory = new ActiveMQConnectionFactory("admin", "admin", "tcp://0.0.0.0:61616");
context.addComponent("artemis", JmsComponent.jmsComponentAutoAcknowledge(factory));
context.addRoutes(new RouteBuilder() {
@Override
public void configure() throws Exception {
from("artemis:ADDRESS1::ADDRESS1.QUEUE1")
.log("${body}")
.to("artemis:ADDRESS2::ADDRESS2.QUEUE1");
}
});
context.addRoutes(new RouteBuilder() {
@Override
public void configure() throws Exception {
from("artemis:ADDRESS1::ADDRESS1.QUEUE2")
.log("${body}")
.to("artemis:ADDRESS2::ADDRESS2.QUEUE2");
}
});
使用此代码,我只能使用特定队列中的消息。但“.to”不起作用。 有什么办法可以做到吗?
我需要这样做,因为我有许多应用程序是消费者,所以我想使用地址“按应用程序”分隔队列。
像这样:
APP1
QUEUE1
QUEUE2
QUEUE3
提前致谢。
我想我找到了解决方案,但我不知道是否是最好的。
我在目标队列中添加了过滤器:
ADDRESS2:
-ADDRESS2.QUEUE1 - Filter -> DESTIONATION = 'QUEUE1'
-ADDRESS2.QUEUE2 - Filter -> DESTIONATION = 'QUEUE2'
当我用骆驼路由消息时,我设置了一个带有值的标头,并且 .to() 我仅设置了地址名称:
context.addRoutes(new RouteBuilder() {
@Override
public void configure() throws Exception {
from("artemis:ADDRESS1::ADDRESS1.QUEUE1")
.log("${body}")
.setHeader("DESTINATION", constant("QUEUE1"))
.to("artemis:ADDRESS2");
}
});
context.addRoutes(new RouteBuilder() {
@Override
public void configure() throws Exception {
from("artemis:ADDRESS1::ADDRESS1.QUEUE1")
.log("${body}")
.setHeader("DESTINATION", constant("QUEUE2"))
.to("artemis:ADDRESS2");
}
});
这可行,但正如我所说,我不知道是否是最好的方法。
尝试禁用生产者端点上的“replyTo”:
.to("artemis:ADDRESS2::ADDRESS2.QUEUE1?disableReplyTo=true")