var onError = function (e) {
        logger.error('Error %s reading from %s', e.code, self._config);
        if (callback) {
            callback(e);
        }