From 70d1e6c88cd560ff92c9a09ac7132a4bbae7d7a1 Mon Sep 17 00:00:00 2001
From: Jorrit Schaap <schaap@astron.nl>
Date: Tue, 2 Apr 2019 11:27:39 +0000
Subject: [PATCH] SW-516: fixed forgotten rename action from self.Request ->
self.request_sender
---
LCS/Messaging/python/messaging/RPC.py | 4 ++--
1 file changed, 2 insertions(+), 2 deletions(-)
diff --git a/LCS/Messaging/python/messaging/RPC.py b/LCS/Messaging/python/messaging/RPC.py
index c34685271fa..b56ed46ea57 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
--
GitLab