Merge pull request #200 from hufeng/v3.0.0
remove _agentAddrSet
diff --git a/packages/dubbo/src/registry/zookeeper.ts b/packages/dubbo/src/registry/zookeeper.ts
index 1a03927..d5f98e1 100644
--- a/packages/dubbo/src/registry/zookeeper.ts
+++ b/packages/dubbo/src/registry/zookeeper.ts
@@ -31,7 +31,7 @@
IDubboRegistryProps,
IZkClientProps,
} from '../types';
-import {eqSet, isDevEnv, msg, traceErr} from '../util';
+import {isDevEnv, msg, traceErr} from '../util';
import Registry from './registry';
const log = debug('dubbo:zookeeper');
@@ -44,15 +44,12 @@
log(`new:|> %O`, props);
//默认dubbo
this._props.zkRoot = this._props.zkRoot || 'dubbo';
- //初始化agentAddrSet
- this._agentAddrSet = new Set();
//初始化zookeeper的client
this._connect(this._init);
}
private _checkTimer: NodeJS.Timer;
private _client: zookeeper.Client;
- private _agentAddrSet: Set<string>;
//========================private method==========================
private _init = async (err: Error) => {
@@ -104,7 +101,6 @@
log('dubboServiceUrl:|> %O', this._dubboServiceUrlMap);
}
- this._agentAddrSet = this._allAgentAddrSet;
this._subscriber.onData(this._allAgentAddrSet);
};
@@ -281,12 +277,7 @@
);
}
- if (!eqSet(this._agentAddrSet, this._allAgentAddrSet)) {
- this._agentAddrSet = this._allAgentAddrSet;
- this._subscriber.onData(this._allAgentAddrSet);
- } else {
- log('no agent change');
- }
+ this._subscriber.onData(this._allAgentAddrSet);
};
}