Getting warning "duplicate message ActiveMQTextMessage..." in full mesh broker network

Solution Verified - Updated -

Issue

Note: In a broker network there are multiple possible reasons for getting duplicate messages. This article captures a specific use-case only and does not attempt to address all possible causes.

This particular case had a very special setup:
* A full broker mesh of 4 ActiveMQ broker instances
* consumers connecting to a broker randomly and disconnecting after a few msgs
* the configuration

  <conditionalNetworkBridgeFilterFactory replayWhenNoConsumers="true" />

present in each brokers config

During extensive tests where two or more consumers disconnect and reconnect to a different broker quickly the following warning would got logged for a number of messages:

[2014-01-21 19:56:25,789] WARN ActiveMQ NIO Worker 5 Queue.java 1999 Queue - queue://TEST.FOO,
subscriptions=2, memory=0%, size=0, in flight groups=active message group buckets: 0, duplicate message 
ActiveMQTextMessage {commandId = 1781, responseRequired = true, messageId = ID:mac.fritz.box-
64039-1390330516163-35:1:1:1:286, originalDestination = null, originalTransactionId = null, producerId = 
ID:mac.fritz.box-64039-1390330516163-30:2:1:1, destination = queue://TEST.FOO, transactionId = null, 
expiration = 0, timestamp = 1390330537024, arrival = 0, brokerInTime = 1390330585788, brokerOutTime = 
1390330585788, correlationId = null, replyTo = null, persistent = true, type = null, priority = 4, groupID =
 null, groupSequence = 0, targetConsumerId = null, compressed = false, userID = null, content = null, 
marshalledProperties = null, dataStructure = null, redeliveryCounter = 0, size = 1078, properties = null, 
readOnlyProperties = false, readOnlyBody = false, droppable = false, text = TestMessage with prefix 
forBroker1 and counter 285} paged in, is cursor audit disabled? Removing from store and redirecting to dlq

Environment

  • JBoss Fuse 6.1
  • JBoss Fuse 6.0 patch 6

Subscriber exclusive content

A Red Hat subscription provides unlimited access to our knowledgebase, tools, and much more.

Current Customers and Partners

Log in for full access

Log In

New to Red Hat?

Learn more about Red Hat subscriptions

Using a Red Hat product through a public cloud?

How to access this content