Hi,
jboss-4.2.2.GA / jboss-messaging-1.4.0.SP3 / jboss-remoting-2.2.2.SP4
I have a jboss cluser with 3 nodes:
1. Each nodes has a clustered queue.
2. Each node sends messages to its local partial queue of this clustered queue
using ConnectionFactory.
3. I am trying to use one listener that listens on this clustered queue.
My first attempt is to use one connection to create a receiver on the clustered
queue, but it fails to receive messages on other nodes, and some messages
stuck on their local partial queue. Then here is my second implementations of
this listener:
1) Create 3 connections/sessions using ClusteredConnectionFactory, so it
supposes to be round-robin and creates one connection to each node.
2) Create one receiver with msg selector on each session using:
session.createReceiver(_replyQueue, selector.toString());
Then add these 3 receivers into a list.
3) When the listener needs to retrieve a message, it goes through this
receiver list:
for(QueueReceiver receiver : replyQueueReceivers) {
Message msg = receiver.receiveNoWait();
if(msg != null && msg instanceof ObjectMessage) {
ObjectMessage objMsg = (ObjectMessage) msg;
return objMsg;
}
}
This approach works in most cases. However, sometime I found the listener fails
to retrieve messages that are in the queue. From jmx console, I can see there
is one message in the queue, and there is one consumer(which is the listener)
on the queue, but it appears the message stuck in the queue and listener fails
to retrieve it.
Any ideas? Thanks.
View the original post :
http://www.jboss.com/index.html?module=bb&op=viewtopic&p=4151363#4151363
Reply to the post :
http://www.jboss.com/index.html?module=bb&op=posting&mode=reply&p=4151363
_______________________________________________
jboss-user mailing list
[email protected]
https://lists.jboss.org/mailman/listinfo/jboss-user
