JMS + ActiveMQ:独占访问数据
JMS + ActiveMQ: exclusive access to data
大家好。
1) 我有一个简单的应用程序,它创建 JMSProducer、ActiveMQ 查询并发送一些消息进行查询。
2) 我还有订阅者应用程序
ActiveMQ 查询(它从上面的应用程序接收消息)。
情况是这样的:
我为我的订户应用程序创建了另一个服务器配置,并在不同的端口上一次启动它两次。
(例如:subscriber-App1 开始于 jetty-http-port-9998/jetty-ssl-port-9994;subscriber-App2 开始于 jetty-http-port-9999/jetty-ssl-port-9995)。
我在Intellij IDEa中打开subscriber-App1控制台和subscriber-App2控制台,开始通过producer-App发送消息。而且我看到订阅者轮流接收消息:当我第一次发送时 - subscriber1 接收它;第二次 - 订阅者 2;第 3 次 - subscriber1 等
问题是:如何配置 subscriber-Application 以使其独占访问数据?主要条件是:如果我的队列只有一个订阅者 - 另一个应用程序无法从队列接收消息。如果我在不同的端口上启动两个 subscriberApps - 所有消息将仅由其中一个接收。
提前致谢!
我相信您应该能够使用 exclusive consumer 功能来实现您的目标。
大家好。
1) 我有一个简单的应用程序,它创建 JMSProducer、ActiveMQ 查询并发送一些消息进行查询。
2) 我还有订阅者应用程序 ActiveMQ 查询(它从上面的应用程序接收消息)。
情况是这样的:
我为我的订户应用程序创建了另一个服务器配置,并在不同的端口上一次启动它两次。 (例如:subscriber-App1 开始于 jetty-http-port-9998/jetty-ssl-port-9994;subscriber-App2 开始于 jetty-http-port-9999/jetty-ssl-port-9995)。
我在Intellij IDEa中打开subscriber-App1控制台和subscriber-App2控制台,开始通过producer-App发送消息。而且我看到订阅者轮流接收消息:当我第一次发送时 - subscriber1 接收它;第二次 - 订阅者 2;第 3 次 - subscriber1 等
问题是:如何配置 subscriber-Application 以使其独占访问数据?主要条件是:如果我的队列只有一个订阅者 - 另一个应用程序无法从队列接收消息。如果我在不同的端口上启动两个 subscriberApps - 所有消息将仅由其中一个接收。
提前致谢!
我相信您应该能够使用 exclusive consumer 功能来实现您的目标。