Change in vdsm[master]: jsonrpc: rename setMessageHandler method
piotr.kliczewski at gmail.com
piotr.kliczewski at gmail.com
Mon May 18 14:43:49 UTC 2015
Piotr Kliczewski has uploaded a new change for review.
Change subject: jsonrpc: rename setMessageHandler method
......................................................................
jsonrpc: rename setMessageHandler method
Change-Id: Iefa9e04dd9f8e52e3f4edcc0a1dadc4845d9f74f
Signed-off-by: pkliczewski <piotr.kliczewski at gmail.com>
---
M lib/yajsonrpc/__init__.py
M lib/yajsonrpc/stompReactor.py
M vdsm/rpc/BindingJsonRpc.py
3 files changed, 4 insertions(+), 4 deletions(-)
git pull ssh://gerrit.ovirt.org:29418/vdsm refs/changes/65/41065/1
diff --git a/lib/yajsonrpc/__init__.py b/lib/yajsonrpc/__init__.py
index 174aa9d..0402158 100644
--- a/lib/yajsonrpc/__init__.py
+++ b/lib/yajsonrpc/__init__.py
@@ -277,7 +277,7 @@
class JsonRpcClient(object):
def __init__(self, transport):
self.log = logging.getLogger("jsonrpc.JsonRpcClient")
- transport.setMessageHandler(self._handleMessage)
+ transport.set_message_handler(self._handleMessage)
self._transport = transport
self._runningRequests = {}
self._lock = Lock()
diff --git a/lib/yajsonrpc/stompReactor.py b/lib/yajsonrpc/stompReactor.py
index e5fbf01..89f0e12 100644
--- a/lib/yajsonrpc/stompReactor.py
+++ b/lib/yajsonrpc/stompReactor.py
@@ -147,7 +147,7 @@
if self._messageHandler is not None:
self._messageHandler((self, data))
- def setMessageHandler(self, msgHandler):
+ def set_message_handler(self, msgHandler):
self._messageHandler = msgHandler
self.check_read()
@@ -194,7 +194,7 @@
if self._messageHandler is not None:
self._messageHandler((self, frame.body))
- def setMessageHandler(self, msgHandler):
+ def set_message_handler(self, msgHandler):
self._messageHandler = msgHandler
self.check_read()
diff --git a/vdsm/rpc/BindingJsonRpc.py b/vdsm/rpc/BindingJsonRpc.py
index a5b5b4a..eae0e7d 100644
--- a/vdsm/rpc/BindingJsonRpc.py
+++ b/vdsm/rpc/BindingJsonRpc.py
@@ -37,7 +37,7 @@
reactor.createListener(client_socket, self._onAccept)
def _onAccept(self, listener, client):
- client.setMessageHandler(self._server.queueRequest)
+ client.set_message_handler(self._server.queueRequest)
def createStompReactor(self):
reactor = StompReactor()
--
To view, visit https://gerrit.ovirt.org/41065
To unsubscribe, visit https://gerrit.ovirt.org/settings
Gerrit-MessageType: newchange
Gerrit-Change-Id: Iefa9e04dd9f8e52e3f4edcc0a1dadc4845d9f74f
Gerrit-PatchSet: 1
Gerrit-Project: vdsm
Gerrit-Branch: master
Gerrit-Owner: Piotr Kliczewski <piotr.kliczewski at gmail.com>
More information about the vdsm-patches
mailing list