activemq-users mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Gary Tully <gary.tu...@gmail.com>
Subject Re: What is "no dispatcher for MessageDispatch ... in ..." trying to tell me
Date Fri, 27 Jun 2014 12:34:52 GMT
that the local consumer is gone. Each consumer registers with the
connection to get messages destined for it.
The dispatcher is removed on consumer close, but before the close is
processes broker side so it is possible to get dispatch to a
nonexistent consumer which is ok because any dispatched and unacked
messages will get redispatched when the close is processed.

On 26 June 2014 13:45, Martin Lichtin <lichtin@yahoo.com.invalid> wrote:
> Hi all, while debugging an (unexpected) redelivered message, I come across the following
log
>
>
> 2014-06-25 13:37:53,608 | DEBUG | ActiveMQ NIO Worker 16   | ActiveMQConnection     
         | he.activemq.ActiveMQConnection$3 1887 | 93 - org.apache.activemq.activemq-osgi
- 5.10.0 | org.apache.activemq.ActiveMQConnection$3@6484d6fb no dispatcher for MessageDispatch
{commandId = 0, responseRequired = false, consumerId = ID:plutohp-60733-1403696178633-8:1:323:1,
destination = queue://myqueue,
> message = ActiveMQTextMessage {commandId = 1211, responseRequired = true, messageId =
ID:plutohp-60733-1403696178633-8:6:101:1:1, originalDestination = null, originalTransactionId
= null, producerId = ID:plutohp-60733-1403696178633-8:6:101:1, destination = queue://myqueue,
transactionId = XID:[1096044365,globalId=3137322e32322e33302e33312e746d30303637313030303031,branchId=3137322e32322e33302e33312e746d393634],
expiration = 0, timestamp = 1403696271841, arrival = 0, brokerInTime = 1403696271842, brokerOutTime
= 1403696273599, correlationId = null, replyTo = null, persistent = true, type = null, priority
= 0, groupID = null, groupSequence = 0, targetConsumerId = null, compressed = false, userID
= null, content = org.apache.activemq.util.ByteSequence@4d3e2c4b, marshalledProperties = org.apache.activemq.util.ByteSequence@2cce178b,
dataStructure = null, redeliveryCounter = 0, size = 0, properties = {breadcrumbId=ID-plutohp-60805-1403696180532-0-970,
>  destination=jms:myqueue}, readOnlyProperties = false, readOnlyBody = false, droppable
= false, jmsXGroupFirstForConsumer = false, text = ..., redeliveryCounter = 0} in {ID:plutohp-60733-1403696178633-8:1:326:1=ActiveMQSession
{id=ID:plutohp-60733-1403696178633-8:1:326,started=true}, ID:plutohp-60733-1403696178633-8:1:325:1=ActiveMQSession
{id=ID:plutohp-60733-1403696178633-8:1:325,started=true}, ID:plutohp-60733-1403696178633-8:1:-1:1=org.apache.activemq.AdvisoryConsumer@60cb634c}
>
>
> It's from the ActiveMQConnection.onCommand() method:
>
>
>                         ActiveMQDispatcher
> dispatcher = dispatchers.get(md.getConsumerId());
>                         if(dispatcher != null) {
>                             ...
>                             dispatcher.dispatch(md);
>                         } else{
>                             LOG.debug("{} no dispatcher for {} in
> {}", this, md, dispatchers);
>                         }
>
> Can someone help me understand what the dispatcher=null case signifies?



-- 
http://redhat.com
http://blog.garytully.com

Mime
View raw message