activemq-users mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From rsmith198 <wsm...@sepaton.com>
Subject Duplicate messages with a Durable Subscriber with networked brokers
Date Mon, 08 Mar 2010 20:44:06 GMT

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.


Mime
View raw message