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?
