Fixed discovery event listener calls - Fixes
@@ -687,11 +687,15 @@ public class GridDiscoveryManager extends GridManagerAdapter<DiscoverySpi> {
}
nextTopVer = new AffinityTopologyVersion(topVer, minorTopVer);
+
+ if (incMinorTopVer)
+ ctx.cache().onDiscoveryEvent(type, customMsg, node, nextTopVer, ctx.state().clusterState());
}
- else
+ else {
nextTopVer = new AffinityTopologyVersion(topVer, minorTopVer);
ctx.cache().onDiscoveryEvent(type, customMsg, node, nextTopVer, ctx.state().clusterState());
+ }
if (type == EVT_DISCOVERY_CUSTOM_EVT) {
for (Class cls = customMsg.getClass(); cls != null; cls = cls.getSuperclass()) {
