def _on_connection_identify_response(self, conn, data, **kwargs):
        if not hasattr(self, '_disabled_notice'):
            self._disabled_notice = True

            def semver(v):
                def cast(x):
                    try:
                        return int(x)
                    except:
                        return x
                return map(cast, v.replace('-','.').split('.'))

            if self.disabled.__code__ != Reader.disabled.__code__ and semver(data['version']) >= semver('0.3'):
                logging.warning('disabled() deprecated and incompatible with nsqd >= 0.3. ' + 
                    'It will be removed in a future release. Use set_max_in_flight(0) instead')
                warnings.warn('disabled() is deprecated and will be removed in a future release, ' +
                    'use set_max_in_flight(0) instead', DeprecationWarning)
        return super(Reader, self)._on_connection_identify_response(conn, data, **kwargs)
dataset/ETHPy150Open nsqio/pynsq/nsq/reader.py/Reader._on_connection_identify_response/original