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]
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()[source]
Transport.polling_interval = 1

Channel

class kombu.transport.mongodb.Channel(*vargs, **kwargs)[source]
client
create_broadcast_cursor(exchange, routing_key, pattern, queue)[source]
get_broadcast()[source]
get_broadcast_cursor(queue)[source]
get_messages()[source]
get_routing()[source]
get_table(exchange)[source]

Get table of bindings for exchange.

queue_delete(queue, **kwargs)[source]
supports_fanout = True