kombu.transport.mongodb¶
MongoDB transport.
copyright: |
|
---|---|
license: | BSD, see LICENSE for more details. |
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¶
-
class
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¶
-