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.
polling_interval
= 5.0¶
-
class