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

Java CacheEntryModified类代码示例

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

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



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

示例1: updated

import org.infinispan.notifications.cachelistener.annotation.CacheEntryModified; //导入依赖的package包/类
@CacheEntryModified
public void updated(CacheEntryModifiedEvent<String, Property<?>> event) {
    if (event.isPre()) {
        return;
    }

    Property<?> oldValue = (Property<?>) ((EventImpl) event).getOldValue();
    Property<?> newValue = event.getValue();

    if (!newValue.equals(oldValue)) {
        List<Observer> observers = this.observersMap.get(event.getKey());
        if (observers != null) {
            observers.forEach(observer -> observer.updated(newValue));
        }
    }
}
 
开发者ID:hawkular,项目名称:hawkular-apm,代码行数:17,代码来源:InfinispanPropertyCache.java


示例2: onModifiedNotifyTrigger

import org.infinispan.notifications.cachelistener.annotation.CacheEntryModified; //导入依赖的package包/类
@CacheEntryModified
public void onModifiedNotifyTrigger(CacheEntryModifiedEvent cacheEvent) {
    if (cacheEvent.isPre()) {
        if (log.isDebugEnabled()) {
            log.debug("Discarding pre onModifiedNotifyTrigger(@CacheEntryModified) event");
        }
        return;
    }
    NotifyTrigger notifyTrigger = (NotifyTrigger)triggersCache.get(cacheEvent.getKey());
    if (log.isDebugEnabled()) {
        log.debugf("onModifiedNotifyTrigger(@CacheEntryModified) received on %s", currentNode);
        log.debugf("CacheEvent: %s", cacheEvent);
        log.debugf("NotifyTrigger: %s", notifyTrigger);
    }
    processNotifyTrigger(notifyTrigger);
}
 
开发者ID:hawkular,项目名称:hawkular-alerts,代码行数:17,代码来源:PartitionManagerImpl.java


示例3: modified

import org.infinispan.notifications.cachelistener.annotation.CacheEntryModified; //导入依赖的package包/类
@CacheEntryModified
public void modified(CacheEntryModifiedEvent<Long, XOffering> event) {
	if (event.isPre()) {
		if (event.getValue() != null)
			removeCourses(event.getValue());
	} else {
		if (event.getValue() != null)
			addCourses(event.getValue());
	}
}
 
开发者ID:Jenner4S,项目名称:unitimes,代码行数:11,代码来源:ReplicatedServerWithMaster.java


示例4: eventReceived

import org.infinispan.notifications.cachelistener.annotation.CacheEntryModified; //导入依赖的package包/类
@CacheEntryModified
public synchronized void eventReceived(CacheEntryModifiedEvent event) {
    Object key = event.getKey();
    Object value = event.getValue();
    if (LOGGER.isDebugEnabled()) LOGGER.debug("Received MODIFIED key on INFOS key=[{}] value=[{}]", key, value);
    if ( (RulesManager.RULES_ARTIFACT_ID.equals(key) && !rulesManager.getReleaseId().getArtifactId().equals(key))
            || (RulesManager.RULES_GROUP_ID.equals(key) && !rulesManager.getReleaseId().getGroupId().equals(key)) ) {
        throw new IllegalStateException("Cannot change rules artifact or group id to ["+key+"].");
    }
    if (RulesManager.RULES_VERSION.equals(key)) {
        updateVersion((String) value);
    }
}
 
开发者ID:redhat-italy,项目名称:hacep,代码行数:14,代码来源:UpdateVersionListener.java


示例5: eventReceived

import org.infinispan.notifications.cachelistener.annotation.CacheEntryModified; //导入依赖的package包/类
@CacheEntryModified
public synchronized void eventReceived(CacheEntryModifiedEvent event) {
    Object key = event.getKey();
    Object value = event.getValue();
    if (LOGGER.isDebugEnabled()) LOGGER.debug("Received MODIFIED key on INFOS key=[{}] value=[{}]", key, value);
    if (RulesManager.RULES_ARTIFACT_ID.equals(key) || RulesManager.RULES_GROUP_ID.equals(key)) {
        throw new IllegalStateException("Cannot change rules artifact or group id.");
    }
    if ( RulesManager.RULES_VERSION.equals(key) && !value.equals("1.0.0") ) {
        throw new RuntimeException( "Upgrade rules version failed!!!" );
    } else if ( RulesManager.RULES_VERSION.equals(key) ){
        updateVersion((String) value);
    }
}
 
开发者ID:redhat-italy,项目名称:hacep,代码行数:15,代码来源:UpdateVersionListenerError.java


示例6: processEvent

import org.infinispan.notifications.cachelistener.annotation.CacheEntryModified; //导入依赖的package包/类
@CacheEntryCreated
@CacheEntryModified
@CacheEntryRemoved
@CacheEntryExpired
public void processEvent(CacheEntryEvent<Object, Object> event) {
    if (isAccepted(event.getType().toString())) {
        infinispanConsumer.processEvent(event.getType().toString(), IS_PRE, event.getCache().getName(), event.getKey());
    }
}
 
开发者ID:HydAu,项目名称:Camel,代码行数:10,代码来源:InfinispanSyncClusteredEventListener.java


示例7: processEvent

