src/pyams_zmq/handler.py
changeset 25 9352acb9366b
parent 0 11f0f97d508f
--- 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