[
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)
