activemq-dev mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From "Ron Koerner (JIRA)" <>
Subject [jira] [Updated] (AMQ-4924) Duplicate messages are left in the persistence store
Date Wed, 11 Dec 2013 11:34:07 GMT


Ron Koerner updated AMQ-4924:

This also seemst to be a duplicate of

> Duplicate messages are left in the persistence store
> ----------------------------------------------------
>                 Key: AMQ-4924
>                 URL:
>             Project: ActiveMQ
>          Issue Type: Bug
>          Components: Broker
>    Affects Versions: 5.8.0, 5.9.0
>            Reporter: Ron Koerner
>            Assignee: Rob Davies
>             Fix For: 5.10.0
>         Attachments:
> We have a local and remote broker connected with a duplex bridge, which is initiated
by the remote broker.
> Producers are attached to the remote broker, one consumer to the local broker.
> The following scenario causes messages to be left in the local store, which are replayed
when the local broker is restarted:
> # messages are forwarded from the remote broker to the local broker
> # messages are dispatched to the local consumer
> # the connection between the local and remote broker fails
> # the local broker tries to acknowledge the message reception to the remote broker, which
> # the remote broker reconnects
> # the messages are resent
> # the local broker correctly identifies them as duplicates, but puts them into the store
nevertheless where they remain until the local broker is restarted
> # other messages are produced and consumed without a problem
> # the local broker is restarted
> # the duplicates are now delivered to the local consumer again and of course out of order
> This behaviour can be identified by a queue size which does not seem to shrink below
a certain number, even if a consumer is connected and consuming other messages.
> When the log level is set to TRACE these messages indicate the problem:
> {code}
> 2013-12-06 20:35:17,405 TRACE .a.a.b.r.c.AbstractStoreCursor -,batchResetNeeded=false,storeHasMessages=true,size=0,cacheEnabled=true,maxBatchSize:1
- cursor got duplicate: ID:smcexp5-58011-1386358514283-7:1:1:1:1, 4 [ActiveMQ VMTransport:
> 2013-12-06 20:35:17,412 TRACE .a.a.b.r.c.AbstractStoreCursor -,batchResetNeeded=false,storeHasMessages=false,size=1,cacheEnabled=false,maxBatchSize:1
- fillBatch [ActiveMQ BrokerService[LOCAL] Task-2]
> {code}

This message was sent by Atlassian JIRA

View raw message