--- a/src/pyams_zmq/handler.py Fri Jan 11 13:52:29 2019 +0100
+++ b/src/pyams_zmq/handler.py Thu Nov 28 19:19:25 2019 +0100
@@ -10,21 +10,26 @@
# FOR A PARTICULAR PURPOSE.
#
+"""PyAMS_zmq.handler module
+
+This module provides a default implementation of a 0MQ messages handler.
+
+These handlers are simple classes which delegate the real message handling
+to their "handler" attribute, which is a simple class which may have a method matching the
+message type.
+"""
+
+from zmq.utils import jsonapi
+from zope.interface import implementer
+
+from pyams_zmq.interfaces import IZMQMessageHandler
+
+
__docformat__ = 'restructuredtext'
-# import standard library
-from zmq.utils import jsonapi
-
-# import interfaces
-from pyams_zmq.interfaces import IZMQMessageHandler
-
-# import packages
-from zope.interface import implementer
-
-
@implementer(IZMQMessageHandler)
-class ZMQMessageHandler(object):
+class ZMQMessageHandler:
"""Base class for message handlers for a :class:`pyams_zmq.process.Process`.
Inheriting classes only need to implement a handler function for each
@@ -34,6 +39,7 @@
handler = None
def __init__(self, process, stream, stop, handler=None, json_load=-1):
+ # pylint: disable=too-many-arguments
# ZMQ parent process
self.process = process
self._json_load = json_load
@@ -41,14 +47,15 @@
self.rep_stream = stream
self._stop = stop
# Response handler
- self.rep_handler = handler or self.handler()
+ self.rep_handler = handler or self.handler() # pylint: disable=not-callable
self.rep_handler.process = process
def __call__(self, msg):
- """
- Gets called when a messages is received by the stream this handlers is
- registered at. *msg* is a list as returned by
- :meth:`zmq.core.socket.Socket.recv_multipart`.
+ """Gets called when a message is received by the stream this handler is
+ registered with.
+
+ :param msg: message content; it's a list as returned by
+ :meth:`zmq.core.socket.Socket.recv_multipart`.
"""
# Try to JSON-decode the index "self._json_load" of the message
i = self._json_load