This document describes the current stable version of Kombu (4.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)

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'

Transport.default_port = 8500

Transport.driver_name = u'consul'

Transport.driver_type = u'consul'

Transport.driver_version()

Transport.verify_connection(connection)

Channel

class kombu.transport.consul.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'