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]