Class RMQDomainDataLoaderTask¶

Defined in File stage.py

Inheritance Relationships¶

Base Type¶

public stage.Task (Class Task)

Derived Type¶

public stage.RMQControlMessageTask (Class RMQControlMessageTask)

Class Documentation¶

stage.RMQDomainDataLoaderTask : public stage.Task

A RMQDomainDataLoaderTask consumes 'AMSMessages' from RabbitMQ bundles the data of
the files into batches and forwards them to the next task waiting on the
output queuee.

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)

Subclassed by stage.RMQControlMessageTask

Public Functions

__init__(self, o_queue, host, port, vhost, user, password, cert, rmq_queue, policy, prefetch_count=1, signals=[signal.SIGINT, signal.SIGUSR1])¶

callback_close(self)¶

Callback that will be called when RabbitMQ will close
the connection (or if a problem happened with the connection).

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).

signal_wrapper(self, name, pid)¶

stop(self)¶

__call__(self)¶

Busy loop of consuming messages from RMQ queue

Public Members

o_queue¶

cert¶

rmq_queue¶

prefetch_count¶

datasize_byte¶

total_time_ns¶

signals¶

orig_sig_handlers¶

policy¶

rmq_consumer¶