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
-
no_ack
¶ flag to enable/disable acknowledgements.
-
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
-
no_ack
¶ flag to enable/disable acknowledgements.
-
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
()¶
-