def start(self):
logger.info("<STR_LIT>")<EOL>while True:<EOL><INDENT>socks = dict(self.poller.poll(<NUM_LIT:1>))<EOL>if socks.get(self.task_incoming) == zmq.POLLIN:<EOL><INDENT>message = self.task_incoming.recv_multipart()<EOL>logger.debug("<STR_LIT>")<EOL>self.worker_messages.send_multipart(message)<EOL>logger.debug("<STR_LIT>")<EOL><DEDENT>if socks.get(self.worker_messages) == zmq.POLLIN:<EOL><INDENT>message = self.worker_messages.recv_multipart()<EOL>logger.debug("<STR_LIT>")<EOL>self.result_outgoing.send_multipart(message[<NUM_LIT:1>:])<EOL>logger.debug("<STR_LIT>")<EOL><DEDENT><DEDENT>
TODO: docstring