Re: Issue creating a distributed queue using store and forward.

2009-10-08 Thread farshad
Hi Eric, I think you and I have run into the same problem. Please check below. Farshad http://www.nabble.com/Question-about-Queue-destinations-in-network-of-brokers-td25776018.html Eric Van wrote: ActiveMQ 5.3.0_SNAPSHOT (Sep 8th according to the snapshots listing) I'm running

Question about Queue destinations in network of brokers

2009-10-06 Thread farshad
I have a network of 4 brokers configuration with failover://(tcp://host1:61616,tcp://host2:61616,...) defined. My first piece of java code connects to one of these hosts (randomly) and puts some messages in a queue destination (e.g. Document.QUEUE). A second piece of java code connects to

Re: Question about Queue destinations in network of brokers

2009-10-06 Thread farshad
the appropriate values assigned to the networkTTL and dynamicOnly parameters. http://activemq.apache.org/networks-of-brokers.html Joe http://www.ttmsolutions.com farshad wrote: I have a network of 4 brokers configuration with failover://(tcp://host1:61616,tcp://host2:61616

Re: Question about Queue destinations in network of brokers

2009-10-06 Thread farshad
Hi Joe, Thanks again for your reply. Do you know when 5.3 is going to be released? -Farshad Joe Fernandez wrote: Hi Farshad, You may have encountered the following problem: http://issues.apache.org/activemq/browse/AMQ-2135 It is a rather nasty problem where messages become stuck

Re: Distributed brokers and faiovers

2009-10-05 Thread farshad
use an ActiveMQConnectionFactory which needs to be connected to a broker URL specifically. So, if that broker is down do I need to try a different broker myself or does ActiveMQ's failover would connect to a different broker? If so, how? Thanks, Farshad Dejan Bosanac wrote: Hi, check

Distributed brokers and faiovers

2009-10-02 Thread farshad
Hi, I am new to ActiveMQ and am trying to use it in a distributed way. I statically define my brokers as: networkConnectoruri=static://(tcp://host1:61616,tcp://host2:61616,tcp://host3:61616,tcp://host4:61616)/ And transportConnector name=openwire uri=tcp://localhost:61616 / I connect to host1