kombu.transport.couchdb

CouchDB transport.

copyright:

3. 2010 - 2013 by David Clymer.

license:

BSD, see LICENSE for more details.

Transport

class kombu.transport.couchdb.Transport(*args, **kwargs)

class Channel(connection, **kwargs)

client

view_created = False

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

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

Transport.default_port = 5984

Transport.driver_name = 'couchdb'

Transport.driver_type = 'couchdb'

Transport.driver_version()

Transport.polling_interval = 1

Channel

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

client

view_created = False

Functions

kombu.transport.couchdb.create_message_view(db)