• 设为首页
  • 点击收藏
  • 手机版
    手机扫一扫访问
    迪恩网络手机版
  • 关注官方公众号
    微信扫一扫关注
    迪恩网络公众号

Java ViewChanged类代码示例

原作者: [db:作者] 来自: [db:来源] 收藏 邀请

本文整理汇总了Java中org.infinispan.notifications.cachemanagerlistener.annotation.ViewChanged的典型用法代码示例。如果您正苦于以下问题:Java ViewChanged类的具体用法?Java ViewChanged怎么用?Java ViewChanged使用的例子?那么恭喜您, 这里精选的类代码示例或许可以为您提供帮助。



ViewChanged类属于org.infinispan.notifications.cachemanagerlistener.annotation包,在下文中一共展示了ViewChanged类的10个代码示例,这些例子默认根据受欢迎程度排序。您可以为喜欢或者感觉有用的代码点赞,您的评价将有助于我们的系统推荐出更棒的Java代码示例。

示例1: viewChanged

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();
    }
}
 
开发者ID:redhat-developer-demos,项目名称:popular-movie-store,代码行数:10,代码来源:ClusterListener.java


示例2: onTopologyChange

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();
}
 
开发者ID:hawkular,项目名称:hawkular-alerts,代码行数:8,代码来源:PartitionManagerImpl.java


示例3: viewChanged

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);
    }
}
 
开发者ID:jboss-switchyard,项目名称:switchyard,代码行数:13,代码来源:InfinispanRegistry.java


示例4: viewChanged

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());
    }
}
 
开发者ID:hawkular,项目名称:hawkular-metrics,代码行数:10,代码来源:DistributedLock.java


示例5: viewChanged

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);
	}
}
 
开发者ID:gcvt,项目名称:siebog,代码行数:11,代码来源:ECViewListener.java


示例6: viewChanged

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();
   }
}
 
开发者ID:infinispan,项目名称:infinispan-embedded-tutorial,代码行数:11,代码来源:ClusterListener.java


示例7: handleViewChange

import org.infinispan.notifications.cachemanagerlistener.annotation.ViewChanged; //导入依赖的package包/类
@ViewChanged
public void handleViewChange(ViewChangedEvent e) {
  handleViewChangeInternal(e);
}
 
开发者ID:vert-x3,项目名称:vertx-infinispan,代码行数:5,代码来源:InfinispanClusterManager.java


示例8: onViewChange

import org.infinispan.notifications.cachemanagerlistener.annotation.ViewChanged; //导入依赖的package包/类
@ViewChanged
public void onViewChange(ViewChangedEvent viewChangedEvent) {
	if (viewChangedEvent.getCacheManager().isCoordinator()) {
		infinispanClusterService.onViewChangedEvent(viewChangedEvent);
	}
}
 
开发者ID:openwide-java,项目名称:owsi-core-parent,代码行数:7,代码来源:ViewChangedEventCoordinatorListener.java


示例9: onTopologyChange

import org.infinispan.notifications.cachemanagerlistener.annotation.ViewChanged; //导入依赖的package包/类
@ViewChanged
public void onTopologyChange(ViewChangedEvent cacheEvent) {
    processTopologyChange();
}
 
开发者ID:hawkular,项目名称:hawkular-metrics,代码行数:5,代码来源:GroupTriggerManager.java


示例10: viewChanged

import org.infinispan.notifications.cachemanagerlistener.annotation.ViewChanged; //导入依赖的package包/类
@ViewChanged
public void viewChanged(ViewChangedEvent e) {
    for (IListenRoleChange i : this.roleListeners) {
        i.newActiveAvailable();
    }
}
 
开发者ID:lbchen,项目名称:ODL,代码行数:7,代码来源:ClusterManager.java



注:本文中的org.infinispan.notifications.cachemanagerlistener.annotation.ViewChanged类示例整理自Github/MSDocs等源码及文档管理平台,相关代码片段筛选自各路编程大神贡献的开源项目,源码版权归原作者所有,传播和使用请参考对应项目的License;未经允许,请勿转载。


鲜花

握手

雷人

路过

鸡蛋
该文章已有0人参与评论

请发表评论

全部评论

专题导读
上一篇:
Java UIUtils类代码示例发布时间:2022-05-22
下一篇:
Java LoggingExceptionMapper类代码示例发布时间:2022-05-22
热门推荐
阅读排行榜

扫描微信二维码

查看手机版网站

随时了解更新最新资讯

139-2527-9053

在线客服(服务时间 9:00~18:00)

在线QQ客服
地址:深圳市南山区西丽大学城创智工业园
电邮:jeky_zhao#qq.com
移动电话:139-2527-9053

Powered by 互联科技 X3.4© 2001-2213 极客世界.|Sitemap