RPC commands are now synchronized with the protocol.worker
using future.

basic_consume now takes a required callback argument.
I removed the Queue() to prevent receiving...

This enables the pause/resume writing on the wire
implemented in asyncio to control the flow

c....

Add method to handle CLASS_BASIC+QOS_OK

Write priority even if it is zero

/ is the default virtualhost, but
when declaring a virtualhost foo on an amqp,
/foo is not the v...

Signed-off-by: Thomas Recouvreux <[email protected]>

`channel.close()` and `amqp.close()` are now coroutine, by default they
block until the server r...

Signed-off-by: Thomas Recouvreux <[email protected]>

Fix #11

* Replace `protocol.close_client()` by `protocol.close()` and
`protocol.wait_closed()`....

Propagate ssl attribute
Log warning on ssl use because it is not supported yet
Log warning on lo...

Conflicts:
aioamqp/protocol.py

When a frame format is missing, if the dispatch_frame
raise a KeyError, Protocol.dispatch_frame ...

Full_name of queues is now more hidden than before. A very small amount
of tests need to know th...

start_connection now trigger self.dispatch_frame() to ensure we receive
responses from the serve...

* Add the ability to delete a queue (Channel.queue_delete(..))
* Return the response frame for v...