activemq-users mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From liangwb2001 <liangwb2...@gmail.com>
Subject A probability for Queue Message dispatch delay
Date Mon, 04 Jun 2012 08:24:42 GMT
Hi dear all:
    I'm using 3 brokers in product env. and recently i found activemq
dispatch a message slowly in one of queue on the server.  After some test I
found a probability cause this case:
    1. in
org.apache.activemq.broker.region.cursors.StoreQueueCursor.addMessageLast(StoreQueueCursor.java:100)
                persistent.addMessageLast(node);
       if  persistent.addMessageLast(node) failure for example:
org.apache.activemq.broker.region.cursors.AbstractStoreCursor.recoverMessage(AbstractStoreCursor.java:79)
                recordUniqueId(message.getMessageId()) return false.
    2. in
org.apache.activemq.store.kahadb.MessageDatabase.upadateIndex(MessageDatabase.java:1027)
                if previous == null return true.
    Then in org.apache.activemq.broker.region.Queue: the messages's size are
little than store's;
    Is this causing the latter message dispathed delay?
    If changing config enableAudit="false" will ok.
Thanks

--
View this message in context: http://activemq.2283324.n4.nabble.com/A-probability-for-Queue-Message-dispatch-delay-tp4652949.html
Sent from the ActiveMQ - User mailing list archive at Nabble.com.

Mime
View raw message