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

简单消息传递API- kombu.simple

简单的消息传递界面。

持久化

class kombu.simple.SimpleQueue(channel, name, no_ack=None, queue_opts=None, queue_args=None, exchange_opts=None, serializer=None, compression=None, accept=None)

持久队列的简单API。

channel

电流通道

producer

Producer 用于发布消息。

consumer

Consumer 用于接收消息。

no_ack

启用/禁用确认的标志。

queue

Queue 从…消费(如果在消费)。

queue_opts

队列声明的其他选项。

exchange_opts

交易所申报的其他选项。

get(block=True, timeout=None)

get_nowait()

put(message, serializer=None, headers=None, compression=None, routing_key=None, **kwargs)

clear()

__len__()

len(self) -> self.qsize() 。

qsize()

close()

缓冲层

class kombu.simple.SimpleBuffer(channel, name, no_ack=None, queue_opts=None, queue_args=None, exchange_opts=None, serializer=None, compression=None, accept=None)

用于临时队列的简单API。

channel

电流通道

producer

Producer 用于发布消息。

consumer

Consumer 用于接收消息。

no_ack

启用/禁用确认的标志。

queue

Queue 从…消费(如果在消费)。

queue_opts

队列声明的其他选项。

exchange_opts

交易所申报的其他选项。

get(block=True, timeout=None)

get_nowait()

put(message, serializer=None, headers=None, compression=None, routing_key=None, **kwargs)

clear()

__len__()

len(self) -> self.qsize() 。

qsize()

close()