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

MongoDB Transport - kombu.transport.mongodb

MongoDB transport.

copyright:
  1. 2010 - 2013 by Flavio Percoco Premoli.
license:

BSD, see LICENSE for more details.

Transport

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

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'
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()[source]
implements = {'asynchronous': False, 'exchange_type': frozenset({'topic', 'direct', 'fanout'}), 'heartbeats': False}
polling_interval = 1

Channel

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

MongoDB Channel.

broadcast[source]
broadcast_collection = 'messages.broadcast'
calc_queue_size = True
capped_queue_size = 100000
client[source]
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()[source]

Return current time in UTC.

get_table(exchange)[source]

Get table of bindings for exchange.

messages[source]
messages_collection = 'messages'
queue_delete(queue, **kwargs)[source]

Delete queue.

queues[source]
queues_collection = 'messages.queues'
routing[source]
routing_collection = 'messages.routing'
ssl = False
supports_fanout = True
ttl = False