Return-Path: 
 <users-return-13738-apmail-activemq-users-archive=activemq.apache.org@activemq.apache.org>
Delivered-To: apmail-activemq-users-archive@www.apache.org
Received: (qmail 15024 invoked from network); 24 Apr 2008 10:58:20 -0000
Received: from hermes.apache.org (HELO mail.apache.org) (140.211.11.2)
  by minotaur.apache.org with SMTP; 24 Apr 2008 10:58:20 -0000
Received: (qmail 76276 invoked by uid 500); 24 Apr 2008 10:58:21 -0000
Delivered-To: apmail-activemq-users-archive@activemq.apache.org
Received: (qmail 76258 invoked by uid 500); 24 Apr 2008 10:58:20 -0000
Mailing-List: contact users-help@activemq.apache.org; run by ezmlm
Precedence: bulk
List-Help: <mailto:users-help@activemq.apache.org>
List-Unsubscribe: <mailto:users-unsubscribe@activemq.apache.org>
List-Post: <mailto:users@activemq.apache.org>
List-Id: <users.activemq.apache.org>
Reply-To: users@activemq.apache.org
Delivered-To: mailing list users@activemq.apache.org
Received: (qmail 76247 invoked by uid 99); 24 Apr 2008 10:58:20 -0000
Received: from athena.apache.org (HELO athena.apache.org) (140.211.11.136)
    by apache.org (qpsmtpd/0.29) with ESMTP; Thu, 24 Apr 2008 03:58:20 -0700
X-ASF-Spam-Status: No, hits=1.2 required=10.0
	tests=SPF_NEUTRAL
X-Spam-Check-By: apache.org
Received-SPF: neutral (athena.apache.org: local policy)
Received: from [211.29.132.186] (HELO mail05.syd.optusnet.com.au)
 (211.29.132.186)
    by apache.org (qpsmtpd/0.29) with ESMTP; Thu, 24 Apr 2008 10:57:35 +0000
Received: from homer.home.metrak.com
 (c122-107-206-136.eburwd5.vic.optusnet.com.au [122.107.206.136])
	by mail05.syd.optusnet.com.au (8.13.1/8.13.1) with ESMTP id m3OAvieP016029
	for <users@activemq.apache.org>; Thu, 24 Apr 2008 20:57:45 +1000
Received: from [127.0.0.1] (homer.home.metrak.com [127.0.0.1])
	by homer.home.metrak.com (Postfix) with ESMTP id 37B3B670117
	for <users@activemq.apache.org>; Thu, 24 Apr 2008 20:57:44 +1000 (EST)
Message-ID: <481067A7.4070106@metrak.com>
Date: Thu, 24 Apr 2008 20:57:43 +1000
From: paul sorenson <sf@metrak.com>
User-Agent: Thunderbird 1.5.0.12 (X11/20070719)
MIME-Version: 1.0
To: users@activemq.apache.org
Subject: duplicate of every message on topic
Content-Type: text/plain; charset=ISO-8859-1; format=flowed
Content-Transfer-Encoding: 7bit
X-Virus-Checked: Checked by ClamAV on apache.org

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>