org.infinispan.configuration.cache.ExpirationConfigurationBuilder.wakeUpInterval()方法的使用及代码示例

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

ExpirationConfigurationBuilder.wakeUpInterval介绍

暂无

代码示例

代码示例来源：origin: wildfly/wildfly

@Override
public ExpirationConfiguration get() {
return new ConfigurationBuilder().expiration()
.wakeUpInterval(this.interval)
.lifespan(this.lifespan)
.maxIdle(this.maxIdle)
.create();
}
}

代码示例来源：origin: org.wildfly/wildfly-clustering-infinispan-extension

@Override
public ExpirationConfiguration get() {
return new ConfigurationBuilder().expiration()
.wakeUpInterval(this.interval)
.lifespan(this.lifespan)
.maxIdle(this.maxIdle)
.create();
}
}

代码示例来源：origin: org.infinispan/infinispan-core

public void testWakeupInterval() {
ExpirationManagerImpl em = new ExpirationManagerImpl();
Configuration cfg = getCfg().expiration().wakeUpInterval(789L).build();
ScheduledExecutorService mockService = mock(ScheduledExecutorService.class);
em.initialize(mockService, "", cfg);
ScheduledFuture mockFuture = mock(ScheduledFuture.class);
when(mockService.scheduleWithFixedDelay(isA(ExpirationManagerImpl.ScheduledTask.class), eq(789l),
eq(789l), eq(TimeUnit.MILLISECONDS)))
.thenReturn(mockFuture);
em.start();
assertEquals(mockFuture, em.expirationTask);
verify(mockService).scheduleWithFixedDelay(any(Runnable.class), anyLong(), anyLong(), any(TimeUnit.class)); // expect that the executor was never used!!
}
}

代码示例来源：origin: org.infinispan/infinispan-core

@Override
protected void configure(ConfigurationBuilder config) {
config
// Prevent the reaper from running, reaperEnabled(false) doesn't work when a store is present
.expiration().wakeUpInterval(Long.MAX_VALUE)
.persistence().addStore(DummyInMemoryStoreConfigurationBuilder.class);
}
}

代码示例来源：origin: org.keycloak/keycloak-model-infinispan

private ConfigurationBuilder getActionTokenCacheConfig() {
ConfigurationBuilder cb = new ConfigurationBuilder();
cb.memory()
.evictionStrategy(EvictionStrategy.NONE)
.evictionType(EvictionType.COUNT)
.size(InfinispanConnectionProvider.ACTION_TOKEN_CACHE_DEFAULT_MAX);
cb.expiration()
.maxIdle(InfinispanConnectionProvider.ACTION_TOKEN_MAX_IDLE_SECONDS, TimeUnit.SECONDS)
.wakeUpInterval(InfinispanConnectionProvider.ACTION_TOKEN_WAKE_UP_INTERVAL_SECONDS, TimeUnit.SECONDS);
return cb;
}

代码示例来源：origin: org.infinispan/infinispan-core

@Override
protected void configure(ConfigurationBuilder config) {
config
// Prevent the reaper from running, reaperEnabled(false) doesn't work when a store is present
.expiration().wakeUpInterval(Long.MAX_VALUE)
.persistence().addSingleFileStore().location(TestingUtil.tmpDirectory(this.getClass()));
}

代码示例来源：origin: org.exoplatform.kernel/exo.kernel.component.ext.cache.impl.infinispan.v5

/**
* Clean the configuration template to prevent conflicts
*/
protected void resetConfiguration(ConfigurationBuilder confBuilder)
{
confBuilder.invocationBatching().enable().eviction().strategy(EvictionStrategy.NONE).maxEntries(-1).expiration()
.lifespan(-1L).maxIdle(-1L).wakeUpInterval(60000L);
}
}

代码示例来源：origin: org.infinispan/infinispan-jcache-remote

protected static org.infinispan.configuration.cache.ConfigurationBuilder getExpiryCacheConfig() {
ConfigurationBuilder builder = getDefaultClusteredCacheConfig(CacheMode.DIST_SYNC);
builder.expiration().lifespan(EXPIRATION_TIMEOUT).wakeUpInterval(100, TimeUnit.MILLISECONDS);
return hotRodCacheConfiguration(builder);
}

代码示例来源：origin: org.infinispan/infinispan-jcache

@Override
protected void createCacheManagers() throws Throwable {
ConfigurationBuilder defaultClusteredCacheConfig2 = getDefaultClusteredCacheConfig(CacheMode.DIST_SYNC, false);
defaultClusteredCacheConfig2.expiration().lifespan(EXPIRATION_TIMEOUT).wakeUpInterval(100, TimeUnit.MILLISECONDS);
createClusteredCaches(2, "expiry", defaultClusteredCacheConfig2);
cacheManagers.forEach(cm -> replaceComponent(cm, TimeService.class, controlledTimeService, true));
waitForClusterToForm("expiry");
}
}

代码示例来源：origin: org.infinispan/infinispan-core

@Override
protected void configure(ConfigurationBuilder config) {
config
// Prevent the reaper from running, reaperEnabled(false) doesn't work when a store is present
.expiration().wakeUpInterval(Long.MAX_VALUE)
.clustering().cacheMode(CacheMode.DIST_SYNC)
.persistence().addSingleFileStore().location(TestingUtil.tmpDirectory(this.getClass()));
}

代码示例来源：origin: org.infinispan/infinispan-core

public void testNoExpirationThread() {
ExpirationManagerImpl em = new ExpirationManagerImpl();
Configuration cfg = getCfg().expiration().wakeUpInterval(0L).build();
ScheduledExecutorService mockService = mock(ScheduledExecutorService.class);
em.initialize(mockService, "", cfg);
em.start();
assertNull("Expiration task is not null! Should not have scheduled anything!", em.expirationTask);
}

