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

SW-699: DEFAULT_RPC_TIMEOUT

parent 1e0b2908
No related branches found
No related tags found
No related merge requests found
...@@ -21,7 +21,7 @@ import sys ...@@ -21,7 +21,7 @@ import sys
import logging import logging
import pprint import pprint
from optparse import OptionParser 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 from lofar.mom.momqueryservice.config import DEFAULT_MOMQUERY_SERVICENAME
''' Simple RPC client for Service momqueryservice ''' Simple RPC client for Service momqueryservice
...@@ -38,7 +38,7 @@ class MoMQueryRPC(RPCClientContextManagerMixin): ...@@ -38,7 +38,7 @@ class MoMQueryRPC(RPCClientContextManagerMixin):
self._rpc_client = rpc_client or RPCClient(service_name=DEFAULT_MOMQUERY_SERVICENAME) self._rpc_client = rpc_client or RPCClient(service_name=DEFAULT_MOMQUERY_SERVICENAME)
@staticmethod @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""" """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)) return MoMQueryRPC(RPCClient(service_name=DEFAULT_MOMQUERY_SERVICENAME, exchange=exchange, broker=broker, timeout=timeout))
......
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