kombu.transport.zookeeper

kombu.transport.zookeeper

Zookeeper transport.

copyright:
  1. 2010 - 2012 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
  • A queue is a znode under the <vhost> path
  • Creates a new sequential node under the queue and writes the message to it
  • If priority is used, we will use it in the node name, so that higher priority messages are picked up first
  • Keep consuming messages from the top of the queue, till we are able to delete a particular message. If deletion raises a NoNode exception, we try again with the next message

References

Limitations

  • A queue cannot handle more than 2^32 messages. This is an internal limitation with zookeeper. This has to be handled internally in this module.

Transport

class kombu.transport.zookeeper.Transport(*args, **kwargs)
class Channel(connection, **kwargs)
client
Transport.channel_errors = (<class 'kombu.exceptions.StdChannelError'>, <class 'socket.error'>)
Transport.connection_errors = (<class 'kombu.exceptions.StdConnectionError'>,)
Transport.default_port = 2181
Transport.driver_name = 'kazoo'
Transport.driver_type = 'zookeeper'
Transport.driver_version()
Transport.polling_interval = 1

Channel

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

Table Of Contents

Previous topic

kombu.transport.couchdb

Next topic

kombu.transport.filesystem

This Page