Gary Tully created AMQ-7062:
-------------------------------
Summary: 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
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)
