本文整理汇总了Java中org.ehcache.config.CacheConfiguration类的典型用法代码示例。如果您正苦于以下问题:Java CacheConfiguration类的具体用法?Java CacheConfiguration怎么用?Java CacheConfiguration使用的例子?那么恭喜您, 这里精选的类代码示例或许可以为您提供帮助。
CacheConfiguration类属于org.ehcache.config包,在下文中一共展示了CacheConfiguration类的20个代码示例,这些例子默认根据受欢迎程度排序。您可以为喜欢或者感觉有用的代码点赞,您的评价将有助于我们的系统推荐出更棒的Java代码示例。
示例1: before
import org.ehcache.config.CacheConfiguration; //导入依赖的package包/类
@Before
public void before() throws Exception {
CachingProvider cachingProvider = Caching.getCachingProvider();
EhcacheCachingProvider ehcacheProvider = (EhcacheCachingProvider) cachingProvider;
DefaultConfiguration configuration = new DefaultConfiguration(ehcacheProvider.getDefaultClassLoader(),
new DefaultPersistenceConfiguration(diskPath.newFolder()));
CacheConfiguration<Integer, String> cacheConfiguration =
CacheConfigurationBuilder.newCacheConfigurationBuilder(Integer.class, String.class, resources).build();
configuration.addCacheConfiguration("cache", cacheConfiguration);
cacheManager = ehcacheProvider.getCacheManager(ehcacheProvider.getDefaultURI(), configuration);
EhcacheManager ehcacheManager = cacheManager.unwrap(EhcacheManager.class);
Field field = EhcacheManager.class.getDeclaredField("serviceLocator");
field.setAccessible(true);
@SuppressWarnings("unchecked")
ServiceProvider<Service> serviceProvider = (ServiceProvider<Service>)field.get(ehcacheManager);
StatisticsService statisticsService = serviceProvider.getService(StatisticsService.class);
cache = cacheManager.getCache("cache", Integer.class, String.class);
cacheStatistics = statisticsService.getCacheStatistics("cache");
}
开发者ID:ehcache,项目名称:ehcache3,代码行数:26,代码来源:JCacheCalculationTest.java
示例2: newCacheConfigurationBuilder_oneExpiryThreeResourcePools
import org.ehcache.config.CacheConfiguration; //导入依赖的package包/类
@Test
public void newCacheConfigurationBuilder_oneExpiryThreeResourcePools() throws Exception {
//given
addProp(CacheConfigurationServiceImpl.PROP_KEY_SUFFIX_TIME_TO_IDLE_SECS,60);
addProp(CacheConfigurationServiceImpl.PROP_KEY_SUFFIX_MAX_ENTRIES_HEAP,1);
addProp(CacheConfigurationServiceImpl.PROP_KEY_SUFFIX_MAX_MB_OFF_HEAP,2);
addProp(CacheConfigurationServiceImpl.PROP_KEY_SUFFIX_MAX_MB_DISK,3);
//when
CacheConfigurationBuilder<String,String> builder = cacheConfigurationService.newCacheConfigurationBuilder(CACHE_NAME, String.class, String.class);
CacheConfiguration<String, String> cacheConfiguration = builder.build();
//then
assertThat(cacheConfiguration.getResourcePools().getResourceTypeSet().size()).isEqualTo(3);
assertThat(cacheConfiguration.getExpiry()).isEqualTo(Expirations.timeToIdleExpiration(Duration.of(60, TimeUnit.SECONDS)));
}
开发者ID:gchq,项目名称:stroom-stats,代码行数:21,代码来源:TestCacheConfigurationService.java
示例3: createCache
import org.ehcache.config.CacheConfiguration; //导入依赖的package包/类
private void createCache(CacheManager cacheManager, String cacheName, Duration timeToLive, boolean persistentCache) {
ResourcePoolsBuilder resourcePoolsBuilder = ResourcePoolsBuilder.heap(100);
if (persistentCache) {
resourcePoolsBuilder = resourcePoolsBuilder.disk(1, MemoryUnit.MB, true);
}
CacheConfiguration<Object, Object> cacheConfiguration = CacheConfigurationBuilder.newCacheConfigurationBuilder(Object.class, Object.class,
resourcePoolsBuilder)
.withExpiry(Expirations.timeToLiveExpiration(timeToLive))
.build();
for (String cache : cacheManager.getCacheNames()) {
if (cache.equals(cacheName)) {
log.warn("cache '{}' already exists. skipping creation", cacheName);
return;
}
}
cacheManager.createCache(cacheName, Eh107Configuration.fromEhcacheCacheConfiguration(cacheConfiguration));
}
开发者ID:cronn-de,项目名称:jira-sync,代码行数:20,代码来源:JiraServiceCacheConfig.java
示例4: cacheManager
import org.ehcache.config.CacheConfiguration; //导入依赖的package包/类
@Bean
public CacheManager cacheManager(@Autowired Config config) {
long ttl = Long.valueOf(config.getProperties().getProperty(Config.PROP_CACHE_TTL));
double pctOfHeap = Double.valueOf(config.getProperties().getProperty(Config.PROP_CACHE_SIZE));
long cacheSizeMB = new Double(Runtime.getRuntime().maxMemory() * pctOfHeap / 1048576.0).longValue();
LogFactory.getLog(getClass()).info(
String.format("Initializing cache TTL=%d secs, size=%d MB (%.2f percent of max heap)",
ttl, cacheSizeMB, pctOfHeap * 100));
org.ehcache.config.CacheConfiguration<Object, Object> cacheConfiguration = CacheConfigurationBuilder
.newCacheConfigurationBuilder(Object.class, Object.class,
ResourcePoolsBuilder.newResourcePoolsBuilder()
.heap(cacheSizeMB, MemoryUnit.MB))
.withExpiry(Expirations.timeToLiveExpiration(new org.ehcache.expiry.Duration(ttl, TimeUnit.SECONDS)))
.build();
Map<String, CacheConfiguration<?, ?>> caches = new HashMap<>();
caches.put(CACHE_DEFAULT, cacheConfiguration);
EhcacheCachingProvider provider = (EhcacheCachingProvider) javax.cache.Caching.getCachingProvider();
// when our cacheManager bean is re-created several times for
// diff test configurations, this provider seems to hang on to state
// causing cache settings to not be right. so we always close().
provider.close();
DefaultConfiguration configuration = new DefaultConfiguration(
caches, provider.getDefaultClassLoader());
return new JCacheCacheManager(
provider.getCacheManager(provider.getDefaultURI(), configuration));
}
开发者ID:codeforkjeff,项目名称:conciliator,代码行数:35,代码来源:Application.java
示例5: init
import org.ehcache.config.CacheConfiguration; //导入依赖的package包/类
@Before
public void init() {
CacheConfiguration<Long, String> cacheConfiguration = CacheConfigurationBuilder.newCacheConfigurationBuilder(Long.class, String.class, heap(10))
.build();
service = new DefaultSharedManagementService();
cacheManager1 = CacheManagerBuilder.newCacheManagerBuilder()
.withCache("aCache1", cacheConfiguration)
.using(service)
.using(config1 = new DefaultManagementRegistryConfiguration().setCacheManagerAlias("myCM1"))
.build(true);
cacheManager2 = CacheManagerBuilder.newCacheManagerBuilder()
.withCache("aCache2", cacheConfiguration)
.withCache("aCache3", cacheConfiguration)
.using(service)
.using(config2 = new DefaultManagementRegistryConfiguration().setCacheManagerAlias("myCM2"))
.build(true);
// this serie of calls make sure the registry still works after a full init / close / init loop
cacheManager1.close();
cacheManager1.init();
cacheManager2.close();
cacheManager2.init();
}
开发者ID:ehcache,项目名称:ehcache3,代码行数:27,代码来源:DefaultSharedManagementServiceTest.java
示例6: testCopyValueOnRead
import org.ehcache.config.CacheConfiguration; //导入依赖的package包/类
@Test
public void testCopyValueOnRead() throws Exception {
CacheConfiguration<Long, Person> cacheConfiguration = baseConfig
.add(new DefaultCopierConfiguration<>(PersonOnReadCopier.class, DefaultCopierConfiguration.Type.VALUE))
.build();
Cache<Long, Person> cache = cacheManager.createCache("cache", cacheConfiguration);
Person original = new Person("Bar", 24);
cache.put(1l, original);
Person retrieved = cache.get(1l);
assertNotSame(original, retrieved);
assertThat(retrieved.name, equalTo("Bar"));
assertThat(retrieved.age, equalTo(24));
original.age = 56;
retrieved = cache.get(1l);
assertThat(retrieved.age, equalTo(56));
assertNotSame(cache.get(1l), cache.get(1l));
}
开发者ID:ehcache,项目名称:ehcache3,代码行数:23,代码来源:CacheCopierTest.java
示例7: testCopyValueOnWrite
import org.ehcache.config.CacheConfiguration; //导入依赖的package包/类
@Test
public void testCopyValueOnWrite() throws Exception {
CacheConfiguration<Long, Person> cacheConfiguration = baseConfig
.add(new DefaultCopierConfiguration<>(PersonOnWriteCopier.class, DefaultCopierConfiguration.Type.VALUE))
.build();
Cache<Long, Person> cache = cacheManager.createCache("cache", cacheConfiguration);
Person original = new Person("Bar", 24);
cache.put(1l, original);
Person retrieved = cache.get(1l);
assertNotSame(original, retrieved);
assertThat(retrieved.name, equalTo("Bar"));
assertThat(retrieved.age, equalTo(24));
original.age = 56;
retrieved = cache.get(1l);
assertThat(retrieved.age, equalTo(24));
assertSame(cache.get(1l), cache.get(1l));
}
开发者ID:ehcache,项目名称:ehcache3,代码行数:23,代码来源:CacheCopierTest.java
示例8: testIdentityCopier
import org.ehcache.config.CacheConfiguration; //导入依赖的package包/类
@Test
public void testIdentityCopier() throws Exception {
CacheConfiguration<Long, Person> cacheConfiguration = baseConfig.build();
Cache<Long, Person> cache = cacheManager.createCache("cache", cacheConfiguration);
Person original = new Person("Bar", 24);
cache.put(1l, original);
Person retrieved = cache.get(1l);
assertSame(original, retrieved);
original.age = 25;
retrieved = cache.get(1l);
assertSame(original, retrieved);
assertSame(cache.get(1l), cache.get(1l));
}
开发者ID:ehcache,项目名称:ehcache3,代码行数:19,代码来源:CacheCopierTest.java
示例9: testSerializingCopier
import org.ehcache.config.CacheConfiguration; //导入依赖的package包/类
@Test
public void testSerializingCopier() throws Exception {
CacheConfiguration<Long, Person> cacheConfiguration = baseConfig
.add(new DefaultCopierConfiguration<>(SerializingCopier.<Person>asCopierClass(), DefaultCopierConfiguration.Type.VALUE))
.add(new DefaultSerializerConfiguration<>(PersonSerializer.class, DefaultSerializerConfiguration.Type.VALUE))
.build();
Cache<Long, Person> cache = cacheManager.createCache("cache", cacheConfiguration);
Person original = new Person("Bar", 24);
cache.put(1l, original);
Person retrieved = cache.get(1l);
assertNotSame(original, retrieved);
assertThat(retrieved.name, equalTo("Bar"));
assertThat(retrieved.age, equalTo(24));
original.age = 56;
retrieved = cache.get(1l);
assertThat(retrieved.age, equalTo(24));
assertNotSame(cache.get(1l), cache.get(1l));
}
开发者ID:ehcache,项目名称:ehcache3,代码行数:24,代码来源:CacheCopierTest.java
示例10: testOverSizedObjectPutFailsWithOnHeapAsAuthority
import org.ehcache.config.CacheConfiguration; //导入依赖的package包/类
@Test
public void testOverSizedObjectPutFailsWithOnHeapAsAuthority() {
CacheManager cacheManager = CacheManagerBuilder.newCacheManagerBuilder()
.withDefaultSizeOfMaxObjectSize(500, MemoryUnit.B).build(true);
CacheConfiguration<String, String> cacheConfiguration = CacheConfigurationBuilder
.newCacheConfigurationBuilder(String.class, String.class,
newResourcePoolsBuilder()
.heap(100, MemoryUnit.KB).build())
.build();
Cache<String, String> cache = cacheManager.createCache("cache",
cacheConfiguration);
cache.put("key1", getOverSizedObject());
assertThat(cache.get("key1"), nullValue());
cache.put("key1", "value1");
cache.replace("key1", getOverSizedObject());
assertThat(cache.get("key1"), nullValue());
}
开发者ID:ehcache,项目名称:ehcache3,代码行数:23,代码来源:OverSizeMappingTest.java
示例11: testPutAll_without_cache_writer
import org.ehcache.config.CacheConfiguration; //导入依赖的package包/类
@Test
public void testPutAll_without_cache_writer() throws Exception {
CacheConfigurationBuilder cacheConfigurationBuilder = CacheConfigurationBuilder.newCacheConfigurationBuilder(String.class, String.class,
heap(100));
CacheConfiguration<String, String> cacheConfiguration = cacheConfigurationBuilder.build();
CacheManagerBuilder<CacheManager> managerBuilder = CacheManagerBuilder.newCacheManagerBuilder();
CacheManager cacheManager = managerBuilder.withCache("myCache", cacheConfiguration).build(true);
Cache<String, String> myCache = cacheManager.getCache("myCache", String.class, String.class);
HashMap<String, String> stringStringHashMap = new HashMap<>();
for (int i = 0; i < 3; i++) {
stringStringHashMap.put("key" + i, "value" + i);
}
// the call to putAll
myCache.putAll(stringStringHashMap);
for (int i = 0; i < 3; i++) {
assertThat(myCache.get("key" + i), is("value" + i));
}
}
开发者ID:ehcache,项目名称:ehcache3,代码行数:25,代码来源:EhcacheBulkMethodsITest.java
示例12: clusteredCacheManagerWithDynamicallyAddedCacheExample
import org.ehcache.config.CacheConfiguration; //导入依赖的package包/类
@Test
public void clusteredCacheManagerWithDynamicallyAddedCacheExample() throws Exception {
// tag::clusteredCacheManagerWithDynamicallyAddedCacheExample[]
CacheManagerBuilder<PersistentCacheManager> clusteredCacheManagerBuilder
= CacheManagerBuilder.newCacheManagerBuilder()
.with(ClusteringServiceConfigurationBuilder.cluster(URI.create("terracotta://localhost/my-application"))
.autoCreate()
.defaultServerResource("primary-server-resource")
.resourcePool("resource-pool-a", 28, MemoryUnit.MB));
PersistentCacheManager cacheManager = clusteredCacheManagerBuilder.build(false);
cacheManager.init();
try {
CacheConfiguration<Long, String> config = CacheConfigurationBuilder.newCacheConfigurationBuilder(Long.class, String.class,
ResourcePoolsBuilder.newResourcePoolsBuilder()
.with(ClusteredResourcePoolBuilder.clusteredDedicated("primary-server-resource", 2, MemoryUnit.MB))).build();
Cache<Long, String> cache = cacheManager.createCache("clustered-cache", config);
} finally {
cacheManager.close();
}
// end::clusteredCacheManagerWithDynamicallyAddedCacheExample[]
}
开发者ID:ehcache,项目名称:ehcache3,代码行数:25,代码来源:GettingStarted.java
示例13: before
import org.ehcache.config.CacheConfiguration; //导入依赖的package包/类
@Before
public void before() throws Exception {
CacheConfiguration<Integer, String> cacheConfiguration =
CacheConfigurationBuilder
.newCacheConfigurationBuilder(Integer.class, String.class, resources)
.withExpiry(ExpiryPolicyBuilder.timeToLiveExpiration(Duration.ofMillis(TIME_TO_EXPIRATION)))
.build();
StatisticsService statisticsService = new DefaultStatisticsService();
cacheManager = CacheManagerBuilder.newCacheManagerBuilder()
.withCache("cache", cacheConfiguration)
.using(new DefaultPersistenceConfiguration(diskPath.newFolder()))
.using(statisticsService)
.using(new TimeSourceConfiguration(timeSource))
.build(true);
cache = cacheManager.getCache("cache", Integer.class, String.class);
// Get the tier statistic.
tierStatistics = statisticsService.getCacheStatistics("cache")
.getTierStatistics().get(tierName);
}
开发者ID:ehcache,项目名称:ehcache3,代码行数:24,代码来源:TierCalculationTest.java
示例14: before
import org.ehcache.config.CacheConfiguration; //导入依赖的package包/类
@Before
public void before() throws Exception {
CacheConfiguration<Integer, String> cacheConfiguration =
CacheConfigurationBuilder.newCacheConfigurationBuilder(Integer.class, String.class, resources).build();
StatisticsService statisticsService = new DefaultStatisticsService();
cacheManager = CacheManagerBuilder.newCacheManagerBuilder()
.withCache("cache", cacheConfiguration)
.using(new DefaultPersistenceConfiguration(diskPath.newFolder()))
.using(statisticsService)
.build(true);
cache = cacheManager.getCache("cache", Integer.class, String.class);
cacheStatistics = statisticsService.getCacheStatistics("cache");
}
开发者ID:ehcache,项目名称:ehcache3,代码行数:18,代码来源:CacheCalculationTest.java
示例15: configEhcache2Jsr107
import org.ehcache.config.CacheConfiguration; //导入依赖的package包/类
@Test
public void configEhcache2Jsr107() {
CachingProvider provider = Caching.getCachingProvider();
CacheManager cacheManager = provider.getCacheManager();
CacheConfiguration<Long, String> cacheConfiguration = CacheConfigurationBuilder
.newCacheConfigurationBuilder(Long.class, String.class, ResourcePoolsBuilder.heap(10)).build();
Cache<Long, String> cache = cacheManager.createCache("myCache",
Eh107Configuration.fromEhcacheCacheConfiguration(cacheConfiguration));
Eh107Configuration<Long, String> configuration = cache.getConfiguration(Eh107Configuration.class);
configuration.unwrap(CacheConfiguration.class);
configuration.unwrap(CacheRuntimeConfiguration.class);
try {
cache.getConfiguration(CompleteConfiguration.class);
throw new AssertionError("IllegalArgumentException expected");
} catch (IllegalArgumentException iaex) {
// Expected
}
}
开发者ID:dzh,项目名称:jframe,代码行数:24,代码来源:TestJCache.java
示例16: testProvidingOffHeapDiskStoreConfiguration
import org.ehcache.config.CacheConfiguration; //导入依赖的package包/类
@Test
public void testProvidingOffHeapDiskStoreConfiguration() throws Exception {
OffHeapDiskStore.Provider provider = new OffHeapDiskStore.Provider();
ServiceLocator serviceLocator = dependencySet().with(diskResourceService).with(provider).build();
serviceLocator.startAllServices();
CacheConfiguration cacheConfiguration = mock(CacheConfiguration.class);
when(cacheConfiguration.getResourcePools()).thenReturn(newResourcePoolsBuilder().disk(1, MemoryUnit.MB, false).build());
PersistenceSpaceIdentifier space = diskResourceService.getPersistenceSpaceIdentifier("cache", cacheConfiguration);
@SuppressWarnings("unchecked")
Store.Configuration<Long, Object[]> storeConfig1 = mock(Store.Configuration.class);
when(storeConfig1.getKeyType()).thenReturn(Long.class);
when(storeConfig1.getValueType()).thenReturn(Object[].class);
when(storeConfig1.getResourcePools()).thenReturn(ResourcePoolsBuilder.newResourcePoolsBuilder()
.disk(10, MB)
.build());
when(storeConfig1.getDispatcherConcurrency()).thenReturn(1);
OffHeapDiskStore<Long, Object[]> offHeapDiskStore1 = provider.createStore(storeConfig1, space,
new OffHeapDiskStoreConfiguration("pool", 2, 4));
assertThat(offHeapDiskStore1.getThreadPoolAlias(), is("pool"));
assertThat(offHeapDiskStore1.getWriterConcurrency(), is(2));
assertThat(offHeapDiskStore1.getDiskSegments(), is(4));
}
开发者ID:ehcache,项目名称:ehcache3,代码行数:26,代码来源:OffHeapDiskStoreTest.java
示例17: evictionTest
import org.ehcache.config.CacheConfiguration; //导入依赖的package包/类
public void evictionTest() {
CacheConfiguration<Long, String> cacheConfiguration = CacheConfigurationBuilder
.newCacheConfigurationBuilder(Long.class, String.class, ResourcePoolsBuilder.heap(2L))
.withEvictionAdvisor(new OddKeysEvictionAdvisor<Long, String>()).build();
CacheManager cacheManager = CacheManagerBuilder.newCacheManagerBuilder().withCache("cache", cacheConfiguration)
.build(true);
Cache<Long, String> cache = cacheManager.getCache("cache", Long.class, String.class);
// Work with the cache
cache.put(42L, "The Answer!");
cache.put(41L, "The wrong Answer!");
cache.put(39L, "The other wrong Answer!");
cacheManager.close();
}
开发者ID:dzh,项目名称:jframe,代码行数:18,代码来源:TestEviction.java
示例18: testDoesNotNotifyAboutCacheOnInitOrClose
import org.ehcache.config.CacheConfiguration; //导入依赖的package包/类
@Test
public void testDoesNotNotifyAboutCacheOnInitOrClose() {
final CacheConfiguration<Object, Object> cacheConfiguration = new BaseCacheConfiguration<>(Object.class, Object.class, null, null, null, ResourcePoolsHelper
.createHeapOnlyPools());
final Store.Provider mock = mock(Store.Provider.class);
when(mock.rank(any(Set.class), any(Collection.class))).thenReturn(1);
final CacheEventDispatcherFactory cenlProvider = mock(CacheEventDispatcherFactory.class);
final CacheEventDispatcher<Object, Object> cenlServiceMock = mock(CacheEventDispatcher.class);
when(cenlProvider.createCacheEventDispatcher(any(Store.class))).thenReturn(cenlServiceMock);
final Collection<Service> services = getServices(mock, cenlProvider);
when(mock.createStore(ArgumentMatchers.<Store.Configuration>any())).thenReturn(mock(Store.class));
final String cacheAlias = "bar";
Map<String, CacheConfiguration<?, ?>> caches = newCacheMap();
caches.put(cacheAlias, cacheConfiguration);
DefaultConfiguration config = new DefaultConfiguration(caches, null);
EhcacheManager cacheManager = new EhcacheManager(config, services);
final CacheManagerListener listener = mock(CacheManagerListener.class);
cacheManager.registerListener(listener);
cacheManager.init();
final Cache<Object, Object> bar = cacheManager.getCache(cacheAlias, Object.class, Object.class);
verify(listener, never()).cacheAdded(cacheAlias, bar);
cacheManager.close();
verify(listener, never()).cacheRemoved(cacheAlias, bar);
}
开发者ID:ehcache,项目名称:ehcache3,代码行数:27,代码来源:EhcacheManagerTest.java
示例19: startServers
import org.ehcache.config.CacheConfiguration; //导入依赖的package包/类
@Before
public void startServers() throws Exception {
CLUSTER.getClusterControl().startAllServers();
CLUSTER.getClusterControl().waitForActive();
CLUSTER.getClusterControl().waitForRunningPassivesInStandby();
final CacheManagerBuilder<PersistentCacheManager> clusteredCacheManagerBuilder
= CacheManagerBuilder.newCacheManagerBuilder()
.with(ClusteringServiceConfigurationBuilder.cluster(CLUSTER.getConnectionURI().resolve("/crud-cm-replication"))
.autoCreate()
.defaultServerResource("primary-server-resource"));
CACHE_MANAGER1 = clusteredCacheManagerBuilder.build(true);
CACHE_MANAGER2 = clusteredCacheManagerBuilder.build(true);
CacheConfiguration<Long, BlobValue> config = CacheConfigurationBuilder.newCacheConfigurationBuilder(Long.class, BlobValue.class,
ResourcePoolsBuilder.newResourcePoolsBuilder().heap(500, EntryUnit.ENTRIES)
.with(ClusteredResourcePoolBuilder.clusteredDedicated("primary-server-resource", 4, MemoryUnit.MB)))
.add(ClusteredStoreConfigurationBuilder.withConsistency(cacheConsistency))
.build();
CACHE1 = CACHE_MANAGER1.createCache("clustered-cache", config);
CACHE2 = CACHE_MANAGER2.createCache("clustered-cache", config);
}
开发者ID:ehcache,项目名称:ehcache3,代码行数:22,代码来源:BasicClusteredCacheOpsReplicationWithMultipleClientsTest.java
示例20: testCacheManagerListener_called_after_configuration_updated
import org.ehcache.config.CacheConfiguration; //导入依赖的package包/类
@Test
public void testCacheManagerListener_called_after_configuration_updated() throws Exception {
EhcacheManager cacheManager = (EhcacheManager) CacheManagerBuilder.newCacheManagerBuilder()
.build();
CacheManagerListener cacheManagerListener = spy(new AssertiveCacheManagerListener(cacheManager.getRuntimeConfiguration()));
cacheManager.registerListener(cacheManagerListener);
cacheManager.init();
CacheConfiguration<String, String> cacheConfiguration = CacheConfigurationBuilder.newCacheConfigurationBuilder(String.class, String.class,
newResourcePoolsBuilder()
.heap(10, EntryUnit.ENTRIES)
.offheap(1, MemoryUnit.MB))
.build();
cacheManager.createCache(CACHE_NAME, cacheConfiguration);
verify(cacheManagerListener).cacheAdded(eq(CACHE_NAME), (Cache<?, ?>) isNotNull());
cacheManager.removeCache(CACHE_NAME);
verify(cacheManagerListener).cacheRemoved(eq(CACHE_NAME), (Cache<?, ?>) isNotNull());
}
开发者ID:ehcache,项目名称:ehcache3,代码行数:21,代码来源:CacheManagerListenerInteractionsTest.java
注:本文中的org.ehcache.config.CacheConfiguration类示例整理自Github/MSDocs等源码及文档管理平台,相关代码片段筛选自各路编程大神贡献的开源项目,源码版权归原作者所有,传播和使用请参考对应项目的License;未经允许,请勿转载。 |
请发表评论