Skip to content
Snippets Groups Projects
Commit 8801accb authored by Jorrit Schaap's avatar Jorrit Schaap
Browse files

SW-699: added facory method to create MoMQueryRPC

parent b28d04f8
No related branches found
No related tags found
No related merge requests found
......@@ -21,7 +21,7 @@ import sys
import logging
import pprint
from optparse import OptionParser
from lofar.messaging import RPCClient, RPCClientContextManagerMixin, DEFAULT_BROKER, DEFAULT_BUSNAME
from lofar.messaging import RPCClient, RPCClientContextManagerMixin, DEFAULT_BROKER, DEFAULT_BUSNAME, DEFAULT_BUS_TIMEOUT
from lofar.mom.momqueryservice.config import DEFAULT_MOMQUERY_SERVICENAME
''' Simple RPC client for Service momqueryservice
......@@ -35,6 +35,10 @@ class MoMQueryRPC(RPCClientContextManagerMixin):
super().__init__()
self._rpc_client = rpc_client or RPCClient(service_name=DEFAULT_MOMQUERY_SERVICENAME)
@staticmethod
def create(exchange: str = DEFAULT_BUSNAME, broker: str = DEFAULT_BROKER, timeout: int=DEFAULT_BUS_TIMEOUT):
return MoMQueryRPC(RPCClient(service_name=DEFAULT_MOMQUERY_SERVICENAME, exchange=exchange, broker=broker, timeout=timeout))
def add_trigger(self, user_name, host_name, project_name, meta_data):
logger.info("Requestion add_trigger for user_name: %s, host_name: %s, project_name: %s and "
"meta_data: %s", user_name, host_name, project_name, meta_data)
......
0% Loading or .
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment