Class AMSFakeRMQUpdate¶

Defined in File orchestrator.py

Class Documentation¶

class AMSFakeRMQUpdate¶

@brief A debugging pipeline step that reads in a file of requests and publishes them into a listening queue.

Public Functions

__init__(self, str json_file, str host, int port, str vhost, str user, str password, str cert, str publish_queue, signals=[signal.SIGTERM, signal.SIGINT, signal.SIGUSR1])¶

__call__(self)¶

Public Members

producer¶

publish_queue¶

json_file¶