This document is for Kombu's development version, which can be significantly different from previous releases. Get the stable docs here: 4.5.
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, **kwargs)[source]¶ Simple API for persistent queues.
-
channel
¶ Current channel
-
no_ack
¶ flag to enable/disable acknowledgments.
-
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, **kwargs)[source]¶ Simple API for ephemeral queues.
-
channel
¶ Current channel
-
no_ack
¶ flag to enable/disable acknowledgments.
-
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
()¶
-