kombu.transport.memory

In-memory transport.

Transport

class kombu.transport.memory.Transport(client, **kwargs)[source]
class Channel(connection, **kwargs)
after_reply_message_received(queue)
close()
do_restore = False
queues = {}
supports_fanout = True
Transport.driver_name = 'memory'
Transport.driver_type = 'memory'
Transport.driver_version()[source]
Transport.state = <kombu.transport.virtual.BrokerState object>

memory backend state is global.

Channel

class kombu.transport.memory.Channel(connection, **kwargs)[source]
after_reply_message_received(queue)[source]
close()[source]
do_restore = False
queues = {}
supports_fanout = True