Django Managers - kombu.transport.django.managers
-
class kombu.transport.django.managers.MessageManager
-
cleanup()
-
cleanup_every = 10
-
connection_for_write()
-
pop()
-
class kombu.transport.django.managers.QueueManager
-
fetch(queue_name)
-
publish(queue_name, payload)
-
purge(queue_name)
-
size(queue_name)