Hi all,

It's me again.

I've been trying to get a consumer to listen to two channels using
LoopingCall: http://dpaste.com/hold/118305/. The code is modified from
the original examples. What I wanted to achieve was to listen to
different queues asynchronously (on one channel each queue). The code
which I sent both queues are on the same exchange.

A snip:
    def do(queue, chan):
        msg = yield queue.get()
        print 'Result: %s from chan id #%d' % (msg.content.body, chan.id)

    lcall = task.LoopingCall(do, queue, chan)
    lcall2 = task.LoopingCall(do, queue2, chan2)


The concrete problem I've is that I use one channel for a fanout
exchange to broadcast messages and another for a point-to-point
communication and I would like to listen to both and operate

Is this ok? Is there a better way? Should I use threads here?

Another question I've is what about terminating the connection:
How should I end the connection without sending the STOP message?

Thank you,


Mailing list: https://launchpad.net/~txamqp-user
Post to     : txamqp-user@lists.launchpad.net
Unsubscribe : https://launchpad.net/~txamqp-user
More help   : https://help.launchpad.net/ListHelp

Reply via email to