本文整理了Java中javax.cache.Cache.registerCacheEntryListener()
方法的一些代码示例,展示了Cache.registerCacheEntryListener()
的具体用法。这些代码示例主要来源于Github
/Stackoverflow
/Maven
等平台,是从一些精选项目中提取出来的代码,具有较强的参考意义,能在一定程度帮忙到你。Cache.registerCacheEntryListener()
方法的具体详情如下:
包路径:javax.cache.Cache
类名称:Cache
方法名:registerCacheEntryListener
[英]Registers a CacheEntryListener. The supplied CacheEntryListenerConfiguration is used to instantiate a listener and apply it to those events specified in the configuration.
[中]注册CacheEntryListener。提供的CacheEntryListenerConfiguration用于实例化侦听器并将其应用于配置中指定的事件。
代码示例来源:origin: AxonFramework/AxonFramework
@Override
protected Registration doRegisterListener(CacheEntryListenerConfiguration listenerAdapter) {
jCache.registerCacheEntryListener(listenerAdapter);
return () -> {
jCache.deregisterCacheEntryListener(listenerAdapter);
return true;
};
}
代码示例来源:origin: cache2k/cache2k
/**
* Delegates to wrapped cache.
*/
@Override
public void registerCacheEntryListener(CacheEntryListenerConfiguration<K, T> cacheEntryListenerConfiguration) {
cache.registerCacheEntryListener(cacheEntryListenerConfiguration);
}
代码示例来源:origin: com.hazelcast.simulator/tests-common
@TimeStep(prob = 0.25)
public void register(ThreadState state) {
try {
cache.registerCacheEntryListener(listenerConfiguration);
state.operationCounter.register++;
} catch (IllegalArgumentException e) {
state.operationCounter.registerIllegalArgException++;
}
}
代码示例来源:origin: org.axonframework/axon-core
@Override
protected Registration doRegisterListener(CacheEntryListenerConfiguration listenerAdapter) {
jCache.registerCacheEntryListener(listenerAdapter);
return () -> {
jCache.deregisterCacheEntryListener(listenerAdapter);
return true;
};
}
代码示例来源:origin: org.axonframework/axon-messaging
@Override
protected Registration doRegisterListener(CacheEntryListenerConfiguration listenerAdapter) {
jCache.registerCacheEntryListener(listenerAdapter);
return () -> {
jCache.deregisterCacheEntryListener(listenerAdapter);
return true;
};
}
代码示例来源:origin: org.wso2.carbon.governance/org.wso2.carbon.governance.api
/**
* Method used to retrieve cache object for RXT Configs.
*
* @param name the name of the cache
* @return the cache object for the given cache manger and cache name
*/
public static Cache<String, Boolean> getRXTConfigCache(String name) {
CacheManager manager = getCacheManager();
Cache<String, Boolean> cache = (manager != null) ? manager.<String, Boolean>getCache(name) :
Caching.getCacheManager().<String, Boolean>getCache(name);
if (rxtCacheInitiated) {
cache.registerCacheEntryListener(entryCreatedListener);
cache.registerCacheEntryListener(entryUpdatedListener);
cache.registerCacheEntryListener(entryRemovedListener);
rxtCacheInitiated = true;
}
return cache;
}
代码示例来源:origin: hazelcast/hazelcast-code-samples
private void registerListener(Cache<String, Integer> cache) {
// create the EntryListener
MyCacheEntryListener<String, Integer> clientListener = new MyCacheEntryListener<String, Integer>();
// using our listener, let's create a configuration
CacheEntryListenerConfiguration<String, Integer> conf = new MutableCacheEntryListenerConfiguration<String, Integer>(
FactoryBuilder.factoryOf(clientListener), null, true, false);
// register it to the cache at run-time
cache.registerCacheEntryListener(conf);
}
代码示例来源:origin: org.apache.camel/camel-jcache
@Override
protected void doStart() throws Exception {
if (entryListenerConfiguration != null) {
getCache().deregisterCacheEntryListener(entryListenerConfiguration);
}
entryListenerConfiguration = createEntryListenerConfiguration();
getCache().registerCacheEntryListener(entryListenerConfiguration);
super.doStart();
}
代码示例来源:origin: org.apache.commons/commons-jcs-jcache
final Cache<String, String> cache = cacheManager.getCache("default");
final Set<String> event = new HashSet<String>();
cache.registerCacheEntryListener(new CacheEntryListenerConfiguration<String, String>()
cache.registerCacheEntryListener(new CacheEntryListenerConfiguration<String, String>()
cache.registerCacheEntryListener(new CacheEntryListenerConfiguration<String, String>()
代码示例来源:origin: javax.cache/cache-tests
@Test
public void testDynamicRegistration() {
assertEquals(1, getConfigurationCacheEntryListenerConfigurationSize(cache));
MyCacheEntryListener secondListener = new MyCacheEntryListener<Long, String>(oldValueRequired);
MutableCacheEntryListenerConfiguration<Long,
String> listenerConfiguration = new
MutableCacheEntryListenerConfiguration(FactoryBuilder.factoryOf(secondListener), null, oldValueRequired, true);
cache.registerCacheEntryListener(listenerConfiguration);
assertEquals(2,getConfigurationCacheEntryListenerConfigurationSize(cache));
CompleteConfiguration<Long, String> cacheConfig = (CompleteConfiguration)cache.getConfiguration(CompleteConfiguration.class);
for (CacheEntryListenerConfiguration<Long, String> config : cacheConfig.getCacheEntryListenerConfigurations()) {
config.hashCode();
config.isOldValueRequired();
config.isSynchronous();
}
//Can only register the same configuration once
try {
cache.registerCacheEntryListener(listenerConfiguration);
fail();
} catch (IllegalArgumentException e) {
//expected
}
}
代码示例来源:origin: javax.cache/cache-tests
new CacheEntryListenerClient<>(cacheEntryListenerServer.getInetAddress(), cacheEntryListenerServer.getPort());
listenerConfiguration = new MutableCacheEntryListenerConfiguration<Long, String>(FactoryBuilder.factoryOf(clientListener), null, oldValueRequired, true);
cache.registerCacheEntryListener(listenerConfiguration);
cacheEntryListenerServer.addCacheEventListener(brokenListener);
代码示例来源:origin: javax.cache/cache-tests
@Test
public void testDeregistration() {
assertEquals(1, getConfigurationCacheEntryListenerConfigurationSize(cache));
MyCacheEntryListener secondListener = new MyCacheEntryListener<Long, String>(oldValueRequired);
MutableCacheEntryListenerConfiguration<Long,
String> secondListenerConfiguration = new
MutableCacheEntryListenerConfiguration(FactoryBuilder.factoryOf(secondListener), null, oldValueRequired, true);
cache.registerCacheEntryListener(secondListenerConfiguration);
assertEquals(2, getConfigurationCacheEntryListenerConfigurationSize(cache));
cache.deregisterCacheEntryListener(secondListenerConfiguration);
assertEquals(1, getConfigurationCacheEntryListenerConfigurationSize(cache));
//no effect if called after it has been removed
cache.deregisterCacheEntryListener(secondListenerConfiguration);
assertEquals(1, getConfigurationCacheEntryListenerConfigurationSize(cache));
//Deregister the listener registered at configuration time
cache.deregisterCacheEntryListener(listenerConfiguration);
assertEquals(0, getConfigurationCacheEntryListenerConfigurationSize(cache));
}
代码示例来源:origin: javax.cache/cache-tests
FactoryBuilder.factoryOf(new MyCacheEntryEventFilter()),
oldValueRequired, true);
cache.registerCacheEntryListener(listenerConfiguration);
cacheEntryListenerServer.addCacheEventListener(filteredListener);
内容来源于网络,如有侵权,请联系作者删除!