本文整理了Java中org.infinispan.configuration.cache.Configuration.dataContainer()
方法的一些代码示例,展示了Configuration.dataContainer()
的具体用法。这些代码示例主要来源于Github
/Stackoverflow
/Maven
等平台,是从一些精选项目中提取出来的代码,具有较强的参考意义,能在一定程度帮忙到你。Configuration.dataContainer()
方法的具体详情如下:
包路径:org.infinispan.configuration.cache.Configuration
类名称:Configuration
方法名:dataContainer
暂无
代码示例来源:origin: org.infinispan/infinispan-core
@Test
public void testDefault() throws IOException {
String xml = "<?xml version=\"1.0\" encoding=\"UTF-8\"?>" +
"<infinispan>" +
"<cache-container name=\"1\" default-cache=\"default-cache\">" +
"<local-cache name=\"default-cache\" />" +
"</cache-container>" +
"</infinispan>";
InputStream stream = new ByteArrayInputStream(xml.getBytes());
EmbeddedCacheManager cm = TestCacheManagerFactory.fromStream(stream);
try
{
// Verify that the configuration is correct
Assert.assertNull(cm.getDefaultCacheConfiguration().dataContainer().dataContainer());
Assert.assertEquals(cm.getCache().getAdvancedCache().getDataContainer().getClass(), DefaultDataContainer.class);
}
finally
{
TestingUtil.killCacheManagers(cm);
}
}
代码示例来源:origin: org.infinispan/infinispan-core
@Override
public void call() {
Configuration cfg = cm.getDefaultCacheConfiguration();
assertTrue(cfg.dataContainer().<byte[]>keyEquivalence() instanceof AnyEquivalence);
assertTrue(cfg.dataContainer().<byte[]>valueEquivalence() instanceof AnyEquivalence);
assertEquals(StorageType.BINARY, cfg.memory().storageType());
}
});
代码示例来源:origin: org.infinispan/infinispan-core
@Override
public void call() {
Configuration cfg = cm.getDefaultCacheConfiguration();
assertTrue(cfg.dataContainer().<byte[]>keyEquivalence() instanceof AnyEquivalence);
assertTrue(cfg.dataContainer().<byte[]>valueEquivalence() instanceof AnyEquivalence);
assertEquals(StorageType.OBJECT, cfg.memory().storageType());
}
});
代码示例来源:origin: org.infinispan/infinispan-core
Assert.assertEquals(cm.getDefaultCacheConfiguration().dataContainer().dataContainer().getClass().getName(), QueryableDataContainer.class.getName());
代码示例来源:origin: org.infinispan/infinispan-core
@Override
public void call() {
Configuration cfg = cm.getDefaultCacheConfiguration();
assertTrue(cfg.dataContainer().<byte[]>keyEquivalence() instanceof AnyEquivalence);
assertTrue(cfg.dataContainer().valueEquivalence() instanceof AnyEquivalence);
assertEquals(StorageType.OFF_HEAP, cfg.memory().storageType());
assertEquals(EvictionStrategy.MANUAL, cfg.memory().evictionStrategy());
}
});
代码示例来源:origin: org.infinispan/infinispan-core
@Test
public void testCustomDataContainer() {
ConfigurationBuilder configuration = new ConfigurationBuilder();
configuration.dataContainer().dataContainer(new QueryableDataContainer());
EmbeddedCacheManager cm = TestCacheManagerFactory.createCacheManager(configuration);
try {
AdvancedCache<Object, Object> cache = cm.getCache().getAdvancedCache();
DataContainer ddc = DefaultDataContainer.unBoundedDataContainer(cache.getCacheConfiguration().locking().concurrencyLevel());
ActivationManager activationManager = mock(ActivationManager.class);
doNothing().when(activationManager).onUpdate(Mockito.any(), Mockito.anyBoolean());
TestingUtil.inject(ddc, new InternalEntryFactoryImpl(), activationManager,
TIME_SERVICE, mock(InternalExpirationManager.class));
QueryableDataContainer.setDelegate(ddc);
// Verify that the config is correct
Assert.assertEquals(cm.getDefaultCacheConfiguration().dataContainer().dataContainer().getClass(), QueryableDataContainer.class);
DataContainer container = cache.getDataContainer();
Assert.assertEquals(container.getClass(), InternalDataContainerAdapter.class);
DataContainer delegate = ((InternalDataContainerAdapter) container).delegate();
Assert.assertEquals(delegate.getClass(), QueryableDataContainer.class);
QueryableDataContainer dataContainer = QueryableDataContainer.class.cast(delegate);
cache.put("name", "Pete");
Assert.assertTrue(checkLoggedOperations(dataContainer.getLoggedOperations(), "put(name, Pete", "compute(name,"));
} finally {
TestingUtil.killCacheManagers(cm);
}
}
代码示例来源:origin: org.infinispan/infinispan-hibernate-cache-commons
ConfigurationBuilder configurationBuilder = new ConfigurationBuilder();
configurationBuilder.read(pendingPutsConfiguration);
configurationBuilder.dataContainer().keyEquivalence(cacheConfiguration.dataContainer().keyEquivalence());
cacheManager.defineConfiguration(pendingPutsName, configurationBuilder.build());
代码示例来源:origin: org.infinispan/infinispan-core
assertTrue(c.dataContainer().dataContainer() instanceof QueryableDataContainer);
assertTrue(c.dataContainer().<byte[]>keyEquivalence() instanceof AnyEquivalence);
assertTrue(c.dataContainer().<byte[]>valueEquivalence() instanceof AnyEquivalence);
内容来源于网络,如有侵权,请联系作者删除!