This document is for Kombu's development version, which can be significantly different from previous releases. Get the stable docs here: 5.3.

# Consul Transport - `kombu.transport.consul`

Consul Transport module for Kombu.

## Features

It uses Consul.io’s Key/Value store to transport messages in Queues

It uses python-consul for talking to Consul’s HTTP API

## Features

- Type: Native

- Supports Direct: Yes

- Supports Topic: Unreviewed

- Supports Fanout: Unreviewed

- Supports Priority: Unreviewed

- Supports TTL: Unreviewed

## Connection String

Connection string has the following format:

    consul://CONSUL_ADDRESS[:PORT]

## 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
    property 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…

  driver_version()
  verify_connection(connection)

## Channel

class kombu.transport.consul.Channel(*args, **kwargs)

  Consul Channel class which talks to the Consul Key/Value store.

  index = None
  property lock_name
  prefix = 'kombu'
  session_ttl = 30
  timeout = '10s'