networkapi.queue_tools.rabbitmq package¶
Submodules¶
networkapi.queue_tools.rabbitmq.queue_manager module¶
-
class
networkapi.queue_tools.rabbitmq.queue_manager.
QueueManager
(broker_vhost='/', queue_name=None, exchange_name=None, queue_type='direct', routing_key=None)[source]¶ Bases:
object
Object to manager objects sent to queue.
-
append
(dict_obj)[source]¶ Appended in list object a dictionary that represents the body of the message that will be sent to queue.
Parameters: dict_obj – Dict object
-
log
= <celery.utils.log.ProcessAwareLogger object>¶
-
Module contents¶
-
class
networkapi.queue_tools.rabbitmq.
QueueManager
(broker_vhost='/', queue_name=None, exchange_name=None, queue_type='direct', routing_key=None)[source]¶ Bases:
object
Object to manager objects sent to queue.
-
append
(dict_obj)[source]¶ Appended in list object a dictionary that represents the body of the message that will be sent to queue.
Parameters: dict_obj – Dict object
-
log
= <celery.utils.log.ProcessAwareLogger object>¶
-