def METHOD_NAME(self):
    """fire up worker threads, get messages and dispatch among them"""
    for i in range(self.wnum):
        t = Thread(target=self.worker)
        t.start()
    try:
        while True:
            self.q.put(recv(self.inf))
    except EOFError:
        logging.info("terminating on reaching EOF.")