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)[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¶
-
events
= {}¶
-
queues
= {}¶
-
supports_fanout
= True¶
-
-
driver_name
= 'memory'¶
-
driver_type
= 'memory'¶
-
implements
= {'asynchronous': False, 'exchange_type': frozenset({'direct', 'fanout', 'headers', 'topic'}), 'heartbeats': False}¶
-
state
= <kombu.transport.virtual.base.BrokerState object>¶ memory backend state is global.
-
class
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¶
-
events
= {}¶
-
queues
= {}¶
-
supports_fanout
= True¶
-