You are viewing a plain text version of this content. The canonical link for it is here.
Posted to users@qpid.apache.org by Daryoush Mehrtash <dm...@gmail.com> on 2011/08/19 00:33:18 UTC
Can't get federated brokers to work in
I am trying to get two qpid c++ Brokers in a federation but can't get them
to work. I am trying to get the client (python) "spout" and "drain" to be
connected on two different brokers and have a queue route between them.
Following instruction on:
https://cwiki.apache.org/qpid/using-broker-federation.html
I do the following
1) start up two brokers on two different machines
2) ON the source machine where "spout" will be running do:
qpid-config -a SOURCE_BROKER add queue public
3)ON destination machine where "drain" will be running do:
qpid-route queue add DEST_BROKER SOURCE_BROKER amq.fanout public
4)Run spout on the source machine
./spout -a SOURCE_BROKER public
5) try to run the "drain" on destination machine
./drain -a DEST_BROKER public
When I try to run drain I get error message:
Traceback (most recent call last):
> File "./drain", line 81, in <module>
> rcv = ssn.receiver(addr)
> File "<string>", line 6, in receiver
> File
> "/home/ijet/BGB/ext/qpid_python_client/qpid-0.10/python/qpid/messaging/endpoints.py",
> line 606, in receiver
> raise e
> qpid.messaging.exceptions.NotFound: no such queue: public
I can see that the route is setup
Static Routes: DEST_BROKER(ex=amq.fanout) <= SRC_BROKER(queue=public)
If I connect the drain to the source broker it sees the messages. If I do
create the queue at the destination broker, the drain doesn't throw the
exception, but it wont see any of the messages on the source broker.
Is there something else I need to do to get the brokers to talk to each
other?
Thanks
Daryoush
Re: Can't get federated brokers to work in
Posted by Gordon Sim <gs...@redhat.com>.
On 08/18/2011 11:33 PM, Daryoush Mehrtash wrote:
> I am trying to get two qpid c++ Brokers in a federation but can't get them
> to work. I am trying to get the client (python) "spout" and "drain" to be
> connected on two different brokers and have a queue route between them.
> Following instruction on:
> https://cwiki.apache.org/qpid/using-broker-federation.html
>
> I do the following
>
> 1) start up two brokers on two different machines
> 2) ON the source machine where "spout" will be running do:
>
> qpid-config -a SOURCE_BROKER add queue public
>
> 3)ON destination machine where "drain" will be running do:
>
> qpid-route queue add DEST_BROKER SOURCE_BROKER amq.fanout public
>
> 4)Run spout on the source machine
> ./spout -a SOURCE_BROKER public
>
> 5) try to run the "drain" on destination machine
> ./drain -a DEST_BROKER public
You don't have a queue called public on this broker. You either need to
point drain at amq.fanout:
./drain -a DEST_BROKER amq.fanout
or create the public and bind it to amq.fanout:
qpid-config -a DEST_BROKER add queue public
qpid-config -a DEST_BROKER bind a,q.fanout queue
---------------------------------------------------------------------
Apache Qpid - AMQP Messaging Implementation
Project: http://qpid.apache.org
Use/Interact: mailto:users-subscribe@qpid.apache.org
Re: Can't get federated brokers to work in
Posted by Daryoush Mehrtash <dm...@gmail.com>.
I am running the latest c++ build on Ubuntu 10.04.02
daryoush
On Thu, Aug 18, 2011 at 5:05 PM, Steve Huston <sh...@riverace.com> wrote:
> What platform is this on?
>
> Federation won't work correctly on Windows yet.
>
> -Steve
>
> ----- Original Message -----
> From: "Daryoush Mehrtash" <dm...@gmail.com>
> To: users@qpid.apache.org
> Sent: Thursday, August 18, 2011 6:33:18 PM
> Subject: Can't get federated brokers to work in
>
> I am trying to get two qpid c++ Brokers in a federation but can't get them
> to work. I am trying to get the client (python) "spout" and "drain" to
> be
> connected on two different brokers and have a queue route between them.
> Following instruction on:
> https://cwiki.apache.org/qpid/using-broker-federation.html
>
> I do the following
>
> 1) start up two brokers on two different machines
> 2) ON the source machine where "spout" will be running do:
>
> qpid-config -a SOURCE_BROKER add queue public
>
> 3)ON destination machine where "drain" will be running do:
>
> qpid-route queue add DEST_BROKER SOURCE_BROKER amq.fanout public
>
> 4)Run spout on the source machine
> ./spout -a SOURCE_BROKER public
>
> 5) try to run the "drain" on destination machine
> ./drain -a DEST_BROKER public
>
> When I try to run drain I get error message:
>
> Traceback (most recent call last):
> > File "./drain", line 81, in <module>
> > rcv = ssn.receiver(addr)
> > File "<string>", line 6, in receiver
> > File
> >
> "/home/ijet/BGB/ext/qpid_python_client/qpid-0.10/python/qpid/messaging/endpoints.py",
> > line 606, in receiver
> > raise e
> > qpid.messaging.exceptions.NotFound: no such queue: public
>
>
>
> I can see that the route is setup
>
> Static Routes: DEST_BROKER(ex=amq.fanout) <= SRC_BROKER(queue=public)
>
>
> If I connect the drain to the source broker it sees the messages. If I do
> create the queue at the destination broker, the drain doesn't throw the
> exception, but it wont see any of the messages on the source broker.
>
>
> Is there something else I need to do to get the brokers to talk to each
> other?
>
> Thanks
>
> Daryoush
>
> ---------------------------------------------------------------------
> Apache Qpid - AMQP Messaging Implementation
> Project: http://qpid.apache.org
> Use/Interact: mailto:users-subscribe@qpid.apache.org
>
>
Re: Can't get federated brokers to work in
Posted by Steve Huston <sh...@riverace.com>.
What platform is this on?
Federation won't work correctly on Windows yet.
-Steve
----- Original Message -----
From: "Daryoush Mehrtash" <dm...@gmail.com>
To: users@qpid.apache.org
Sent: Thursday, August 18, 2011 6:33:18 PM
Subject: Can't get federated brokers to work in
I am trying to get two qpid c++ Brokers in a federation but can't get them
to work. I am trying to get the client (python) "spout" and "drain" to be
connected on two different brokers and have a queue route between them.
Following instruction on:
https://cwiki.apache.org/qpid/using-broker-federation.html
I do the following
1) start up two brokers on two different machines
2) ON the source machine where "spout" will be running do:
qpid-config -a SOURCE_BROKER add queue public
3)ON destination machine where "drain" will be running do:
qpid-route queue add DEST_BROKER SOURCE_BROKER amq.fanout public
4)Run spout on the source machine
./spout -a SOURCE_BROKER public
5) try to run the "drain" on destination machine
./drain -a DEST_BROKER public
When I try to run drain I get error message:
Traceback (most recent call last):
> File "./drain", line 81, in <module>
> rcv = ssn.receiver(addr)
> File "<string>", line 6, in receiver
> File
> "/home/ijet/BGB/ext/qpid_python_client/qpid-0.10/python/qpid/messaging/endpoints.py",
> line 606, in receiver
> raise e
> qpid.messaging.exceptions.NotFound: no such queue: public
I can see that the route is setup
Static Routes: DEST_BROKER(ex=amq.fanout) <= SRC_BROKER(queue=public)
If I connect the drain to the source broker it sees the messages. If I do
create the queue at the destination broker, the drain doesn't throw the
exception, but it wont see any of the messages on the source broker.
Is there something else I need to do to get the brokers to talk to each
other?
Thanks
Daryoush
---------------------------------------------------------------------
Apache Qpid - AMQP Messaging Implementation
Project: http://qpid.apache.org
Use/Interact: mailto:users-subscribe@qpid.apache.org