我有下面的Java进程,它正在侦听ActiveMQ.And的MyMessageQueue队列,我可以看到使用这个语句System.out.println("Message Retrieved is:"+message);在processBrokerQueues方法中检索到的消息。httpClient = HttpClients.createDefault();
// URL of the
遇到这个设计问题,并尝试找到一种使用JMS实现它的最佳方法。
Web App有一个监听器,多个生产者,多个WorkerBee。侦听器将消息从其队列推送到WorkerBee。生成的所有消息都在侦听器中排队。我想实现一个可以使用某种负载平衡进程将消息从侦听器队列发送到每个WorkerBee的进程。在侦听器队列或WorkerBee<e