implementing async rpc client about py-amqp

[ask]

Channel.wait is a relic from amqplib, I don't believe it's used anymore.

Connection.drain_events is the common way to read from the socket, it will drain events from all channels and supports a timeout argument. Like channel.wait it's also a blocking function though, so if you want to drain events asynchronously you should use select/poll/epoll to call the function when the socket is readable.

kombu.async is what celery uses to consume messages asynchronously, but the API is not really public yet. You don't have to use kombu, as you should be able to write a simple select loop around py-amqp, but you will have to learn how to do that elsewhere.

[eandersson]

As a temporary solution I set a timeout on drain_events and simply caught the timeout event. Works like a charm. Thanks.