diff --git a/SAS/MoM/MoMQueryService/MoMQueryServiceClient/momqueryrpc.py b/SAS/MoM/MoMQueryService/MoMQueryServiceClient/momqueryrpc.py index 1f95a4c5cc79633fa8d6fbc7ff874522b20726a6..29508cfb55b66d196e11280671fabdef851244b6 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, DEFAULT_BUS_TIMEOUT +from lofar.messaging import RPCClient, RPCClientContextManagerMixin, DEFAULT_BROKER, DEFAULT_BUSNAME, DEFAULT_RPC_TIMEOUT from lofar.mom.momqueryservice.config import DEFAULT_MOMQUERY_SERVICENAME ''' Simple RPC client for Service momqueryservice @@ -38,7 +38,7 @@ class MoMQueryRPC(RPCClientContextManagerMixin): 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): + def create(exchange: str = DEFAULT_BUSNAME, broker: str = DEFAULT_BROKER, timeout: int=DEFAULT_RPC_TIMEOUT): """Create a MoMQueryRPC connecting to the given exchange/broker on the default DEFAULT_MOMQUERY_SERVICENAME service""" return MoMQueryRPC(RPCClient(service_name=DEFAULT_MOMQUERY_SERVICENAME, exchange=exchange, broker=broker, timeout=timeout))