This document is for Kombu's development version, which can be significantly different from previous releases. Get the stable docs here: 4.5.

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 = 'messages.broadcast'

calc_queue_size = True

capped_queue_size = 100000

client

connect_timeout = None

default_database = 'kombu_default'

default_hostname = '127.0.0.1'

default_port = 27017

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

get_now()

Return current time in UTC.

get_table(exchange)

Get table of bindings for exchange.

messages

messages_collection = 'messages'

prepare_queue_arguments(arguments, **kwargs)

queue_delete(queue, **kwargs)

Delete queue.

queues

queues_collection = 'messages.queues'

routing

routing_collection = '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 = 'pymongo'

driver_type = 'mongodb'

driver_version()

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

polling_interval = 1

Channel

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

MongoDB Channel.

broadcast

broadcast_collection = 'messages.broadcast'

calc_queue_size = True

capped_queue_size = 100000

client

connect_timeout = None

default_database = 'kombu_default'

default_hostname = '127.0.0.1'

default_port = 27017

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

get_now()

Return current time in UTC.

get_table(exchange)

Get table of bindings for exchange.

messages

messages_collection = 'messages'

prepare_queue_arguments(arguments, **kwargs)

queue_delete(queue, **kwargs)

Delete queue.

queues

queues_collection = 'messages.queues'

routing

routing_collection = 'messages.routing'

ssl = False

supports_fanout = True

ttl = False