This document is for Kombu's development version, which can be significantly different from previous releases. Get the stable docs here: 4.1.
MongoDB Transport - kombu.transport.mongodb
¶
MongoDB transport.
copyright: |
|
---|---|
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
= 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'¶
-
implements
= {'asynchronous': False, 'exchange_type': frozenset([u'topic', u'fanout', u'direct']), 'heartbeats': False}¶
-
polling_interval
= 1¶
-
class
Channel¶
-
class
kombu.transport.mongodb.
Channel
(*vargs, **kwargs)[source]¶ MongoDB Channel.
-
broadcast_collection
= u'messages.broadcast'¶
-
calc_queue_size
= True¶
-
capped_queue_size
= 100000¶
-
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')¶
-
messages_collection
= u'messages'¶
-
queues_collection
= u'messages.queues'¶
-
routing_collection
= u'messages.routing'¶
-
ssl
= False¶
-
supports_fanout
= True¶
-
ttl
= False¶
-