kombu.transport.django

Kombu transport using the Django database as a message store.

Transport

class kombu.transport.django.Transport(client, **kwargs)[source]
class Channel(connection, **kwargs)
Queue
basic_consume(queue, *args, **kwargs)
queue_model = 'kombu.transport.django.models:Queue'
refresh_connection()
Transport.channel_errors = (<class 'amqp.exceptions.ChannelError'>, <class 'django.core.exceptions.ObjectDoesNotExist'>, <class 'django.core.exceptions.MultipleObjectsReturned'>)
Transport.default_port = 0
Transport.driver_name = 'django'
Transport.driver_type = 'sql'
Transport.driver_version()[source]
Transport.polling_interval = 5.0

Channel

class kombu.transport.django.Channel(connection, **kwargs)[source]
Queue[source]
basic_consume(queue, *args, **kwargs)[source]
queue_model = 'kombu.transport.django.models:Queue'
refresh_connection()[source]