kombu.transport.mongodb¶

MongoDB transport.

copyright:	2010 - 2013 by Flavio Percoco Premoli.
license:	BSD, see LICENSE for more details.

Transport
Channel

Transport ¶

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

class Channel(*vargs, **kwargs)¶

client¶

create_broadcast_cursor(exchange, routing_key, pattern, queue)¶

get_broadcast()¶

get_broadcast_cursor(queue)¶

get_messages()¶

get_routing()¶

get_table(exchange)¶: Get table of bindings for exchange.

queue_delete(queue, **kwargs)¶

supports_fanout = True¶

Transport.can_parse_url = True¶

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

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

Transport.default_port = 27017¶

Transport.driver_name = 'pymongo'¶

Transport.driver_type = 'mongodb'¶

Transport.driver_version()¶

Transport.polling_interval = 1¶

Channel ¶

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

client¶

create_broadcast_cursor(exchange, routing_key, pattern, queue)¶

get_broadcast()¶

get_broadcast_cursor(queue)¶

get_messages()¶

get_routing()¶

get_table(exchange)¶: Get table of bindings for exchange.

queue_delete(queue, **kwargs)¶

supports_fanout = True¶