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

MongoDB Transport - kombu.transport.mongodb

MongoDB transport.

copyright:

3. 2010 - 2013 by Flavio Percoco Premoli.

license:

BSD, see LICENSE for more details.

Transport

class kombu.transport.mongodb.Transport(client, **kwargs)

MongoDB Transport.

class Channel(*vargs, **kwargs)

MongoDB Channel.

broadcast

broadcast_collection = u'messages.broadcast'

calc_queue_size = True

capped_queue_size = 100000

client

connect_timeout = None

default_database = u'kombu_default'

default_hostname = u'127.0.0.1'

default_port = 27017

from_transport_options = (u'body_encoding', u'deadletter_queue', u'connect_timeout', u'ssl', u'ttl', u'capped_queue_size', u'default_hostname', u'default_port', u'default_database', u'messages_collection', u'routing_collection', u'broadcast_collection', u'queues_collection', u'calc_queue_size')

get_now()

Return current time in UTC.

get_table(exchange)

messages

messages_collection = u'messages'

queue_delete(queue, **kwargs)

queues

queues_collection = u'messages.queues'

routing

routing_collection = u'messages.routing'

ssl = False

supports_fanout = True

ttl = False

can_parse_url = True

channel_errors = (<class 'amqp.exceptions.ChannelError'>, <class 'pymongo.errors.ConnectionFailure'>, <class 'pymongo.errors.OperationFailure'>)

connection_errors = (<class 'amqp.exceptions.ConnectionError'>, <class 'pymongo.errors.ConnectionFailure'>)

default_port = 27017

driver_name = u'pymongo'

driver_type = u'mongodb'

driver_version()

implements = {'heartbeats': False, 'asynchronous': False, 'exchange_type': frozenset([u'topic', u'fanout', u'direct'])}

polling_interval = 1

Channel

class kombu.transport.mongodb.Channel(*vargs, **kwargs)

MongoDB Channel.

broadcast

broadcast_collection = u'messages.broadcast'

calc_queue_size = True

capped_queue_size = 100000

client

connect_timeout = None

default_database = u'kombu_default'

default_hostname = u'127.0.0.1'

default_port = 27017

from_transport_options = (u'body_encoding', u'deadletter_queue', u'connect_timeout', u'ssl', u'ttl', u'capped_queue_size', u'default_hostname', u'default_port', u'default_database', u'messages_collection', u'routing_collection', u'broadcast_collection', u'queues_collection', u'calc_queue_size')

get_now()

Return current time in UTC.

get_table(exchange)

messages

messages_collection = u'messages'

queue_delete(queue, **kwargs)

queues

queues_collection = u'messages.queues'

routing

routing_collection = u'messages.routing'

ssl = False

supports_fanout = True

ttl = False