kombu.simple

Simple interface.

Persistent

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

Current channel

producer

Producer used to publish messages.

consumer

Consumer used to receive messages.

no_ack

flag to enable/disable acknowledgements.

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, exchange_opts=None, serializer=None, compression=None, **kwargs)[source]
channel

Current channel

producer

Producer used to publish messages.

consumer

Consumer used to receive messages.

no_ack

flag to enable/disable acknowledgements.

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