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)

basic_consume(queue, *args, **kwargs)

refresh_connection()

Transport.channel_errors = (<class 'kombu.exceptions.StdChannelError'>, <class 'django.core.exceptions.ObjectDoesNotExist'>, <class 'django.core.exceptions.MultipleObjectsReturned'>)

Transport.connection_errors = ()

Transport.default_port = 0

Transport.polling_interval = 5.0

Channel

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

basic_consume(queue, *args, **kwargs)

refresh_connection()