Django Managers - kombu.transport.django.managers

class kombu.transport.django.managers.MessageManager

cleanup()

cleanup_every = 10

connection_for_write()

pop(*args, **kwargs)

class kombu.transport.django.managers.QueueManager

fetch(queue_name)

publish(queue_name, payload)

purge(queue_name)

size(queue_name)

kombu.transport.django.managers.select_for_update(qs)