activemq-users mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From paul sorenson <p...@metrak.com>
Subject Re: duplicate of every message on topic
Date Mon, 28 Apr 2008 11:11:14 GMT
It appears that when starting up, messages are not duplicated.

The full configurations are here: http://paste.uni.cc/18607

cheers

paul sorenson wrote:
> I have been searching through the archives and found quite a few posts 
> re duplicate messages.  None I have seen seem to fit the situation we 
> have here.
> 
> System is ActiveMQ 5.0.0 on SuSE 9.0.
> 
> We have scaled up from 1 to 4 servers, with two identically configured 
> machines (A and B) feeding messages into the 3rd and 4th machines (C and 
> D) which among other things stores the messages in a database.  Messages 
> from C and D are sent back to A and B for management and status purposes.
> 
> The networkConnectors configurations are shown below.
> 
> Machine D is not turned on and machine B is on but idle (not providing 
> any messages).  All clients are connecting with a stomp client that has 
> proved reliable in a single ActiveMQ configuration.  In fact the whole 
> application has been running fine on a single machine.
> 
> When we send messages to /topic/DBS at machine A, two identical copies 
> are presented to the consumers machine C.
> 
> I am contemplating writing simple bridge clients to connect the ActiveMQ 
> instances and workaround this but I would much rather ActiveMQ do the 
> heavy lifting.
> 
> We tried 5.1.0 briefly but we were having trouble with connections 
> dropping out so we didn't persist.
> 
> Any clues on what we might be doing wrong would be most appreciated.
> 
> cheers
> 
> 
> A and B networkConnnectors:
> 
>     <networkConnectors>
>       <networkConnector 
> uri="static://(tcp://hostC:61616)?initialReconnectDelay=10000" 
> name="${activemq.host}-bridge00" dynamicOnly="false">
>         <dynamicallyIncludedDestinations>
>           <topic physicalName="DBA"/>
>           <topic physicalName="DBS"/>
>           <topic physicalName="MANAGEMENT"/>
>           <topic physicalName="RAC"/>
>           <topic physicalName="DAN"/>
>         </dynamicallyIncludedDestinations>
>       </networkConnector>
>       <networkConnector 
> uri="static://(tcp://hostD:61616)?initialReconnectDelay=10000" 
> name="${activemq.host}-bridge01" dynamicOnly="false">
>         <dynamicallyIncludedDestinations>
>           <topic physicalName="DBA"/>
>           <topic physicalName="DBS"/>
>           <topic physicalName="MANAGEMENT"/>
>           <topic physicalName="RAC"/>
>           <topic physicalName="DAN"/>
>         </dynamicallyIncludedDestinations>
>       </networkConnector>
>     </networkConnectors>
> 
> And on C & D:
> 
>     <networkConnectors>
>       <networkConnector 
> uri="static://(tcp://hostA:61616)?initialReconnectDelay=10000" 
> name="${activemq.host}-bridge00" dynamicOnly="false">
>         <dynamicallyIncludedDestinations>
>           <topic physicalName="MANAGEMENT"/>
>           <queue physicalName="HOT"/>
>           <queue physicalName="SENSE"/>
>         </dynamicallyIncludedDestinations>
>       </networkConnector>
>       <networkConnector 
> uri="static://(tcp://hostB:61616)?initialReconnectDelay=10000" 
> name="${activemq.host}-bridge01" dynamicOnly="false">
>         <dynamicallyIncludedDestinations>
>           <topic physicalName="MANAGEMENT"/>
>           <queue physicalName="HOT"/>
>           <queue physicalName="SENSE"/>
>         </dynamicallyIncludedDestinations>
>       </networkConnector>
>     </networkConnectors>
> 


Mime
View raw message