[jboss-jira] [JBoss JIRA] Commented: (JBMESSAGING-1140) QueueReceiver starts out of sync with the server, so receiveNoWait always returns null
Carlo de Wolf (JIRA)
jira-events at lists.jboss.org
Wed Nov 7 08:46:44 EST 2007
[ http://jira.jboss.com/jira/browse/JBMESSAGING-1140?page=comments#action_12386474 ]
Carlo de Wolf commented on JBMESSAGING-1140:
--------------------------------------------
As I read 5.9 the enumeration doesn't have to reflect the contents of a queue, because of message arrival, expiration or consumption. But I still think that both browser and consumer should have a symmetrical view of the queue.
> QueueReceiver starts out of sync with the server, so receiveNoWait always returns null
> --------------------------------------------------------------------------------------
>
> Key: JBMESSAGING-1140
> URL: http://jira.jboss.com/jira/browse/JBMESSAGING-1140
> Project: JBoss Messaging
> Issue Type: Bug
> Components: JMS Client Manager
> Affects Versions: 1.4.0.SP1
> Reporter: Carlo de Wolf
> Assigned To: Tim Fox
>
> When there is a single message on the queue the browser will correctly report 1 message, but the receiver will not receive it right away.
> QueueBrowser browser = session.createBrowser(queue);
> Enumeration e = browser.getEnumeration();
> List messages = CollectionsUtil.list(e);
> QueueReceiver receiver = session.createReceiver(queue);
> message = (TextMessage) receiver.receiveNoWait();
> 2007-11-06 13:58:06,437 TRACE [org.jboss.jms.client.JBossSession] attempting to create consumer for destination:JBossQueue[DLQ]
> 2007-11-06 13:58:06,438 TRACE [org.jboss.jms.client.delegate.DelegateSupport] SessionDelegate[1802245312, ID=c8a-r0sgfo8f-1-hnjqbo8f-ilci1t-110j3] invoking org.jboss.jms.wireformat.SessionCreateConsumerDelegateRequest at 2e7857a5 synchronously on server using Client[838449156]
> 2007-11-06 13:58:06,480 TRACE [org.jboss.jms.client.delegate.DelegateSupport] SessionDelegate[1802245312, ID=c8a-r0sgfo8f-1-hnjqbo8f-ilci1t-110j3] got server response for org.jboss.jms.wireformat.SessionCreateConsumerDelegateRequest at 2e7857a5: org.jboss.jms.wireformat.SessionCreateConsumerDelegateResponse at 1d30b5e2
> 2007-11-06 13:58:06,484 TRACE [org.jboss.jms.client.delegate.DelegateSupport] ConsumerDelegate[1910585900, ID=j8a-itsgfo8f-1-hnjqbo8f-ilci1t-110j3] invoking org.jboss.jms.wireformat.ConsumerChangeRateRequest at 79b2591c synchronously on server using Client[838449156]
> 2007-11-06 13:58:06,486 TRACE [org.jboss.jms.client.delegate.DelegateSupport] ConsumerDelegate[1910585900, ID=j8a-itsgfo8f-1-hnjqbo8f-ilci1t-110j3] got server response for org.jboss.jms.wireformat.ConsumerChangeRateRequest at 79b2591c: org.jboss.jms.wireformat.NullResponse at 468034b6
> 2007-11-06 13:58:06,488 TRACE [org.jboss.jms.client.container.ClientConsumer] ClientConsumer[j8a-itsgfo8f-1-hnjqbo8f-ilci1t-110j3] receiving, timeout = -1
> 2007-11-06 13:58:06,488 TRACE [org.jboss.jms.client.container.ClientConsumer] ClientConsumer[j8a-itsgfo8f-1-hnjqbo8f-ilci1t-110j3]: receive, noWait
> 2007-11-06 13:58:06,488 TRACE [org.jboss.jms.client.container.ClientConsumer] ClientConsumer[j8a-itsgfo8f-1-hnjqbo8f-ilci1t-110j3]: no message available
> 2007-11-06 13:58:06,545 TRACE [org.jboss.jms.client.container.ClientConsumer] org.jboss.jms.client.container.ClientConsumer$HandleMessageRunnable at 66201d6d receiving message delegator->JBossMessage[58368]:PERSISTENT, deliveryId=1 from the remoting layer
> 2007-11-06 13:58:06,545 TRACE [org.jboss.jms.client.container.ClientConsumer] org.jboss.jms.client.container.ClientConsumer$HandleMessageRunnable at 66201d6d added message(s) to the buffer are now 1 messages
--
This message is automatically generated by JIRA.
-
If you think it was sent incorrectly contact one of the administrators: http://jira.jboss.com/jira/secure/Administrators.jspa
-
For more information on JIRA, see: http://www.atlassian.com/software/jira
More information about the jboss-jira
mailing list