Class AMSRMQMessagePrinter¶

Defined in File orchestrator.py

Inheritance Relationships¶

Base Type¶

public RMQDomainDataLoaderTask

Class Documentation¶

orchestrator.AMSRMQMessagePrinter : public RMQDomainDataLoaderTask

A AMSJobReceiver receives job specifications for existing domains running on the
system and get status updates regarding how many new data elements are being inserted in our database.

Attributes:
    o_queue: The output queue to write the transformed messages
    credentials: A JSON file with the credentials to log on the RabbitMQ server.
    certificates: TLS certificates
    rmq_queue: The RabbitMQ queue to listen to.
    prefetch_count: Number of messages prefected by RMQ (impact performance)

Public Functions

__init__(self, str host, int port, str vhost, str user, str password, str cert, str rmq_queue, Optional[int] prefetch_count=1, signals=[signal.SIGTERM, signal.SIGINT, signal.SIGUSR1])¶

callback_message(self, ch, basic_deliver, properties, body)¶

Callback to be called each time the RMQ client consumes a message.

__call__(self)¶

Busy loop of consuming messages from RMQ queue

Public Members

num_messages¶