Mailing-List: contact users-help@activemq.apache.org; run by ezmlm
Precedence: bulk
Reply-To: users@activemq.apache.org
Received-SPF: pass (nike.apache.org: domain of torsten@fusesource.com
 designates 209.85.214.43 as permitted sender)
Content-Type: text/plain; charset=us-ascii
Mime-Version: 1.0 (Apple Message framework v1084)
Subject: Re: master/slave, consumer can not failover
From: Torsten Mielke <torsten@fusesource.com>
In-Reply-To: <1340884772317-4653639.post@n4.nabble.com>
Date: Thu, 28 Jun 2012 14:58:29 +0200
Content-Transfer-Encoding: quoted-printable
Message-Id: <3AED63DF-5722-4A02-95EC-0055F91E81A2@fusesource.com>
References: <1340884772317-4653639.post@n4.nabble.com>
To: users@activemq.apache.org

What's the consumer's logging output?=20
When you shut down the master on hostA, the consumer will loose its =
connection to the broker and should try to reconnect. It will try both =
of the tcp urls in your list until it reconnects.

Also, can you confirm that your slave broker starts up just fine on the =
port number that you specified in your failover url of the consumer?


Regards,

Torsten Mielke
torsten@fusesource.com
tmielke@blogspot.com


On Jun 28, 2012, at 1:59 PM, bizcenter wrote:

> *Deploy the brokers with master/slave, when master stops, consumer can =
not
> reconnect to slave.*
>=20
> code example:
> /String brokerUrl =3D "failover:(tcp://hostA, tcp://hostB)";
> try {
>                connection =3D factory.createConnection();
>            // if a durable topic subscription, and client id must be =
unique
>            if (durable && null !=3D clientId && clientId.length() > 0) =
{
>                connection.setClientID(clientId);
>            }
>            connection.setExceptionListener(this);
>            connection.start();
>=20
>            session =3D connection.createSession(transacted, ackMode);
>            if (isTopic) {
>                destination =3D session.createTopic(subject);
>            } else {
>                destination =3D session.createQueue(subject);
>            }
>=20
>            if (isTopic && durable) {
>                if (null !=3D this.filter) {
>                    consumer =3D =
session.createDurableSubscriber((Topic)
> destination, consumerName, this.filter, false);
>                } else {
>                    consumer =3D =
session.createDurableSubscriber((Topic)
> destination, consumerName);
>                }
>            } else {
>                if (null !=3D this.filter) {
>                    consumer =3D session.createConsumer(destination,
> this.filter);
>                } else {
>                    consumer =3D session.createConsumer(destination);
>                }
>            }
>=20
>            if (this.receiveTimeout =3D=3D 0) {
>                consumer.setMessageListener(this);
>            } else {
>                consumeMessagesAndClose(connection, session, consumer,
> receiveTimeout);
>            }
> // no execution about closing connection, session, consumer/
> =
--------------------------------------------------------------------------=
----------------
>=20
> anyone can give me a favor? thanks. (my english is poor...)
>=20
>=20
>=20
> --
> View this message in context: =
http://activemq.2283324.n4.nabble.com/master-slave-consumer-can-not-failov=
er-tp4653639.html
> Sent from the ActiveMQ - User mailing list archive at Nabble.com.