def queue_message(self, conn, message):
        self.logger.debug('[%s] queueing message: %s' % (conn, message.id))
        self.queue.put((conn, message))
dataset/ETHPy150Open wtolson/gnsq/gnsq/reader.py/Reader.queue_message/original