I'm trying to play with the QPID broker federation. And now I've another
question :)
Let's begin by explaining my configuration. I've two connected brokers :
on broker A :
------------------
the queues :
Queue Name Attributes
===========================================================================
bridge_queue_1_2785d679-8177-4303-a936-95b40e3412bf auto-del excl
bridge_queue_2_2785d679-8177-4303-a936-95b40e3412bf auto-del excl
bridge_queue_3_2785d679-8177-4303-a936-95b40e3412bf auto-del excl
fed.direct.q1
fed.direct.q2
reply-dekatonshir.21103.1 auto-del excl
topic-dekatonshir.21103.1 auto-del excl
the exchanges :
Type Exchange Name Attributes
==================================================
direct
topic qpid.management
direct amq.direct --durable
topic amq.topic --durable
fanout amq.fanout --durable
headers amq.match --durable
topic fed.topic
fanout fed.fanout
direct fed.direct
the queue fed.direct.q1 is binded to exchanges fed.direct with routing key
q1
the queue fed.direct.q1 is binded to exchanges fed.direct with routing key
q2
the route map :
Finding Linked Brokers:
localhost:5672... Ok
localhost:5673... Ok
Dynamic Routes:
Exchange fed.topic:
localhost:5673 <=> localhost:5672
Exchange fed.fanout:
localhost:5673 <=> localhost:5672
Exchange fed.direct:
localhost:5673 <=> localhost:5672
Static Routes:
none found
On broker B :
-------------------
the queues :
Queue Name Attributes
===========================================================================
bridge_queue_1_6f009106-2ffc-4f13-bbb8-1521556ba314 auto-del excl
bridge_queue_2_6f009106-2ffc-4f13-bbb8-1521556ba314 auto-del excl
bridge_queue_3_6f009106-2ffc-4f13-bbb8-1521556ba314 auto-del excl
fed.direct.q1
fed.direct.q2
reply-dekatonshir.21135.1 auto-del excl
topic-dekatonshir.21135.1 auto-del excl
the exchanges :
Type Exchange Name Attributes
==================================================
direct
topic qpid.management
direct amq.direct --durable
topic amq.topic --durable
fanout amq.fanout --durable
headers amq.match --durable
topic fed.topic
fanout fed.fanout
direct fed.direct
the route map :
Finding Linked Brokers:
localhost:5673... Ok
localhost:5672... Ok
Dynamic Routes:
Exchange fed.topic:
localhost:5672 <=> localhost:5673
Exchange fed.fanout:
localhost:5672 <=> localhost:5673
Exchange fed.direct:
localhost:5672 <=> localhost:5673
Static Routes:
none found
the queue fed.direct.q1 is binded to exchanges fed.direct with routing key
q1
the queue fed.direct.q1 is binded to exchanges fed.direct with routing key
q2
So the aim of my test is to check the behaviour of QPID with a dubious test:
I'm sending a message to the exchange fed.direct with the routing key q1 on
broker A. With my routing configuration that's mean my messages will be
routed to Broker B on the exchange fed.direct with the routing_key q1 (and
so in the queue fed.direct.q1) and it appends :
./direct_consumer.py localhost 5672 fed.direct.q1
message 0
message 1
message 2
message 3
message 4
message 5
message 6
message 7
message 8
message 9
That's all, folks!
But when trying to check if the messages has been consumed in the broker A
I'm a little disapointed because it's not the case :
./direct_consumer.py localhost 5673 fed.direct.q1
message 0
message 1
message 2
message 3
message 4
message 5
message 6
message 7
message 8
message 9
That's all, folks!
Is it because message sended on the queue fed.direct.q1 on broker B are re
sended on broker A ? Did I miss something ?
Thanks
--
View this message in context:
http://n2.nabble.com/Question-about-QPID-broker-federation-tp2449651p2450340.html
Sent from the Apache Qpid users mailing list archive at Nabble.com.
---------------------------------------------------------------------
Apache Qpid - AMQP Messaging Implementation
Project: http://qpid.apache.org
Use/Interact: mailto:[email protected]
