Re: [Txamqp-user] How do you listen to different queues asynchronously?

Hi Esteve, 2009/11/17 Esteve Fernandez esteve.fernan...@gmail.com: and then, when the user quits the application, put the STOP_TOKEN object in the queue:    queue.put(STOP_TOKEN) remember that when you call queue() on a channel instance, you get an instance of DeferredQueue

Re: [Txamqp-user] How do you listen to different queues asynchronously?

Esteve == Esteve Fernandez esteve.fernan...@gmail.com writes: Esteve there's probably something I'm missing here, but why are you Esteve defining a function and attaching it to an errback if you're Esteve already using inlineCallbacks? This looks cleaner to me: I wasn't understanding Ale's

Re: [Txamqp-user] How do you listen to different queues asynchronously?

Ale == Ale peralta.alejan...@gmail.com writes: Ale This is the sort of thing I wanted to achieve but without trapping Ale exceptions. I don't know how dirty this is (a snip, for the whole Ale file see paste): Ale def whichEverFiresFirst(def1, def2): Hi Ale If you want a deferred that fires

Re: [Txamqp-user] How do you listen to different queues asynchronously?

2009/11/15 Terry Jones te...@fluidinfo.com: Hi Terry, Thanks for your response If you want a deferred that fires with the first of n other deferreds, you can just do this:    from twisted.internet import defer    d = defer.DeferredList([def1, def2], fireOnOneCallback=True) I'll look