This document is for Kombu's development version, which can be significantly different from previous releases. Get the stable docs here: 5.3.
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)[source]¶
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…
- 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)[source]¶
In-memory Channel.
- after_reply_message_received(queue)[source]¶
Callback called after RPC reply received.
Notes
Reply queue semantics: can be used to delete the queue after transient reply message received.
- 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.