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 v1085)
Subject: Re: JMS Bridge - trying to copy all messages to remote server
From: Torsten Mielke <torsten@fusesource.com>
In-Reply-To: <1353962485827-4659769.post@n4.nabble.com>
Date: Tue, 27 Nov 2012 09:30:52 +0100
Content-Transfer-Encoding: quoted-printable
Message-Id: <998E95D0-7ED9-48D3-B66D-ACFA105BB946@fusesource.com>
References: <1353962485827-4659769.post@n4.nabble.com>
To: users@activemq.apache.org

Hello,

Do you have a local consumer connected to your queue on the local =
broker?
The fact that only every second message seems to be passed to the remote =
broker, suggests this.

If you have multiple consumers on a particular queue, then messages get =
pushed to consumers in a round robin fashion. Could this be your =
problem?=20

Regards,

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


On Nov 26, 2012, at 9:41 PM, javatestcase wrote:

> Been trying to get ActiveMQ 5.7.0 running on JBossAS 5.1.0 set up to =
use a
> JMS to JMS bridge to copy every message from a queue on the local =
broker to
> a remote broker (both are ActiveMQ).
>=20
> I've tried numerous setups, none worked yet. The primary JBoss server
> processes a request, then uses a ActiveMQ client to ultimately call a
> producer.send() to the queue. Currently the queues on the local and =
remote
> server are named the same thing. I tried making them different with no
> affect, but that could be an issue.
>=20
> Currently, the messages are being "balanced" between the primary and =
the
> secondary. So first message goes to the primary queue, the second goes =
to
> the secondary queue. Clearly the bridge is functioning, but not the =
way I'd
> want.  I'd like message one and two to both exist in the local and =
remote
> queue.
>=20
> Here is the partial setup on the primary server.
>=20
> <jmsBridgeConnectors>
>  <jmsQueueConnector outboundQueueConnectionFactory=3D"#remoteFactory"> =
              =20
>    <inboundQueueBridges>
>      <inboundQueueBridge inboundQueueName =3D "importRequestQueue"
> localQueueName =3D "importRequestQueue"/>
>    </inboundQueueBridges>
>    <outboundQueueBridges>
>       <outboundQueueBridge outboundQueueName =3D "importRequestQueue"
> localQueueName =3D "importRequestQueue"/>
>    </outboundQueueBridges>
>  </jmsQueueConnector>
> </jmsBridgeConnectors>
>=20
> <destinations>
>  <queue physicalName=3D"importRequestQueue"/>   =20
> </destinations>
>=20
> <transportConnector name=3D"primary" uri=3D"tcp://10.10.10.1:61616"/>
>=20
> <bean id=3D"remoteFactory"
> class=3D"org.apache.activemq.ActiveMQConnectionFactory">
>  <property name=3D"brokerURL" value=3D"tcp://10.10.10.2:61666" />
> </bean>
> The secondary server currently has just this. I tried adding the JMS =
bridge
> on this side too, but it didn't seem to change the behavior.
>=20
> <destinations>
>  <queue physicalName=3D"importRequestQueue"/>   =20
> </destinations>
>=20
> <transportConnector name=3D"secondary" uri=3D"tcp://10.10.10.2:61616"/>
> I've seen posts that seem to indicate the bridge works as I expect. =
Perhaps
> I am missing some additional configuration?
>=20
> I've also experimented with NetworkConnector settings, and even
> programatically creating a ForwardingBridge, but haven't been able to =
create
> the desired behavior.  It seems like any of these options should work, =
but
> I'm stuck.
>=20
> Any help would be greatly appreciated.
>=20
>=20
>=20
> --
> View this message in context: =
http://activemq.2283324.n4.nabble.com/JMS-Bridge-trying-to-copy-all-messag=
es-to-remote-server-tp4659769.html
> Sent from the ActiveMQ - User mailing list archive at Nabble.com.