如何使用端点类为不同的选择器创建多个JmsQueueEndpoint对象
如何使用端点类为不同的选择器创建多个JmsQueueEndpoint对象
提问于 2017-09-06 20:33:16
我有一个队列，在该队列中，我希望处理选定的消息，并能够使用Java实现它，如下所示：
from("amq:queue:{{jms.miscQueue}}?transacted=false&selector=DSBSelectorID %3D '" + SELECTOR_ID_TRANSACTION_A2A + "'")
from("amq:queue:{{jms.miscQueue}}?transacted=false&selector=DSBSelectorID %3D '" + SELECTOR_ID_TRANSACTION_A2P + "'")现在，我想通过如下创建JMS端点来实现同样的目标(实际上，Java工作得很好，但是随着时间的推移，调试变得困难了，因为越来越多的选项嵌入到URI中)：
JmsQueueEndpoint activeMQEndpointA2A = endpoint("amq:queue:{{jms.miscQueue}}", JmsQueueEndpoint.class);
activeMQEndpointA2A.setTransacted(false);
activeMQEndpointA2A.setSelector("DSBSelectorID %3D 'Route-Transaction-A2A'");
JmsQueueEndpoint activeMQEndpointA2P = endpoint("amq:queue:{{jms.miscQueue}}", JmsQueueEndpoint.class);
activeMQEndpointA2P.setTransacted(false);
activeMQEndpointA2P.setSelector("DSBSelectorID %3D 'Route-Transaction-A2P'");当我在骆驼路由中使用activeMQEndpointA2A和activeMQEndpointA2P时，它只对第一个端点和第二个端点起作用，无法连接到队列，并一直抛出错误如下所示
调用程序的设置对于目标“io.az.jms”失败--试图恢复。原因: DSBSelectorID %3D‘路由-事务-A2P’
有人能建议它是否可以通过Java实现吗？另外，如果我有几个路由，并且要在端点URI上定义多个选项，那么推荐的方法是什么？
回答 1
Stack Overflow用户
发布于 2017-09-09 07:29:51
您不能这样做，获取一个端点，然后修改它的属性，然后再次获得端点(您得到与第一个端点相同的实例)，例如A2A和A2P是相同的端点实例。
您需要使用唯一的端点，因此选择器应该在uri中。
页面原文内容由Stack Overflow提供。腾讯云小微IT领域专用引擎提供翻译支持
原文链接：
https://stackoverflow.com/questions/46083885
复制相关文章
相似问题
腾讯云开发者
