Details
-
Bug
-
Resolution: Done
-
Major
-
JBoss A-MQ 6.3
-
None
-
+
Description
When brokers "RedeliveryPlugin" is configured with maximumRedeliveries="-1" (deliver forever) and a "duplicate message from store" is detected, the duplicate message never makes it to the DLQ and keeps getting redelivered to the original queue.
2018-09-21 08:33:43,000 | WARN | JobScheduler:JMS | AbstractStoreCursor | gion.cursors.AbstractStoreCursor 116 | 163 - org.apache.activemq.activemq-osgi - 5.11.0.redhat-630262 | org.apache.activemq.broker.region.cursors.QueueStorePrefetch@13044dcb:MYQUEUEXXX,batchResetNeeded=false,size=0,cacheEnabled=true,maxBatchSize:3,hasSpace:true,pendingCachedIds.size:1,lastSyncCachedId:null,lastSyncCachedId-seq:null,lastAsyncCachedId:ID:MYID2XXX-41992-1537343117867-33:1:1:1:31,lastAsyncCachedId-seq:34164,store=permits:9999,sd=nextSeq:34228,lastRet:MessageOrderCursor:[def:0, low:0, high:0],pending:0 - cursor got duplicate send ID:MYIDXXX1536652818855-25:1:2:1:4 seq: org.apache.activemq.store.kahadb.KahaDBStore$StoreQueueTask$InnerFutureTask@26c9ffc9 2018-09-21 08:33:43,001 | WARN | JobScheduler:JMS | Queue | mq.broker.region.BaseDestination 853 | 163 - org.apache.activemq.activemq-osgi - 5.11.0.redhat-630262 | duplicate message from store ID:MYIDXXX1536652818855-25:1:2:1:4, redirecting for dlq processing 2018-09-21 08:33:43,001 | TRACE | JobScheduler:JMS | RedeliveryPlugin | emq.broker.util.RedeliveryPlugin 173 | 163 - org.apache.activemq.activemq-osgi - 5.11.0.redhat-630262 | redelivery #31514 of: ID:MYIDXXX1536652818855-25:1:2:1:4 with delay: 10000, dest: queue://MYQUEUEXXX 2018-09-21 08:33:53,000 | WARN | JobScheduler:JMS | AbstractStoreCursor | gion.cursors.AbstractStoreCursor 116 | 163 - org.apache.activemq.activemq-osgi - 5.11.0.redhat-630262 | org.apache.activemq.broker.region.cursors.QueueStorePrefetch@13044dcb:MYQUEUEXXX,batchResetNeeded=false,size=0,cacheEnabled=true,maxBatchSize:3,hasSpace:true,pendingCachedIds.size:1,lastSyncCachedId:null,lastSyncCachedId-seq:null,lastAsyncCachedId:ID:MYID2XXX-41992-1537343117867-33:1:1:1:31,lastAsyncCachedId-seq:34164,store=permits:9999,sd=nextSeq:34229,lastRet:MessageOrderCursor:[def:0, low:0, high:0],pending:0 - cursor got duplicate send ID:MYIDXXX1536652818855-25:1:2:1:4 seq: org.apache.activemq.store.kahadb.KahaDBStore$StoreQueueTask$InnerFutureTask@7be7d7d7 2018-09-21 08:33:53,001 | WARN | JobScheduler:JMS | Queue | mq.broker.region.BaseDestination 853 | 163 - org.apache.activemq.activemq-osgi - 5.11.0.redhat-630262 | duplicate message from store ID:MYIDXXX1536652818855-25:1:2:1:4, redirecting for dlq processing 2018-09-21 08:33:53,001 | TRACE | JobScheduler:JMS | RedeliveryPlugin | emq.broker.util.RedeliveryPlugin 173 | 163 - org.apache.activemq.activemq-osgi - 5.11.0.redhat-630262 | redelivery #31515 of: ID:MYIDXXX1536652818855-25:1:2:1:4 with delay: 10000, dest: queue://MYQUEUEXXX 2018-09-21 08:34:03,000 | WARN | JobScheduler:JMS | AbstractStoreCursor | gion.cursors.AbstractStoreCursor 116 | 163 - org.apache.activemq.activemq-osgi - 5.11.0.redhat-630262 | org.apache.activemq.broker.region.cursors.QueueStorePrefetch@13044dcb:MYQUEUEXXX,batchResetNeeded=false,size=0,cacheEnabled=true,maxBatchSize:3,hasSpace:true,pendingCachedIds.size:1,lastSyncCachedId:null,lastSyncCachedId-seq:null,lastAsyncCachedId:ID:MYID2XXX-41992-1537343117867-33:1:1:1:31,lastAsyncCachedId-seq:34164,store=permits:9999,sd=nextSeq:34230,lastRet:MessageOrderCursor:[def:0, low:0, high:0],pending:0 - cursor got duplicate send ID:MYIDXXX1536652818855-25:1:2:1:4 seq: org.apache.activemq.store.kahadb.KahaDBStore$StoreQueueTask$InnerFutureTask@17f4d783 2018-09-21 08:34:03,001 | WARN | JobScheduler:JMS | Queue | mq.broker.region.BaseDestination 853 | 163 - org.apache.activemq.activemq-osgi - 5.11.0.redhat-630262 | duplicate message from store ID:MYIDXXX1536652818855-25:1:2:1:4, redirecting for dlq processing 2018-09-21 08:34:03,001 | TRACE | JobScheduler:JMS | RedeliveryPlugin | emq.broker.util.RedeliveryPlugin 173 | 163 - org.apache.activemq.activemq-osgi - 5.11.0.redhat-630262 | redelivery #31516 of: ID:MYIDXXX1536652818855-25:1:2:1:4 with delay: 10000, dest: queue://MYQUEUEXXX
