Django Managers - kombu.transport.django.managers
-
class
kombu.transport.django.managers.
MessageManager
[source]
-
cleanup
()[source]
-
cleanup_every
= 10
-
connection_for_write
()[source]
-
pop
(*args, **kwargs)[source]
-
class
kombu.transport.django.managers.
QueueManager
[source]
-
fetch
(queue_name)[source]
-
publish
(queue_name, payload)[source]
-
purge
(queue_name)[source]
-
size
(queue_name)[source]
-
kombu.transport.django.managers.
commit_on_success
(fun)[source]
-
kombu.transport.django.managers.
select_for_update
(qs)[source]