Mailing-List: contact users-help@activemq.apache.org; run by ezmlm
Precedence: bulk
Reply-To: users@activemq.apache.org
Received-SPF: neutral (athena.apache.org: 216.139.236.26 is neither permitted
 nor denied by domain of anubhava@aol.com)
Date: Mon, 28 Mar 2011 15:18:25 -0700 (PDT)
From: anuhbava <anubhava@aol.com>
To: users@activemq.apache.org
Message-ID: <1301350705390-3413235.post@n4.nabble.com>
In-Reply-To: <AANLkTimT3xwpywa1WXJCDnD=r9JSmCVjF=0d9rwRTnJA@mail.gmail.com>
References: <1300488137874-3388635.post@n4.nabble.com>
 <AANLkTimpj775CCsT_iVCPFgf-H-2n1iY4PJJQPBvwcBT@mail.gmail.com>
 <AANLkTimY2BGViqXOWaE1d3ALUD2aYJ2j7Xs2ZQ8=bwd8@mail.gmail.com>
 <AANLkTikUwKF92Hz0hNy9DOyMN28egBZDmtRQvWHZbjSg@mail.gmail.com>
 <AANLkTi=N3LaQ4AWP8hK48OYAgWpSVodvjw4AN57j3+vz@mail.gmail.com>
 <AANLkTinc1PDi931s3do2H9M5WMxBWKU8KjEWmFOds7G6@mail.gmail.com>
 <1300827317566-3397734.post@n4.nabble.com>
 <AANLkTimt4nmEhQPLb9zuCOgdsQt4k4BHMD41=-VZAU5z@mail.gmail.com>
 <1301004692891-3403957.post@n4.nabble.com>
 <AANLkTimT3xwpywa1WXJCDnD=r9JSmCVjF=0d9rwRTnJA@mail.gmail.com>
Subject: Re: network of broker stop forwarding messages without
 advisorySupport enabled
MIME-Version: 1.0
Content-Type: text/plain; charset=us-ascii
Content-Transfer-Encoding: 7bit

Hi Gary,

Thanks for pointing the source code to me, its been a great help to try &
understand how AMQ code is behaving for these scenarios.

Here is what I found so far:
1. connectionFactory.setClientIDPrefix("ID:ReplyDest.host") and
connectionFactory.setClientID("ID:ReplyDest.host") calls are completely
ignored while creating a new temporary queue name.
2. session.createQueue("ID:ReplyDest.host-client-queue-" + new Date());
throws exception as I mentioned earlier as well.
3. Only hack I could find to alter the naming convention was this call:
((ActiveMQConnection)
connection).getConnectionInfo().getConnectionId().setValue("ID:ReplyDest.");
4. Using above trick will alter the naming convention of temporary
destinations as temp-queue://ID:ReplyDest.12334535345.1
5. However when I added this in activemq.xml in
staticallyIncludedDestinations tag:
    "/>
    Brokers ignored this directive for temporary destinations inclusions. It
seems staticallyIncludedDestinations only works for named queues and topics
but not for temp destinations.
6. Now if I create regular destinations using
session.createTopic("ReplyDest.client-topic" + new Date()); and have
corresponding staticallyIncludedDestinations inclusions then my
request/responses flow without problems.
7. As per your very nice suggestion I have now included 
 " advisoryForConsumed="false" advisoryForDelivery="false" 
gcInactiveDestinations="true" inactiveTimoutBeforeGC="30000"/>

in my destinationPolicy tag. However what I noticed is that even if producer
and consumer are killed but these newly created named topics are NOT deleted
until all but one the broker are shutdown. Which is somewhat unexpected
behavior and it may not work for us since at no time we are going to
shutdown our AMQ brokers in production, even though producer/consumers can
be very dynamic and can start/stop many times. Do you have any other
suggestion for my case, one that can cleanup/remove these (temporary for my
use case but not really temporary for AMQ) destinations without stopping any
brokers?

many thanks for your help so far,
Anubhava


--
View this message in context: http://activemq.2283324.n4.nabble.com/network-of-broker-stop-forwarding-messages-without-advisorySupport-enabled-tp3386261p3413235.html
Sent from the ActiveMQ - User mailing list archive at Nabble.com.