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

内存中传输- kombu.transport.memory

用于Kombu的内存传输模块。

使用内存存储消息的简单传输。消息只能在线程之间传递。

功能

• 类型：虚拟

• 支持Direct：是

• 支持主题：是

• 支持扇出：否

• 支持优先级：否

• 支持TTL：支持

连接字符串

连接字符串的格式如下：

memory://

运输

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

内存中传输。

class Channel(connection, **kwargs)

内存通道。

after_reply_message_received(queue)

在收到RPC回复后调用了回调。

备注

回复队列语义：用于在收到临时回复消息后删除队列。

close()

关闭通道。

取消所有使用者，并重新排队未确认的消息。

do_restore = False

用于在通道超出范围时恢复未确认消息的标志。

events = {}

queues = {}

supports_fanout = True

如果通道支持扇出交换，则设置标志。

driver_name = 'memory'

驱动程序库的名称(例如‘py-amqp’、‘redis’)。

driver_type = 'memory'

驱动程序的类型，可用于使用AMQP协议(DRIVER_TYPE：‘AMQP’)、Redis(DRIVER_TYPE：‘REDIS’)等来分隔传输...

driver_version()

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

内存后端状态为全局。

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

渠道

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

内存通道。

after_reply_message_received(queue)

在收到RPC回复后调用了回调。

备注

回复队列语义：用于在收到临时回复消息后删除队列。

close()

关闭通道。

取消所有使用者，并重新排队未确认的消息。

do_restore = False

用于在通道超出范围时恢复未确认消息的标志。

events = {}

queues = {}

supports_fanout = True

如果通道支持扇出交换，则设置标志。