From 8801accb68ed4520ff04887d3e75c53a8c649b4f Mon Sep 17 00:00:00 2001
From: Jorrit Schaap <schaap@astron.nl>
Date: Fri, 7 Jun 2019 14:33:05 +0000
Subject: [PATCH] SW-699: added facory method to create MoMQueryRPC
---
.../MoMQueryService/MoMQueryServiceClient/momqueryrpc.py | 6 +++++-
1 file changed, 5 insertions(+), 1 deletion(-)
diff --git a/SAS/MoM/MoMQueryService/MoMQueryServiceClient/momqueryrpc.py b/SAS/MoM/MoMQueryService/MoMQueryServiceClient/momqueryrpc.py
index 67f96a4263a..dd5ea1ab184 100644
--- a/SAS/MoM/MoMQueryService/MoMQueryServiceClient/momqueryrpc.py
+++ b/SAS/MoM/MoMQueryService/MoMQueryServiceClient/momqueryrpc.py
@@ -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)
--
GitLab