org.infinispan.client.hotrod.RemoteCacheManager.administration()方法的使用及代码示例

x33g5p2x  于2022-01-28 转载在 其他  
字(8.7k)|赞(0)|评价(0)|浏览(80)

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

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

相关文章