This document describes the current stable version of Kombu (4.5). For development docs, go here.

Zookeeper Transport - kombu.transport.zookeeper

Zookeeper transport.

copyright:
  1. 2010 - 2013 by Mahendra M.
license:

BSD, see LICENSE for more details.

Synopsis

Connects to a zookeeper node as <server>:<port>/<vhost> The <vhost> becomes the base for all the other znodes. So we can use it like a vhost.

This uses the built-in kazoo recipe for queues

References

Limitations This queue does not offer reliable consumption. An entry is removed from the queue prior to being processed. So if an error occurs, the consumer has to re-queue the item or it will be lost.

Transport

class kombu.transport.zookeeper.Transport(*args, **kwargs)[source]

Zookeeper Transport.

class Channel(connection, **kwargs)

Zookeeper Channel.

client
channel_errors = (<class 'amqp.exceptions.ChannelError'>,)
connection_errors = (<class 'amqp.exceptions.ConnectionError'>,)
default_port = 2181
driver_name = 'kazoo'
driver_type = 'zookeeper'
driver_version()[source]
polling_interval = 1

Channel

class kombu.transport.zookeeper.Channel(connection, **kwargs)[source]

Zookeeper Channel.

client