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

In-memory Transport - kombu.transport.memory

In-memory transport.

Transport

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

In-memory Transport.

class Channel(connection, **kwargs)

In-memory Channel.

after_reply_message_received(queue)

close()

do_restore = False

events = {}

queues = {}

supports_fanout = True

driver_name = u'memory'

driver_type = u'memory'

driver_version()

implements = {'asynchronous': False, 'exchange_type': frozenset([u'topic', u'headers', u'fanout', u'direct']), 'heartbeats': False}

state = <kombu.transport.virtual.base.BrokerState object>

memory backend state is global.

Channel

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

In-memory Channel.

after_reply_message_received(queue)

close()

do_restore = False

events = {}

queues = {}

supports_fanout = True