Add a callback to be notified when RabbitMQ has sent a
Connection.Blocked frame indicating that RabbitMQ is low on
resources. Publishers can use this to voluntarily suspend publishing,
instead of relying on back pressure throttling. The callback
will be passed the Connection.Blocked method frame.

See also ConnectionParameters.blocked_connection_timeout.

Parameters:

callback_method (method) – Callback to call on Connection.Blocked,
having the signature callback_method(pika.frame.Method), where the
method frame’s method member is of type
pika.spec.Connection.Blocked

Add a callback to be notified when RabbitMQ has sent a
Connection.Unblocked frame letting publishers know it’s ok
to start publishing again. The callback will be passed the
Connection.Unblocked method frame.

Parameters:

callback_method (method) – Callback to call on
Connection.Unblocked, having the signature
callback_method(pika.frame.Method), where the method frame’s
method member is of type pika.spec.Connection.Unblocked

Create a new channel with the next available channel number or pass
in a channel number to use. Must be non-zero if you would like to
specify but it is recommended that you let Pika manage the channel
numbers.

Parameters:

on_open_callback (method) – The callback when the channel is opened

channel_number (int) – The channel number to use, defaults to the
next available.

Disconnect from RabbitMQ. If there are any open channels, it will
attempt to close them prior to fully disconnecting. Channels which
have active consumers will attempt to send a Basic.Cancel to RabbitMQ
to cleanly stop the delivery of messages prior to closing the channel.