Getting warning "duplicate message ActiveMQTextMessage..." in full mesh broker network
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.