qpid-users mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From ffrenchm <ffrench.mathi...@gmail.com>
Subject Re: Question about QPID broker federation
Date Mon, 09 Mar 2009 17:58:52 GMT

I'm must say I did the same test with a static uni directional route and I've
the same problem. The messages are never consumed on the source broker and I
do not know how to force the consumption of messages in the source broker. I
do not understand the reason of this behaviour : is it not dangerous to keep
message duplicates in the brokers network ?


ffrenchm wrote:
> 
> 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-tp2449651p2450576.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:users-subscribe@qpid.apache.org


Mime
View raw message