@Override
public void coordinatorChanged() {
- AbstractScheme scheme = schemes.get(activeScheme);
- if (scheme == null) return;
- scheme.handleClusterViewChanged();
notifyClusterViewChanged();
}
@Override
public void entryCreated(Node key, String cacheName, boolean originLocal) {
- AbstractScheme scheme = schemes.get(activeScheme);
- logger.debug("Created : {} cache : {} existingValue : {}", key, cacheName, scheme.getNodeConnections().get(key));
+ if (originLocal) return;
}
/*
connectionService.notifyNodeDisconnectFromMaster(node);
break;
case CLUSTER_VIEW_CHANGED:
+ AbstractScheme scheme = schemes.get(activeScheme);
+ if (scheme == null) return;
+ scheme.handleClusterViewChanged();
connectionService.notifyClusterViewChanged();
break;
default: