kombu.transport.memory

In-memory transport.

copyright:

3. 2009 - 2012 by Ask Solem.

license:

BSD, see LICENSE for more details.

Transport

class kombu.transport.memory.Transport(client, **kwargs)

class Channel(connection, **kwargs)

after_reply_message_received(queue)

do_restore = False

queues = {}

Transport.state = <kombu.transport.virtual.BrokerState object at 0x47b5e50>

memory backend state is global.

Channel

class kombu.transport.memory.Channel(connection, **kwargs)

after_reply_message_received(queue)

do_restore = False

queues = {}