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

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

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

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

相关文章