Method __init__

storm-client/src/py/storm/DistributedRPC.py:98–102

(self, handler)

class Processor(Iface, TProcessor):
    def __init__(self, handler):
        self._handler = handler
        self._processMap = {}
        self._processMap["execute"] = Processor.process_execute
        self._on_message_begin = None

    def on_message_begin(self, func):
        self._on_message_begin = func