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

In-memory Transport - kombu.transport.memory

In-memory transport module for Kombu.

Simple transport using memory for storing messages. Messages can be passed only between threads.

Features

• Type: Virtual

• Supports Direct: Yes

• Supports Topic: Yes

• Supports Fanout: No

• Supports Priority: No

• Supports TTL: Yes

Connection String

Connection string is in the following format:

memory://

Transport

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

In-memory Transport.

class Channel(connection, **kwargs)

In-memory Channel.

after_reply_message_received(queue)

Callback called after RPC reply received.

Notes

Reply queue semantics: can be used to delete the queue after transient reply message received.

close()

Close channel.

Cancel all consumers, and requeue unacked messages.

do_restore = False

flag to restore unacked messages when channel goes out of scope.

events = {}

queues = {}

supports_fanout = True

flag set if the channel supports fanout exchanges.

driver_name = 'memory'

Name of driver library (e.g. ‘py-amqp’, ‘redis’).

driver_type = 'memory'

Type of driver, can be used to separate transports using the AMQP protocol (driver_type: ‘amqp’), Redis (driver_type: ‘redis’), etc…

driver_version()

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

memory backend state is global.

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

Channel

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

In-memory Channel.

after_reply_message_received(queue)

Callback called after RPC reply received.

Notes

Reply queue semantics: can be used to delete the queue after transient reply message received.

close()

Close channel.

Cancel all consumers, and requeue unacked messages.

do_restore = False

flag to restore unacked messages when channel goes out of scope.

events = {}

queues = {}

supports_fanout = True

flag set if the channel supports fanout exchanges.