activemq-users mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From vv <vanisath...@gmail.com>
Subject Re: Duplicate messages with a Durable Subscriber with networked brokers
Date Wed, 19 May 2010 08:14:50 GMT

hi,

do you face any problems with the network of brokers, when the brokers get
disconnected and then gets reconnected again?.

in a 2 nodes, network-of-brokers when the 2 brokers gets disconnected due to
a communication failure, will each of the brokers acquire the lock to become
the master..later when they reconnect what will happen?


rsmith198 wrote:
> 
> UPDATE is activeMQ 5.3 install
> 
> 
> rsmith198 wrote:
>> 
>> 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-tp27827251p28605285.html
Sent from the ActiveMQ - User mailing list archive at Nabble.com.


Mime
View raw message