try
{
QueueSession session1 = queueConnection1.createQueueSession(false, Session.CLIENT_ACKNOWLEDGE);
queue = (Queue)context.lookup(TEST_QUEUE);
QueueReceiver receiver1 = session1.createReceiver(queue);
QueueSession session2 = queueConnection2.createQueueSession(false, Session.CLIENT_ACKNOWLEDGE);
QueueReceiver receiver2 = session2.createReceiver(queue);
queueConnection1.start();
queueConnection2.start();
int c1=0, c2=0;
Message messageConsumer1=null, messageConsumer2=null;
Message lastMessageConsumer1 = null, lastMessageConsumer2=null;
do
{
messageConsumer1 = receiver1.receive(100);
messageConsumer2 = receiver2.receive(100);
if (messageConsumer1 != null)
{
c1 ++;
lastMessageConsumer1 = messageConsumer1;
}