You are viewing a plain text version of this content. The canonical link for it is here.
Posted to issues@activemq.apache.org by "Gary Tully (JIRA)" <ji...@apache.org> on 2018/09/25 16:58:00 UTC
[jira] [Created] (AMQ-7062) RedeliverPlugin can loop on duplicate
detection sending to dlq
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)