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)

Bases: object

Object to manager objects sent to queue.

append(dict_obj)

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 at 0x7fdee35b9a10>

send()

Module contents

class networkapi.queue_tools.rabbitmq.QueueManager(broker_vhost='/', queue_name=None, exchange_name=None, queue_type='direct', routing_key=None)

Bases: object

Object to manager objects sent to queue.

append(dict_obj)

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 at 0x7fdee35b9a10>

send()