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

Zookeeper Transport - kombu.transport.zookeeper

Zookeeper transport.

copyright:

3. 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

• https://zookeeper.apache.org/doc/trunk/recipes.html#sc_recipes_Queues
• https://kazoo.readthedocs.io/en/latest/api/recipe/queue.html

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)

Zookeeper Transport.

class Channel(connection, **kwargs)

Zookeeper Channel.

client

Transport.channel_errors = (<class 'amqp.exceptions.ChannelError'>,)

Transport.connection_errors = (<class 'amqp.exceptions.ConnectionError'>,)

Transport.default_port = 2181

Transport.driver_name = u'kazoo'

Transport.driver_type = u'zookeeper'

Transport.driver_version()

Transport.polling_interval = 1

Channel

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

Zookeeper Channel.

client