def __init__(self, conn, config, q, logger, callback=None):
Thread.__init__(self)<EOL>self._conn = conn<EOL>self._log = logger<EOL>self._config = config<EOL>self._q = q<EOL>self._cb = callback<EOL>self._retry_count = <NUM_LIT:0><EOL>self.cooldown = Event()<EOL>self.exit = Event()<EOL>
Extend threads to support more control logic.