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]