kombu.compression

Object utilities.

copyright:

3. 2009 - 2012 by Ask Solem.

license:

BSD, see LICENSE for more details.

class kombu.abstract.MaybeChannelBound(*args, **kwargs)

Mixin for classes that can be bound to an AMQP channel.

bind(channel)

Create copy of the instance that is bound to a channel.

can_cache_declaration = False

Defines whether maybe_declare can skip declaring this entity twice.

channel

Current channel if the object is bound.

is_bound

Flag set if the channel is bound.

maybe_bind(channel)

Bind instance to channel if not already bound.

revive(channel)

Revive channel after the connection has been re-established.

Used by ensure().

when_bound()

Callback called when the class is bound.