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

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)

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)

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