我正在使用多个 <si:service-activator>
的和 <jms:message-driven-channel-adapter>
订阅多个队列和主题。来自每个目的地的消息都在一个单独的线程中接收,这意味着我的接收代码充满了锁来保护可变的内部状态。
我希望我的接收代码是无锁的。是否可以将 spring-integration/activemq 配置为从同一线程上的多个目的地接收?
如果这是不可能的,我可以想到两种选择:
有人有更好的想法吗?
最佳答案
使用 wildcard pattern在一个队列上。
也就是说,不要从两个队列中读取,而是使用一个队列并在名称中指定要读取的所有队列。
即:"QUEUE.NR1,QUEUE.NR2"
或 "SOME.PREFIX.>"
读取具有该前缀的所有队列。您的客户端代码将其作为单个队列处理。
关于multithreading - Spring-integration/ActiveMQ 在单个线程中订阅多个目的地,我们在Stack Overflow上找到一个类似的问题: https://stackoverflow.com/questions/30365908/