kombu.transport.memory

In-memory transport.

Transport

class kombu.transport.memory.Transport(client, **kwargs)
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()
Transport.state = <kombu.transport.virtual.BrokerState object at 0x7f954959d450>

memory backend state is global.

Channel

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

Table Of Contents

Previous topic

kombu.transport.qpid

Next topic

kombu.transport.redis

This Page