[ https://issues.apache.org/jira/browse/AMQ-7062?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]
Gary Tully resolved AMQ-7062. ----------------------------- Resolution: Fixed > RedeliverPlugin can loop on duplicate detection sending to dlq > -------------------------------------------------------------- > > Key: AMQ-7062 > URL: https://issues.apache.org/jira/browse/AMQ-7062 > Project: ActiveMQ > Issue Type: Bug > Components: Broker > Affects Versions: 5.15.0 > Reporter: Gary Tully > Assignee: Gary Tully > Priority: Major > Fix For: 5.16.0 > > > 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. > {code:java} > WARN | JobScheduler:JMS | AbstractStoreCursor | > gion.cursors.AbstractStoreCursor 116 | > 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 > WARN | JobScheduler:JMS | Queue | > mq.broker.region.BaseDestination 853 | duplicate message from store > ID:MYIDXXX1536652818855-25:1:2:1:4, redirecting for dlq processing > TRACE | JobScheduler:JMS | RedeliveryPlugin | > emq.broker.util.RedeliveryPlugin 173 | redelivery #31514 of: > ID:MYIDXXX1536652818855-25:1:2:1:4 with delay: 10000, dest: queue://MYQUEUEXXX > WARN | JobScheduler:JMS | AbstractStoreCursor | > gion.cursors.AbstractStoreCursor 116 | > 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 > WARN | JobScheduler:JMS | Queue | > mq.broker.region.BaseDestination 853 | duplicate message from store > ID:MYIDXXX1536652818855-25:1:2:1:4, redirecting for dlq processing > TRACE | JobScheduler:JMS | RedeliveryPlugin | > emq.broker.util.RedeliveryPlugin 173 | redelivery #31515 of: > ID:MYIDXXX1536652818855-25:1:2:1:4 with delay: 10000, dest: queue://MYQUEUEXXX > WARN | JobScheduler:JMS | AbstractStoreCursor | > gion.cursors.AbstractStoreCursor 116 | > 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 > WARN | JobScheduler:JMS | Queue | > mq.broker.region.BaseDestination 853 | duplicate message from store > ID:MYIDXXX1536652818855-25:1:2:1:4, redirecting for dlq processing > TRACE | JobScheduler:JMS | RedeliveryPlugin | > emq.broker.util.RedeliveryPlugin 173 | redelivery #31516 of: > ID:MYIDXXX1536652818855-25:1:2:1:4 with delay: 10000, dest: queue://MYQUEUEXXX > {code} > > -- This message was sent by Atlassian JIRA (v7.6.3#76005)