This document is for Kombu's development version, which can be significantly different from previous releases. Get the stable docs here: 4.3.
Consul Transport - kombu.transport.consul
¶
Consul Transport.
It uses Consul.io’s Key/Value store to transport messages in Queues
It uses python-consul for talking to Consul’s HTTP API
Transport¶
-
class
kombu.transport.consul.
Transport
(*args, **kwargs)[source]¶ Consul K/V storage Transport for Kombu.
-
class
Channel
(*args, **kwargs)¶ Consul Channel class which talks to the Consul Key/Value store.
-
index
= None¶
-
lock_name
¶
-
prefix
= u'kombu'¶
-
session_ttl
= 30¶
-
timeout
= u'10s'¶
-
-
default_port
= 8500¶
-
driver_name
= u'consul'¶
-
driver_type
= u'consul'¶
-
class