This document is for Kombu's development version, which can be significantly different from previous releases. Get the stable docs here: 3.0.

In-memory Transport - kombu.transport.memory

In-memory transport.

Transport

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

In-memory Transport.

class Channel(connection, **kwargs)

In-memory Channel.

after_reply_message_received(queue)
close()
do_restore = False
queues = {}
supports_fanout = True
driver_name = 'memory'
driver_type = 'memory'
driver_version()[source]
implements = {'exchange_type': frozenset({'headers', 'topic', 'fanout', 'direct'}), 'heartbeats': False, 'async': False}
state = <kombu.transport.virtual.base.BrokerState object>

memory backend state is global.

Channel

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

In-memory Channel.

after_reply_message_received(queue)[source]
close()[source]
do_restore = False
queues = {}
supports_fanout = True