Duplicate messages with a Durable Subscriber in networked brokers I have a
network of three brokers wsmithe6400 who has two bridges one to DrWho the
other to FUJI I; I have a Durable Subscriber set up on wsmithe6400 to
receive messages from DrWho and consumer DrWho to receive message from
wsmithe6400 I am getting the following warning on wsmithe6400 “WARN |
Duplicate message add attempt rejected”. On DrWho I am seeing duplicate
messages on DrWho in response to a single message sent from wsmithe6400
Received message ID =ID:wsmith-e6400-1902-1268072594495-0:0:1:1:49
Redelivered false Timestamp 1268072621510
Received message ID =ID:wsmith-e6400-1902-1268072594495-0:0:1:1:49
redelivered false Timestamp 1268072621510
The following is a description of all configurations
Basic topology
Name wsmithe6400 read from Durable Subscriber on topic CMS Persistent
Consumer
ID ID:wsmith-e6400-1885-1268072529605-0:0 <- Name DrWho send to
(Durable Subscriber) on topic CMS Persistent Consumer -> ID
ID:node0-44544-1268072578833-0:0
wsmithe6400 send to on topic discover topic DrWho read from Consumer
on discover topic
Configuration
Name wsmithe6400
ID ID:wsmith-e6400-1885-1268072529605-0:0
<destinations>
<topic name="CMS" physicalName="wsmithe6400.activemq.CMStopic" />
<topic name="CMSPersistentConsumer"
physicalName="wsmithe6400.activemq.CMSPersistentConsumer" />
</destinations>
<networkConnectors>
<networkConnector name="BridgeToDrWho" networkTTL="1"
conduitSubscriptions="false" duplex="false"
uri="static://(tcp://192.168.9.33:61616)">
<excludedDestinations >
<topic physicalName="fuji.activemq.discovertopic"/>
</excludedDestinations>
<staticallyIncludedDestinations>
<topic physicalName="drWho.activemq.discovertopic" />
</staticallyIncludedDestinations>
</networkConnector>
<networkConnector name="BridgeToFUJI" networkTTL="1"
conduitSubscriptions="false" duplex="false"
uri="static://(tcp://192.168.8.68:61616)">
<excludedDestinations>
<topic physicalName="drWho.activemq.discovertopic" />
</excludedDestinations>
<staticallyIncludedDestinations >
<topic physicalName="fuji.activemq.discovertopic"/>
</staticallyIncludedDestinations>
</networkConnector>
<transportConnectors>
<transportConnector name="openwire" uri="tcp://0.0.0.0:61616?trace=true"
discoveryUri="multicast://default" />
</transportConnectors>
DrWho
Name DrWho
ID ID:node0-44544-1268072578833-0:0
<destinations>
<topic name="Discover"
physicalName="drWho.activemq.discovertopic" />
</destinations>
<networkConnectors>
<networkConnector name="BridgeToCMS" networkTTL="1"
duplex="false" conduitSubscriptions="false"
uri="static://(tcp://192.168.2.112:61616)">
<staticallyIncludedDestinations>
<topic
physicalName="wsmithe6400.activemq.CMSPersistentConsumer"/>
</staticallyIncludedDestinations>
</networkConnector>
</networkConnectors>
<transportConnectors>
<transportConnector name="openwire"
uri="tcp://0.0.0.0:61616?trace=true" discoveryUri="multicast://default"/>
</transportConnectors>
name FUJI
ID ID:node0-41668-1249961089344-0:0
<destinations>
<topic name="Discover"
physicalName="fuji.activemq.discovertopic" />
</destinations>
<networkConnectors>
<!-- <networkConnector uri="multicast://default" /> -->
<networkConnector name="BridgeToCMS" networkTTL="1"
duplex="false" conduitSubscriptions="false"
uri="static://(tcp://192.168.2.112:61616)" >
</networkConnector>
</networkConnectors>
<transportConnectors>
<transportConnector name="openwire"
uri="tcp://0.0.0.0:61616?trace=true" discoveryUri="multicast://default"/>
</transportConnectors>
--
View this message in context:
http://old.nabble.com/Duplicate-messages-with-a-Durable-Subscriber-with-networked-brokers-tp27827251p27827251.html
Sent from the ActiveMQ - User mailing list archive at Nabble.com.
