def _listen(self, conn):
        try:
            conn.listen()
        except NSQException as error:
            self.logger.warning('[%s] connection lost (%r)' % (conn, error))

        self.handle_connection_failure(conn)
dataset/ETHPy150Open wtolson/gnsq/gnsq/reader.py/Reader._listen/original