Class AMSShutdown¶

Defined in File stage.py

Inheritance Relationships¶

Base Type¶

public AsyncFanOutConsumer

Class Documentation¶

stage.AMSShutdown : public AsyncFanOutConsumer

A RMQ consumer client that listens to control messages from the AMS Deployment tool. When it receives a 'terminate' message
it shutdown the rest of the connections/threads to the RMQ server and gracefully terminates.

Public Functions

__init__(self, List[RMQDomainDataLoaderTask] consumers, str host, int port, str vhost, str user, str password, str cert, int prefetch_count=1)¶

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

on_close_cb(self)¶

__call__(self, pids=None)¶

Protected Attributes

_consumers¶

_signal_pid¶