kombu.transport.django

Kombu transport using the Django database as a message store.

Transport

class kombu.transport.django.Transport(client, **kwargs)

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()

Transport.polling_interval = 5.0

Channel

class kombu.transport.django.Channel(connection, **kwargs)

Queue

basic_consume(queue, *args, **kwargs)

queue_model = 'kombu.transport.django.models:Queue'

refresh_connection()