import org.infinispan.notifications.cachelistener.annotation.CacheEntryModified; //导入依赖的package包/类
@CacheEntryActivated
@CacheEntryCreated
@CacheEntryInvalidated
@CacheEntryLoaded
@CacheEntryModified
@CacheEntryPassivated
@CacheEntryRemoved
@CacheEntryVisited
@CacheEntryExpired
public void processEvent(CacheEntryEvent<Object, Object> event) {
    dispatch(event.getType().toString(), event.isPre(), event.getCache().getName(), event.getKey());
}
 
开发者ID:HydAu,项目名称:Camel,代码行数:13,代码来源:InfinispanSyncLocalEventListener.java


示例8: processEvent

import org.infinispan.notifications.cachelistener.annotation.CacheEntryModified; //导入依赖的package包/类
@CacheEntryCreated
@CacheEntryModified
@CacheEntryRemoved
@CacheEntryExpired
public void processEvent(CacheEntryEvent<Object, Object> event) {
    if (isAccepted(event.getType().toString())) {
        infinispanConsumer.processEvent(event.getType().toString(), event.isPre(), event.getCache().getName(), event.getKey());
    }
}
 
开发者ID:HydAu,项目名称:Camel,代码行数:10,代码来源:InfinispanEmbeddedCustomListener.java


示例9: handleCacheEntry

import org.infinispan.notifications.cachelistener.annotation.CacheEntryModified; //导入依赖的package包/类
@CacheEntryCreated
@CacheEntryModified
public void handleCacheEntry(CacheEntryEvent<String, V> cacheEvent) {
	if (cacheEvent instanceof CacheEntryCreatedEvent) {
		onAction(cacheEvent);
	} else if (cacheEvent instanceof CacheEntryModifiedEvent) {
		onAction(cacheEvent);
	}
}
 
开发者ID:openwide-java,项目名称:owsi-core-parent,代码行数:10,代码来源:CacheEntryEventListener.java


示例10: handleCacheEntry

import org.infinispan.notifications.cachelistener.annotation.CacheEntryModified; //导入依赖的package包/类
@CacheEntryCreated
@CacheEntryRemoved
@CacheEntryModified
public void handleCacheEntry(CacheEntryEvent<String, Message<V>> cacheEvent) {
	if (cacheEvent instanceof CacheEntryCreatedEvent) {
		onMessage(cacheEvent.getValue());
	} else if (cacheEvent instanceof CacheEntryModifiedEvent) {
		onMessage(cacheEvent.getValue());
	}
}
 
开发者ID:openwide-java,项目名称:owsi-core-parent,代码行数:11,代码来源:NodeMessageListener.java


示例11: onModifiedNotifyData

import org.infinispan.notifications.cachelistener.annotation.CacheEntryModified; //导入依赖的package包/类
@CacheEntryModified
public void onModifiedNotifyData(CacheEntryModifiedEvent cacheEvent) {
    if (cacheEvent.isPre()) {
        log.debug("Discarding pre onModifiedNotifyData(@CacheEntryModified) event");
        return;
    }
    NotifyData notifyData = (NotifyData)dataCache.get(cacheEvent.getKey());
    if (log.isDebugEnabled()) {
        log.debug("onModifiedNotifyData(@CacheEntryModified) received.");
        log.debugf("NotifyData: %s", notifyData);
    }
    processNotifyData(notifyData);
}
 
开发者ID:hawkular,项目名称:hawkular-alerts,代码行数:14,代码来源:PartitionManagerImpl.java


示例12: observeModify

import org.infinispan.notifications.cachelistener.annotation.CacheEntryModified; //导入依赖的package包/类
@CacheEntryModified
public void observeModify(CacheEntryModifiedEvent<Object, Object> event) {
    if (event.isPre()) {
        return;
    }

    if (this.toBeUpdated != null) {
        this.toBeUpdated.entryUpdated(event.getKey(), event.getValue(),
                this.containerName, this.cacheName, event.isOriginLocal());
    }
}
 
开发者ID:lbchen,项目名称:ODL,代码行数:12,代码来源:CacheListenerContainer.java


示例13: entryModified

import org.infinispan.notifications.cachelistener.annotation.CacheEntryModified; //导入依赖的package包/类
@CacheEntryModified
public void entryModified(CacheEntryModifiedEvent<String, String> event) {
    if (!event.isPre())
        System.out.println("Updated entry: " + event.getKey() + " " + event.getValue());
}
 
开发者ID:infinispan,项目名称:infinispan-simple-tutorials,代码行数:6,代码来源:InfinispanKubernetes.java


示例14: entryModified

import org.infinispan.notifications.cachelistener.annotation.CacheEntryModified; //导入依赖的package包/类
@CacheEntryModified
public void entryModified(CacheEntryModifiedEvent<String, String> event) {
   // We are only interested in the pre event
   if (event.isPre())
      System.out.printf("About to modify %s\n", event.getKey());
}
 
开发者ID:infinispan,项目名称:infinispan-simple-tutorials,代码行数:7,代码来源:InfinispanListen.java



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


鲜花

握手

雷人

路过

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

请发表评论

全部评论

专题导读
上一篇:
Java TLongFloatMap类代码示例发布时间:2022-05-22
下一篇:
Java OptionType类代码示例发布时间: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