本文整理了Java中org.infinispan.client.hotrod.RemoteCacheManager.administration
方法的一些代码示例,展示了RemoteCacheManager.administration
的具体用法。这些代码示例主要来源于Github
/Stackoverflow
/Maven
等平台,是从一些精选项目中提取出来的代码,具有较强的参考意义,能在一定程度帮忙到你。RemoteCacheManager.administration
方法的具体详情如下:
包路径:org.infinispan.client.hotrod.RemoteCacheManager
类名称:RemoteCacheManager
方法名:administration
暂无
代码示例来源:origin: wildfly/wildfly
@Override
public RemoteCacheManagerAdmin administration() {
return this.remoteCacheManager.administration();
}
代码示例来源:origin: org.wildfly/wildfly-clustering-infinispan-extension
@Override
public RemoteCacheManagerAdmin administration() {
return this.remoteCacheManager.administration();
}
代码示例来源:origin: org.hibernate.ogm/hibernate-ogm-infinispan-remote
protected void startAndValidateCache(RemoteCacheManager hotrodClient, String cacheName, String cacheConfiguration) {
try {
hotrodClient.administration()
.getOrCreateCache( cacheName, cacheConfiguration );
}
catch (HotRodClientException ex) {
failedCacheConfigurationNames.add( cacheConfiguration );
}
}
代码示例来源:origin: infinispan/infinispan-simple-tutorials
@Bean
@Order(2)
public CommandLineRunner createCache(ApplicationContext ctx) {
return args -> {
cacheManager.administration().getOrCreateCache(NEWBORNS_CACHE_NAME, "default");
logger.info(String.format("'%s' cache has been created", NEWBORNS_CACHE_NAME));
};
}
代码示例来源:origin: infinispan/infinispan-spring-boot
@Scheduled(fixedDelay = 2000)
public void retrieveSize() {
logger.info("Cache size " + cacheManager.administration().getOrCreateCache(Data.BASQUE_NAMES_CACHE, "default").size());
}
代码示例来源:origin: infinispan/infinispan-spring-boot
@Override
public void run(String... args) {
// Reset for the example, don't do this in production!!
RemoteCache<Object, Object> cache = cacheManager.administration().getOrCreateCache(Data.BASQUE_NAMES_CACHE, "default");
cache.clear();
}
代码示例来源:origin: org.hibernate.ogm/hibernate-ogm-infinispan-remote
protected void startAndValidateCache(RemoteCacheManager hotrodClient, String cacheName) {
hotrodClient.administration()
.getOrCreateCache( cacheName, getCacheConfiguration( cacheName ) );
}
代码示例来源:origin: org.infinispan/infinispan-jcache-remote
@Override
protected <K, V> void delegateRemoveCache(AbstractJCache<K, V> jcache) {
cm.administration().removeCache(jcache.getName());
}
代码示例来源:origin: org.teiid.wildfly.connectors/connector-infinispan-hotrod
@Override
public <K, V> BasicCache<K, V> getCache(String cacheName, boolean createIfNotExists) throws TranslatorException{
RemoteCache<Object, Object> cache = cacheManager.getCache(cacheName);
if (cache == null && createIfNotExists) {
cacheManager.administration().createCache(cacheName, this.cacheTemplate, EnumSet.of(AdminFlag.PERSISTENT));
cache = cacheManager.getCache(cacheName);
}
return (BasicCache<K,V>)cache;
}
代码示例来源:origin: org.uberfire/uberfire-metadata-backend-infinispan
public RemoteCache<String, KObject> getCache(String index) {
String i = AttributesUtil.toProtobufFormat(index).toLowerCase();
if (!this.getIndices().contains(i)) {
try {
cacheManager
.administration()
.createCache(i,
this.infinispanConfiguration.getIndexedConfiguration(i));
} catch (CacheConfigurationException ex) {
logger.warn("Can't create cache with name <{}>",
i);
logger.warn("Cause:",
ex);
}
}
return this.cacheManager.getCache(i);
}
代码示例来源:origin: org.infinispan/infinispan-jcache-remote
@Override
protected <K, V, C extends Configuration<K, V>> AbstractJCache<K, V> create(String cacheName, C configuration) {
ConfigurationAdapter<K, V> adapter = ConfigurationAdapter.create(configuration);
cm.administration().getOrCreateCache(cacheName, (String)null); // TODO: ISPN-9237 convert a JCache configuration to an Infinispan XML
return createJCache(cacheName, adapter);
}
代码示例来源:origin: kiegroup/appformer
public RemoteCache<String, KObject> getCache(String index) {
String cacheName = AttributesUtil.toProtobufFormat(index).toLowerCase();
if (!this.getIndices().contains(cacheName)) {
String appformerCacheName = addCachePrefix(cacheName);
try {
cacheManager
.administration()
.createCache(appformerCacheName,
this.infinispanConfiguration.getIndexedConfiguration(appformerCacheName));
} catch (HotRodClientException | CacheConfigurationException ex) {
logger.warn("Can't create cache with name <{}>",
appformerCacheName);
logger.warn("Cause:",
ex);
}
}
return this.cacheManager.getCache(addCachePrefix(cacheName));
}
代码示例来源:origin: org.infinispan.server/infinispan-server-testsuite
private void createCache(String cacheName, String transactionMode) {
String xml = String.format(TEST_CACHE_XML_CONFIG, cacheName, transactionMode);
remoteCacheManager.administration().createCache(cacheName, new XMLStringConfiguration(xml));
}
代码示例来源:origin: org.infinispan.server/infinispan-server-testsuite
@Test
public void testAdminOp() throws Exception {
adminRCM.administration().getOrCreateCache("testAdminOp", "template");
}
代码示例来源:origin: org.infinispan.server/infinispan-server-testsuite
@Test
public void testReindexing() {
remoteCacheManager.administration().reindexCache(remoteCache.getName());
}
}
代码示例来源:origin: infinispan/infinispan-simple-tutorials
public static void main(String[] args) {
// Create a client configuration connecting to a local server
ConfigurationBuilder builder = new ConfigurationBuilder();
builder.addServer().host("127.0.0.1").port(ConfigurationProperties.DEFAULT_HOTROD_PORT);
builder.nearCache().mode(NearCacheMode.INVALIDATED).maxEntries(20).cacheNamePattern("near-.*");
// Connect to the server
RemoteCacheManager cacheManager = new RemoteCacheManager(builder.build());
// Create one remote cache with near caching disabled and one with near caching enabled
RemoteCache<Integer, String> numbers = cacheManager.administration().getOrCreateCache("numbers", "default");
RemoteCache<Integer, String> nearNumbers = cacheManager.administration().getOrCreateCache("near-numbers", "default");
for (int i = 1; i<= 20; i++) {
numbers.put(i, String.valueOf(i));
nearNumbers.put(i, String.valueOf(i));
}
// Read both caches data
readCache(numbers);
readCache(nearNumbers);
// Stop the cache manager and release all resources
cacheManager.stop();
}
代码示例来源:origin: org.infinispan.server/infinispan-server-testsuite
@Test
public void testMultimap() {
remoteCacheManager.administration().getOrCreateCache("cutes", "default");
MultimapCacheManager multimapCacheManager = RemoteMultimapCacheManagerFactory.from(remoteCacheManager);
RemoteMultimapCache<Integer, String> people = multimapCacheManager.get("cutes");
people.put(1, "Elaia");
people.put(1, "Oihana");
Collection<String> littles = people.get(1).join();
assertEquals(2, littles.size());
assertTrue(littles.contains("Elaia"));
assertTrue(littles.contains("Oihana"));
}
代码示例来源:origin: kiegroup/appformer
cacheManager.administration().createCache(getTypesCacheName(),
this.infinispanConfiguration.getConfiguration(getTypesCacheName()));
cacheManager.administration().createCache(getSchemaCacheName(),
this.infinispanConfiguration.getConfiguration(getSchemaCacheName()));
代码示例来源:origin: infinispan/infinispan-simple-tutorials
public static void main(String[] args) throws Exception {
// Create a configuration for a locally-running server
ConfigurationBuilder builder = new ConfigurationBuilder();
builder.addServer().host("127.0.0.1")
.port(ConfigurationProperties.DEFAULT_HOTROD_PORT);
// Connect to the server and create a cache
RemoteCacheManager cacheManager = new RemoteCacheManager(builder.build());
cacheManager.administration().getOrCreateCache("people", "default");
// Retrieve the MultimapCacheManager from the CacheManager.
MultimapCacheManager multimapCacheManager = RemoteMultimapCacheManagerFactory.from(cacheManager);
// Retrieve the multimap cache.
RemoteMultimapCache<Integer, String> people = multimapCacheManager.get("people");
people.put(2016, "Alberto");
people.put(2016, "Oihana");
people.put(2016, "Roman");
people.put(2016, "Ane");
people.put(2017, "Paula");
people.put(2017, "Aimar");
people.put(2018, "Elaia");
people.get(2016).whenComplete((v, ex) -> {
System.out.println(v);
}).join();
// Stop the cache manager and release all resources
cacheManager.stop();
}
代码示例来源:origin: org.infinispan.server/infinispan-server-testsuite
@Test(expected = HotRodClientException.class)
public void testAdminOpWithoutAdminPerm() throws IOException {
SecurityConfigurationHelper config = new SecurityConfigurationHelper("DIGEST-MD5");
config.forIspnServer(server1).withServerName("node0");
config.forCredentials(WRITER_LOGIN, WRITER_PASSWD);
RemoteCacheManager writerRCM = new RemoteCacheManager(config.build(), true);
try {
writerRCM.administration().getOrCreateCache("testAdminOpWithoutAdminPerm", "template");
} finally {
writerRCM.stop();
}
}
}
内容来源于网络,如有侵权,请联系作者删除!