receiveNoWait problem in 2.1.0CR1
cstillwell Jun 4, 2010 12:22 PMI have a test that sends multiple messages to a queue, then loops performing a receiveNoWait until a null response is returned. What I am seeing is that one message is read off of the queue and the second receiveNoWait returns null even thought there are still more messages on the queue. I had seen issue HORNETQ-284 which dealt with receiveNoWait not working so I installed 2.1.0CR1. Here's the out put from a test run that sends 4 messages, browses the queue, does the receiveNoWait loop, and then browses the queue again.
If I change the receiveNoWait to receive( 1 ) then it will usually pull all of the messages off of the queue.
HornetQMessage[ID:5d06c39c-6ff1-11df-885e-0023dfffb25d:0000000000000000]:PERSISTENT, RequestId=1111111
HornetQMessage[ID:5d08bf6d-6ff1-11df-885e-0023dfffb25d:0000000000000000]:PERSISTENT, RequestId=1111111
HornetQMessage[ID:5d09349e-6ff1-11df-885e-0023dfffb25d:0000000000000000]:PERSISTENT, RequestId=2222222
HornetQMessage[ID:5d09d0df-6ff1-11df-885e-0023dfffb25d:0000000000000000]:PERSISTENT, RequestId=2222222
4 messages on queue.
Received message: HornetQMessage[ID:5d06c39c-6ff1-11df-885e-0023dfffb25d:0000000000000000]:PERSISTENT, RequestId=1111111, duration 00:00:00.00
This is a test message0
Received message: HornetQMessage[ID:5d08bf6d-6ff1-11df-885e-0023dfffb25d:0000000000000000]:PERSISTENT, RequestId=1111111, duration 00:00:00.00
This is a test message1
Received message: HornetQMessage[ID:5d09349e-6ff1-11df-885e-0023dfffb25d:0000000000000000]:PERSISTENT, RequestId=2222222, duration 00:00:00.00
This is a test message2
Received message: HornetQMessage[ID:5d09d0df-6ff1-11df-885e-0023dfffb25d:0000000000000000]:PERSISTENT, RequestId=2222222, duration 00:00:00.00
This is a test message3
Received message: null, RequestId=0, duration 00:00:00.01
4 messages read from queue.
0 messages on queue.
However, I have seen where using receive( 1 ) does not pul all of the messages off of the queue, but this is intermittent.
HornetQMessage[ID:dd864a14-6fea-11df-bb80-0023dfffb25d:0000000000000000]:PERSISTENT, RequestId=1111111
HornetQMessage[ID:dd889405-6fea-11df-bb80-0023dfffb25d:0000000000000000]:PERSISTENT, RequestId=1111111
HornetQMessage[ID:dd890936-6fea-11df-bb80-0023dfffb25d:0000000000000000]:PERSISTENT, RequestId=2222222
HornetQMessage[ID:dd89a577-6fea-11df-bb80-0023dfffb25d:0000000000000000]:PERSISTENT, RequestId=2222222
HornetQMessage[ID:e02ed4c8-6fea-11df-9346-0023dfffb25d:0000000000000000]:PERSISTENT, RequestId=1111111
HornetQMessage[ID:e030f7a9-6fea-11df-9346-0023dfffb25d:0000000000000000]:PERSISTENT, RequestId=1111111
HornetQMessage[ID:e031bafa-6fea-11df-9346-0023dfffb25d:0000000000000000]:PERSISTENT, RequestId=2222222
HornetQMessage[ID:e032a55b-6fea-11df-9346-0023dfffb25d:0000000000000000]:PERSISTENT, RequestId=2222222
HornetQMessage[ID:e26ed9f9-6fea-11df-b140-0023dfffb25d:0000000000000000]:PERSISTENT, RequestId=1111111
HornetQMessage[ID:e272355a-6fea-11df-b140-0023dfffb25d:0000000000000000]:PERSISTENT, RequestId=1111111
HornetQMessage[ID:e2731fbb-6fea-11df-b140-0023dfffb25d:0000000000000000]:PERSISTENT, RequestId=2222222
HornetQMessage[ID:e273bbfc-6fea-11df-b140-0023dfffb25d:0000000000000000]:PERSISTENT, RequestId=2222222
HornetQMessage[ID:f3a39b52-6fea-11df-84dc-0023dfffb25d:0000000000000000]:PERSISTENT, RequestId=1111111
HornetQMessage[ID:f3a59723-6fea-11df-84dc-0023dfffb25d:0000000000000000]:PERSISTENT, RequestId=1111111
HornetQMessage[ID:f3a68184-6fea-11df-84dc-0023dfffb25d:0000000000000000]:PERSISTENT, RequestId=2222222
HornetQMessage[ID:f3a744d5-6fea-11df-84dc-0023dfffb25d:0000000000000000]:PERSISTENT, RequestId=2222222
16 messages on queue.
Received message: HornetQMessage[ID:dd864a14-6fea-11df-bb80-0023dfffb25d:0000000000000000]:PERSISTENT, RequestId=1111111, duration 00:00:00.00
This is a test message0
Received message: HornetQMessage[ID:dd889405-6fea-11df-bb80-0023dfffb25d:0000000000000000]:PERSISTENT, RequestId=1111111, duration 00:00:00.01
This is a test message1
Received message: HornetQMessage[ID:dd890936-6fea-11df-bb80-0023dfffb25d:0000000000000000]:PERSISTENT, RequestId=2222222, duration 00:00:00.01
This is a test message2
Received message: HornetQMessage[ID:dd89a577-6fea-11df-bb80-0023dfffb25d:0000000000000000]:PERSISTENT, RequestId=2222222, duration 00:00:00.01
This is a test message3
Received message: HornetQMessage[ID:e02ed4c8-6fea-11df-9346-0023dfffb25d:0000000000000000]:PERSISTENT, RequestId=1111111, duration 00:00:00.01
This is a test message0
Received message: null, RequestId=0, duration 00:00:00.01
5 messages read from queue.
HornetQMessage[ID:e030f7a9-6fea-11df-9346-0023dfffb25d:0000000000000000]:PERSISTENT, RequestId=1111111
HornetQMessage[ID:e031bafa-6fea-11df-9346-0023dfffb25d:0000000000000000]:PERSISTENT, RequestId=2222222
HornetQMessage[ID:e032a55b-6fea-11df-9346-0023dfffb25d:0000000000000000]:PERSISTENT, RequestId=2222222
HornetQMessage[ID:e26ed9f9-6fea-11df-b140-0023dfffb25d:0000000000000000]:PERSISTENT, RequestId=1111111
HornetQMessage[ID:e272355a-6fea-11df-b140-0023dfffb25d:0000000000000000]:PERSISTENT, RequestId=1111111
HornetQMessage[ID:e2731fbb-6fea-11df-b140-0023dfffb25d:0000000000000000]:PERSISTENT, RequestId=2222222
HornetQMessage[ID:e273bbfc-6fea-11df-b140-0023dfffb25d:0000000000000000]:PERSISTENT, RequestId=2222222
HornetQMessage[ID:f3a39b52-6fea-11df-84dc-0023dfffb25d:0000000000000000]:PERSISTENT, RequestId=1111111
HornetQMessage[ID:f3a59723-6fea-11df-84dc-0023dfffb25d:0000000000000000]:PERSISTENT, RequestId=1111111
HornetQMessage[ID:f3a68184-6fea-11df-84dc-0023dfffb25d:0000000000000000]:PERSISTENT, RequestId=2222222
HornetQMessage[ID:f3a744d5-6fea-11df-84dc-0023dfffb25d:0000000000000000]:PERSISTENT, RequestId=2222222
11 messages on queue.
Process finished with exit code 0
I do not see this behavior when running with jboss mq. If there is a configuration option that might cause this I would be interested to know what it is. I am running jboss-5.1.0.GA with the default-with-hornetq configuration generated by HornetQ. I have attached my test source in case it's just me.
-
SendReceiveTest.java.zip 1.6 KB