This document describes the current stable version of Kombu (5.0). For development docs, go here.
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= 'kombu'¶
-
session_ttl= 30¶
-
timeout= '10s'¶
-
-
default_port= 8500¶ port number used when no port is specified.
-
driver_name= 'consul'¶ Name of driver library (e.g. ‘py-amqp’, ‘redis’).
-
driver_type= 'consul'¶ Type of driver, can be used to separate transports using the AMQP protocol (driver_type: ‘amqp’), Redis (driver_type: ‘redis’), etc…
-
class
