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

Task #10057: log opening/closing rpc connections with address and broker string

parent a2d921aa
Branches
Tags
No related merge requests found
...@@ -96,7 +96,7 @@ class RPC(): ...@@ -96,7 +96,7 @@ class RPC():
self.Verbose = kwargs.pop("Verbose", False) self.Verbose = kwargs.pop("Verbose", False)
self.BusName = kwargs.pop("busname", None) self.BusName = kwargs.pop("busname", None)
self.ServiceName = service self.ServiceName = service
self.broker = broker self.broker = broker if broker else 'localhost'
if self.BusName is None: if self.BusName is None:
self.Request = ToBus(self.ServiceName, broker=self.broker) self.Request = ToBus(self.ServiceName, broker=self.broker)
else: else:
...@@ -306,6 +306,7 @@ class RPCWrapper(object): ...@@ -306,6 +306,7 @@ class RPCWrapper(object):
def close(self): def close(self):
'''Close all opened rpc connections''' '''Close all opened rpc connections'''
for rpc in self._serviceRPCs.values(): for rpc in self._serviceRPCs.values():
logger.info('closing rpc connection %s at %s', rpc.Request.address, rpc.broker)
rpc.close() rpc.close()
def __enter__(self): def __enter__(self):
...@@ -333,6 +334,7 @@ class RPCWrapper(object): ...@@ -333,6 +334,7 @@ class RPCWrapper(object):
# not in cache # not in cache
# so, create RPC for this service method, open it, and cache it # so, create RPC for this service method, open it, and cache it
rpc = RPC(service_method, busname=self.busname, broker=self.broker, ForwardExceptions=True, **rpckwargs) rpc = RPC(service_method, busname=self.busname, broker=self.broker, ForwardExceptions=True, **rpckwargs)
logger.info('opening rpc connection %s at %s', rpc.Request.address, rpc.broker)
rpc.open() rpc.open()
self._serviceRPCs[service_method] = rpc self._serviceRPCs[service_method] = rpc
......
0% Loading or .
You are about to add 0 people to the discussion. Proceed with caution.
Please register or to comment