Should have been part of commit 795a0e19670a0fde7cef99a47702f34488e73e15.

exchange_name argument was being called queue_name in the example.

As per https://www.rabbitmq.com/resources/specs/amqp-xml-doc0-9-1.pdf
section 1.4.2.5.2.:

Zero ...

Starting with 3.5.2, the writer object is set to None in the stream
protocol. Ideally, we shoul...

Otherwise, _heartbeat_timer_recv_timeout() might try to close a
_stream_writer which is already ...

Defined as "very large", thus don't split frames ever

Otherwise, _heartbeat_timer_recv_timeout() might try to close a
_stream_writer which is already ...

Unlike other channel methods, there's no "no-wait" bit in the close method
in the AMQP protocol....

Before this, we would wait for the server to reply a 504 exception
('channel-error' as per the r...

But don't release the channel id back to the pool until the confirmation
has come. This allows ...

3 lines down, 'amqp.close()' already closes open channels since commit
3ef44fdb397c13c3ae71fff24...

Though in this spot, catching all exceptions is an awful idea.

To be addressed in issue #90.

Otherwise, the test is identical to the one right above it.

get_exchanges() only takes a 'vhost' parameter

Not a big deal in those cases, but for errors/exceptions, this is a
major improvements if a syst...

So this patch sets up 2 independent timers.

The first one is the send timer. This one is trigg...

For now this is unused but will allow us to trigger events on each
write.

Keep the client_connected() method for now as it's needed to create by
asyncio.StreamReaderProto...

This should prevent "vhost doesn't exist" issues if another rabbitmq
test suite is running on th...

The tearDown method calls setUp, which prevents the connection from
being closed, among other th...

And wrap file to 80 chars.

RabbitMQ 3.6.0 changed its handling of unknown vhosts at connect time.
See https://github.com/ra...

The AsyncioTestCaseMixin is only ever used by RabbitTestCase which in turn
is only ever "mixed" ...

On my laptop, a simple echo client and server goes from 25 req/s to
1600 req/s.

This method was missing from the original implementation.
Beware, this is a RabbitMQ extension

This method was missing from the original implementation.
Beware, this is a RabbitMQ extension

this allows the consumer to ack message from the coroutine
The callback signature is:

def calla...