import org.infinispan.notifications.cachemanagerlistener.annotation.ViewChanged; //导入依赖的package包/类
@ViewChanged
public void viewChanged(ViewChangedEvent event) {
    log.info("PMS:::View changed: {} ", event.getNewMembers());
    if (event.getCacheManager().getMembers().size() == expectedNodes) {
        clusterFormedLatch.countDown();
    } else if (event.getNewMembers().size() < event.getOldMembers().size()) {
        shutdownLatch.countDown();
    }
}
 

import org.infinispan.notifications.cachemanagerlistener.annotation.ViewChanged; //导入依赖的package包/类
@ViewChanged
public void onTopologyChange(ViewChangedEvent cacheEvent) {
    /*
        When a node is joining/leaving the cluster partition needs to be re-calculated and updated
     */
    processTopologyChange();
}
 

import org.infinispan.notifications.cachemanagerlistener.annotation.ViewChanged; //导入依赖的package包/类
/**
 * Triggered when a view is changed, signaling that a member has joined or dropped from the cluster.
 * @param event change details
 */
@ViewChanged
public void viewChanged(ViewChangedEvent event) {
    List<Address> dropped = new ArrayList<Address>(event.getOldMembers());
    dropped.removeAll(event.getNewMembers());
    for (Address addr : dropped) {
        dropAllServices(addr);
    }
}
 

import org.infinispan.notifications.cachemanagerlistener.annotation.ViewChanged; //导入依赖的package包/类
@ViewChanged
public void viewChanged(ViewChangedEvent event) {
    log.debugf("view changed: %s", event);
    List<Address> old = new ArrayList<>(event.getOldMembers());
    old.removeAll(event.getNewMembers());
    for (Address address : old) {
        locksCache.remove(key, address.toString());
    }
}
 

import org.infinispan.notifications.cachemanagerlistener.annotation.ViewChanged; //导入依赖的package包/类
@ViewChanged
public void viewChanged(ViewChangedEvent event) {
	final Cache<String, ExecutionControl> cache = GlobalCache.get().getExecutionControls();
	Set<String> allExecCtrls = new HashSet<>(cache.keySet());
	for (String name : allExecCtrls) {
		ExecutionControl ctrl = cache.get(name);
		if (ctrl != null)
			ctrl.onTimeout(-1);
	}
}
 

import org.infinispan.notifications.cachemanagerlistener.annotation.ViewChanged; //导入依赖的package包/类
@ViewChanged
public void viewChanged(ViewChangedEvent event) {
   System.out.printf("---- View changed: %s ----\n", event.getNewMembers());

   if (event.getCacheManager().getMembers().size() == expectedNodes) {
      clusterFormedLatch.countDown();
   } else if (event.getNewMembers().size() < event.getOldMembers().size()) {
      shutdownLatch.countDown();
   }
}
 

import org.infinispan.notifications.cachemanagerlistener.annotation.ViewChanged; //导入依赖的package包/类
@ViewChanged
public void handleViewChange(ViewChangedEvent e) {
  handleViewChangeInternal(e);
}
 

import org.infinispan.notifications.cachemanagerlistener.annotation.ViewChanged; //导入依赖的package包/类
@ViewChanged
public void onViewChange(ViewChangedEvent viewChangedEvent) {
	if (viewChangedEvent.getCacheManager().isCoordinator()) {
		infinispanClusterService.onViewChangedEvent(viewChangedEvent);
	}
}
 

import org.infinispan.notifications.cachemanagerlistener.annotation.ViewChanged; //导入依赖的package包/类
@ViewChanged
public void onTopologyChange(ViewChangedEvent cacheEvent) {
    processTopologyChange();
}
 

import org.infinispan.notifications.cachemanagerlistener.annotation.ViewChanged; //导入依赖的package包/类
@ViewChanged
public void viewChanged(ViewChangedEvent e) {
    for (IListenRoleChange i : this.roleListeners) {
        i.newActiveAvailable();
    }
}