This document describes the current stable version of Kombu (5.3). For development docs, go here.

Simple Messaging API - kombu.simple

Simple messaging interface.

Persistent

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

Simple API for persistent queues.

channel

Current channel

producer

Producer used to publish messages.

consumer

Consumer used to receive messages.

no_ack

flag to enable/disable acknowledgments.

queue

Queue to consume from (if consuming).

queue_opts

Additional options for the queue declaration.

exchange_opts

Additional options for the exchange declaration.

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()

Buffer

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

Simple API for ephemeral queues.

channel

Current channel

producer

Producer used to publish messages.

consumer

Consumer used to receive messages.

no_ack

flag to enable/disable acknowledgments.

queue

Queue to consume from (if consuming).

queue_opts

Additional options for the queue declaration.

exchange_opts

Additional options for the exchange declaration.

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()