javax.cache.Cache.registerCacheEntryListener()方法的使用及代码示例

x33g5p2x  于2022-01-18 转载在 其他  
字(6.7k)|赞(0)|评价(0)|浏览(135)

本文整理了Java中javax.cache.Cache.registerCacheEntryListener()方法的一些代码示例,展示了Cache.registerCacheEntryListener()的具体用法。这些代码示例主要来源于Github/Stackoverflow/Maven等平台,是从一些精选项目中提取出来的代码,具有较强的参考意义,能在一定程度帮忙到你。Cache.registerCacheEntryListener()方法的具体详情如下:
包路径:javax.cache.Cache
类名称:Cache
方法名:registerCacheEntryListener

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);

相关文章