diff --git a/LCS/Messaging/python/messaging/RPC.py b/LCS/Messaging/python/messaging/RPC.py index c34685271fab6871fd5f4262c57bad8c1f33da39..b56ed46ea578b5132cef6d5ab1ce5ba90add6455 100644 --- a/LCS/Messaging/python/messaging/RPC.py +++ b/LCS/Messaging/python/messaging/RPC.py @@ -302,7 +302,7 @@ class RPCWrapper(object): def close(self): '''Close all opened rpc connections''' for rpc in list(self._serviceRPCs.values()): - logger.debug('closing rpc connection %s at %s', rpc.Request.address, rpc.broker) + logger.debug('closing rpc connection %s at %s', rpc.request_sender.address, rpc.broker) rpc.close() def __enter__(self): @@ -330,7 +330,7 @@ class RPCWrapper(object): # not in cache # 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) - logger.debug('opening rpc connection %s at %s', rpc.Request.address, rpc.broker) + logger.debug('opening rpc connection %s at %s', rpc.request_sender.address, rpc.broker) rpc.open() self._serviceRPCs[service_method] = rpc