代码示例来源：origin: org.infinispan/infinispan-core

@Override
protected EmbeddedCacheManager createCacheManager() throws Exception {
ConfigurationBuilder builder = TestCacheManagerFactory.getDefaultCacheConfiguration(false);
builder.persistence().addStore(SimpleLoaderConfigurationBuilder.class);
// Effectively disabling reaper
builder.expiration().wakeUpInterval(1, TimeUnit.DAYS);
EmbeddedCacheManager cm = TestCacheManagerFactory.createCacheManager(builder);
TestingUtil.replaceComponent(cm, TimeService.class, timeService, true);
cache = cm.getCache();
return cm;
}

代码示例来源：origin: org.infinispan/infinispan-core

@Override
protected EmbeddedCacheManager createCacheManager() throws Exception {
ConfigurationBuilder cfg = new ConfigurationBuilder();
cfg.memory().size(MAX_CACHE_ELEMENTS)
.expiration().wakeUpInterval(3000L)
.build();
EmbeddedCacheManager cm = TestCacheManagerFactory.createCacheManager(cfg);
cache = cm.getCache();
return cm;
}

代码示例来源：origin: org.infinispan/infinispan-core

private Cache configureAndBuildCache(int capacity) {
ConfigurationBuilder cOnfig= new ConfigurationBuilder();
config
.memory().size(capacity)
.expiration().wakeUpInterval(5000L).maxIdle(120000L);
String cacheName = "cache" + capacity;
cacheManager.defineConfiguration(cacheName, config.build());
return cacheManager.getCache(cacheName);
}

代码示例来源：origin: org.infinispan/infinispan-core

@Override
protected void createCacheManagers() throws Throwable {
ConfigurationBuilder builder = getDefaultClusteredCacheConfig(CacheMode.SCATTERED_SYNC, false);
builder.clustering().biasAcquisition(BiasAcquisition.ON_WRITE);
// Scan biases frequently
builder.expiration().wakeUpInterval(100);
createCluster(builder, 3);
waitForClusterToForm();
Arrays.stream(managers()).forEach(
cm -> TestingUtil.replaceComponent(cm, TimeService.class, timeService, true));
rpcManager0 = ControlledRpcManager.replaceRpcManager(cache(0));
rpcManager1 = CountingRpcManager.replaceRpcManager(cache(1));
TestingUtil.wrapInboundInvocationHandler(cache(0), handler -> handler0 = new RenewWaitingInvocationHandler(handler));
}

代码示例来源：origin: org.infinispan/infinispan-core

private static ConfigurationBuilder config(boolean passivation, int threads) {
ConfigurationBuilder cOnfig= new ConfigurationBuilder();
config.expiration().wakeUpInterval(100);
config.memory().size(1);
config.persistence()
.passivation(passivation)
.addStore(LockableStoreConfigurationBuilder.class)
.async()
.enabled(USE_ASYNC_STORE)
.threadPoolSize(threads);
return config;
}

代码示例来源：origin: org.infinispan/infinispan-core

@Override
protected EmbeddedCacheManager createCacheManager() throws Exception {
ConfigurationBuilder cfg = new ConfigurationBuilder();
cfg.memory().size(CACHE_SIZE).evictionType(EvictionType.COUNT).storageType(StorageType.BINARY)
.expiration().wakeUpInterval(100L)
.locking().useLockStriping(false) // to minimise chances of deadlock in the unit test
.build();
cacheManager = TestCacheManagerFactory.createCacheManager(cfg);
cache = cacheManager.getCache();
return cacheManager;
}

代码示例来源：origin: org.infinispan/infinispan-core

@Override
protected EmbeddedCacheManager createCacheManager() throws Exception {
ConfigurationBuilder cOnfig= getDefaultStandaloneCacheConfig(true);
config
.memory().size(10)
.expiration().wakeUpInterval(10L)
.persistence().addStore(DummyInMemoryStoreConfigurationBuilder.class)
.build();
EmbeddedCacheManager cm = TestCacheManagerFactory.createCacheManager(config);
cache = cm.getCache();
tm = getTransactionManager(cache);
return cm;
}

代码示例来源：origin: org.infinispan/infinispan-core

protected EmbeddedCacheManager createCacheManager() throws Exception {
ConfigurationBuilder cfgBuilder = new ConfigurationBuilder();
cfgBuilder.memory().size(128) // 128 max entries
.expiration().wakeUpInterval(100L)
.locking().useLockStriping(false) // to minimize chances of deadlock in the unit test
.invocationBatching().enable(true);
EmbeddedCacheManager cm = TestCacheManagerFactory.createCacheManager(cfgBuilder);
cache = cm.getCache();
cache.addListener(new EvictionFunctionalTest.EvictionListener());
return cm;
}

代码示例来源：origin: org.infinispan/infinispan-core

protected EmbeddedCacheManager createCacheManager() throws Exception {
ConfigurationBuilder builder = TestCacheManagerFactory.getDefaultCacheConfiguration(false);
builder.memory().size(CACHE_SIZE).storageType(getStorageType())
.expiration().wakeUpInterval(100L).locking()
.useLockStriping(false) // to minimize chances of deadlock in the unit test
.invocationBatching();
EmbeddedCacheManager cm = TestCacheManagerFactory.createCacheManager(builder);
cache = cm.getCache();
evictiOnListener= new EvictionListener();
cache.addListener(evictionListener);
TestingUtil.replaceComponent(cm, TimeService.class, timeService = new ControlledTimeService(), true);
return cm;
}