Class RMQControlMessageTask¶

Defined in File stage.py

Inheritance Relationships¶

Base Type¶

public stage.RMQDomainDataLoaderTask (Class RMQDomainDataLoaderTask)

Class Documentation¶

stage.RMQControlMessageTask : public stage.RMQDomainDataLoaderTask

A RMQControlMessageTask consumes JSON-messages from RabbitMQ and forwards them to
the o_queue of the pruning Task.

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, *args, **kwargs)¶

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

Callback that will be called each time a message will be consummed.
the connection (or if a problem happened with the connection).