def __init__(self, data_q, log_level=None,<EOL>*args, **kwargs):
super(QueueProcessor, self).__init__(*args, **kwargs)<EOL>self.q = data_q<EOL>self._response_handlers = {'<STR_LIT>': self._handle_unsubscribed,<EOL>'<STR_LIT>': self._handle_subscribed,<EOL>'<STR_LIT>': self._handle_conf,<EOL>'<STR_LIT>': self._handle_auth,<EOL>'<STR_LIT>': self._handle_auth}<EOL>self._data_handlers = {'<STR_LIT>': self._handle_ticker,<EOL>'<STR_LIT>': self._handle_book,<EOL>'<STR_LIT>': self._handle_raw_book,<EOL>'<STR_LIT>': self._handle_candles,<EOL>'<STR_LIT>': self._handle_trades}<EOL>self._registry = {}<EOL>self.channel_directory = {}<EOL>self.channel_handlers = {}<EOL>self.last_update = {}<EOL>self.tickers = defaultdict(Queue)<EOL>self.books = defaultdict(Queue)<EOL>self.raw_books = defaultdict(Queue)<EOL>self.trades = defaultdict(Queue)<EOL>self.candles = defaultdict(Queue)<EOL>self.account = Queue()<EOL>self._stopped = Event()<EOL>self.log = logging.getLogger(self.__module__)<EOL>self.log.setLevel(level=logging.INFO if not log_level else log_level)<EOL>
Initialze a QueueProcessor instance.

        :param data_q: Queue()
        :param log_level: logging level
        :param args: Thread *args
        :param kwargs: Thread **kwargs