Return-Path: 
 <users-return-11115-apmail-activemq-users-archive=activemq.apache.org@activemq.apache.org>
Delivered-To: apmail-activemq-users-archive@www.apache.org
Received: (qmail 97042 invoked from network); 23 Oct 2007 13:32:30 -0000
Received: from hermes.apache.org (HELO mail.apache.org) (140.211.11.2)
  by minotaur.apache.org with SMTP; 23 Oct 2007 13:32:30 -0000
Received: (qmail 61892 invoked by uid 500); 23 Oct 2007 13:32:17 -0000
Delivered-To: apmail-activemq-users-archive@activemq.apache.org
Received: (qmail 61869 invoked by uid 500); 23 Oct 2007 13:32:17 -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 61860 invoked by uid 99); 23 Oct 2007 13:32:17 -0000
Received: from athena.apache.org (HELO athena.apache.org) (140.211.11.136)
    by apache.org (qpsmtpd/0.29) with ESMTP; Tue, 23 Oct 2007 06:32:17 -0700
X-ASF-Spam-Status: No, hits=2.6 required=10.0
	tests=DNS_FROM_OPENWHOIS,SPF_HELO_PASS,SPF_PASS,WHOIS_MYPRIVREG
X-Spam-Check-By: apache.org
Received-SPF: pass (athena.apache.org: domain of lists@nabble.com designates
 216.139.236.158 as permitted sender)
Received: from [216.139.236.158] (HELO kuber.nabble.com) (216.139.236.158)
    by apache.org (qpsmtpd/0.29) with ESMTP; Tue, 23 Oct 2007 13:32:18 +0000
Received: from isper.nabble.com ([192.168.236.156])
	by kuber.nabble.com with esmtp (Exim 4.63)
	(envelope-from <lists@nabble.com>)
	id 1IkJrR-0006Qn-JP
	for users@activemq.apache.org; Tue, 23 Oct 2007 06:31:57 -0700
Message-ID: <13364379.post@talk.nabble.com>
Date: Tue, 23 Oct 2007 06:31:57 -0700 (PDT)
From: ttmdev <joe.fernandez@ttmsolutions.com>
To: users@activemq.apache.org
Subject: Re: Store and forward brokers issue
In-Reply-To: <13342280.post@talk.nabble.com>
MIME-Version: 1.0
Content-Type: text/plain; charset=us-ascii
Content-Transfer-Encoding: 7bit
X-Nabble-From: joe.fernandez@ttmsolutions.com
References: <13342280.post@talk.nabble.com>
X-Virus-Checked: Checked by ClamAV on apache.org


Vinod,

Try setting the network connector attribute called 'dynamicOnly' to true as
follows. 

<networkConnector name="default-nc" dynamicOnly="true"
uri="multicast://default"/> 

This will instruct the broker to forward messages only if there are active
consumers at the connected broker. By default, dynamicOnly is set to false. 

Joe
 


Vinod Venkatraman wrote:
> 
> Hi,
> 
> Am using apache-activemq-5.0-20071015.164042-22.zip
> 
> I have couple of standalone store and forward brokers running. With
> configuration as shown below. Producers/Consumers/Brokers are using
> multicast discovery.
> 
> Following is the problem i am facing:
> When producer and consumer happen to discover and connect to the same
> broker (say B1) even then many messages are getting forwarded to B2. And
> since there are no consumers on B2 they remain there and are never
> consumed. 
> 
> Meanwhile the consumer connected to B1 receives no/very few messages.
> 
> I verified this by making a 2nd consumer connect directly to B2 and then
> it consumes all the forwarded messages.
> 
> What I was expecting is that messages would never be forwarded to B2 as it
> does not have any registered consumers.
> 
> When producer and consumer happen to discover and connect to different
> brokers things work fine and all messages are consumed. 
> 
> Any help would be appreciated.
> 
> <beans>
> 
>   <!-- Allows us to use system properties as variables in this
> configuration file -->
>   <bean
> class="org.springframework.beans.factory.config.PropertyPlaceholderConfigurer"/>
> 
>     <broker brokerName="broker_vinod" useJmx="true"
> xmlns="http://activemq.org/config/1.0">
>     <persistenceAdapter>
>         <journaledJDBC journalLogFiles="5"
> dataDirectory="${activemq.base}/activemq-data/broker1_slave"/>
>     </persistenceAdapter>
> 
>     <transportConnectors>
>        <transportConnector name="openwire" uri="tcp://localhost:61616"
> discoveryUri="multicast://default"/>
>     </transportConnectors>
> 
>     <networkConnectors>
>       <!-- by default just auto discover the other brokers -->
>       <networkConnector name="default-nc" uri="multicast://default"/>
>     </networkConnectors>
> 
>   </broker>
> 
> 
> 
> Thanks,
> Vinod
> 

-- 
View this message in context: http://www.nabble.com/Store-and-forward-brokers-issue-tf4670537s2354.html#a13364379
Sent from the ActiveMQ - User mailing list archive at Nabble.com.