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

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

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

Configuration.jmxStatistics介绍

暂无

代码示例

代码示例来源：origin: org.infinispan/infinispan-server-memcached

public MemcachedDecoder(AdvancedCache<byte[], byte[]> memcachedCache, ScheduledExecutorService scheduler,
            NettyTransport transport, Predicate<? super String> ignoreCache,
            MediaType valuePayload) {
 super(MemcachedDecoderState.DECODE_HEADER);
 this.cache = (AdvancedCache<byte[], byte[]>) memcachedCache.withMediaType(TEXT_PLAIN_TYPE, valuePayload.toString());
 this.scheduler = scheduler;
 this.transport = transport;
 this.ignoreCache = ignoreCache;
 isStatsEnabled = cache.getCacheConfiguration().jmxStatistics().enabled();
}

代码示例来源：origin: de.smartics.properties/smartics-properties-cache-infinispan

/**
 * Default constructor.
 *
 * @param manager the Infinispan cache manager.
 */
public AbstractInfinispanCompoundKeyCacheManager(
  final EmbeddedCacheManager manager)
{
 this.manager = manager;
 configManager = new GuavaCacheManager();
 manager.getDefaultCacheConfiguration().jmxStatistics();
 this.cache = manager.getCache(CACHE_NAME);
 if (!manager.isRunning(CACHE_NAME))
 {
  final Configuration cacheConfig = this.cache.getCacheConfiguration();
  cacheConfig.jmxStatistics();
  cacheConfig.indexing().indexLocalOnly();
  cache.start();
 }
 // cache.addListener(new CompoundKeyHandlingCacheListener());
 cache.clear();
}

代码示例来源：origin: org.infinispan/infinispan-hibernate-cache-commons

@Start
private void start() {
  this.cacheName = ByteString.fromString(cache.getName());
  this.setStatisticsEnabled(cacheConfiguration.jmxStatistics().enabled());
  syncRpcOptions = rpcManager.getRpcOptionsBuilder(ResponseMode.SYNCHRONOUS_IGNORE_LEAVERS, DeliverOrder.NONE).build();
}

代码示例来源：origin: org.infinispan/infinispan-hibernate-cache-commons

InfinispanBaseRegion region = factory.buildEntityRegion("com.acme.Address", AccessType.TRANSACTIONAL);
  AdvancedCache cache = region.getCache();
  assertFalse( cache.getCacheConfiguration().jmxStatistics().enabled() );
  assertFalse( cache.getCacheConfiguration().jmxStatistics().enabled() );
  assertFalse( cache.getCacheConfiguration().jmxStatistics().enabled() );
  assertFalse( cache.getCacheConfiguration().jmxStatistics().enabled() );
  assertFalse( cache.getCacheConfiguration().jmxStatistics().enabled() );
} finally {
  factory.stop();

代码示例来源：origin: org.infinispan/infinispan-cli-server

private void printCacheStats(PrintWriter pw, Cache<?, ?> cache) throws StatementException {
 if (!cache.getCacheConfiguration().jmxStatistics().enabled()) {
   throw log.statisticsNotEnabled(cache.getName());
 }
 for (CommandInterceptor interceptor : cache.getAdvancedCache().getInterceptorChain()) {
   printComponentStats(pw, cache, interceptor);
 }
 printComponentStats(pw, cache, cache.getAdvancedCache().getLockManager());
 printComponentStats(pw, cache, cache.getAdvancedCache().getRpcManager());
}

代码示例来源：origin: org.infinispan/infinispan-cli-interpreter

private void printCacheStats(PrintWriter pw, Cache<?, ?> cache) throws StatementException {
 if (!cache.getCacheConfiguration().jmxStatistics().enabled()) {
   throw log.statisticsNotEnabled(cache.getName());
 }
 for (AsyncInterceptor interceptor : cache.getAdvancedCache().getAsyncInterceptorChain().getInterceptors()) {
   printComponentStats(pw, cache, interceptor);
 }
 printComponentStats(pw, cache, cache.getAdvancedCache().getLockManager());
 printComponentStats(pw, cache, cache.getAdvancedCache().getRpcManager());
}

代码示例来源：origin: org.infinispan/infinispan-hibernate-cache-commons

InfinispanBaseRegion region = factory.buildEntityRegion("com.acme.Address", AccessType.TRANSACTIONAL);
  AdvancedCache cache = region.getCache();
  assertTrue(cache.getCacheConfiguration().jmxStatistics().enabled());
  assertTrue(cache.getCacheConfiguration().jmxStatistics().enabled());
  assertTrue(cache.getCacheConfiguration().jmxStatistics().enabled());
  assertTrue(cache.getCacheConfiguration().jmxStatistics().enabled());
  assertTrue(cache.getCacheConfiguration().jmxStatistics().enabled());
} finally {
  factory.stop();

代码示例来源：origin: org.infinispan/infinispan-embedded-query

stats.setStatisticsEnabled(cfg.jmxStatistics().enabled());
try {
  ObjectName statsObjName = new ObjectName(

代码示例来源：origin: org.infinispan/infinispan-query

stats.setStatisticsEnabled(cfg.jmxStatistics().enabled());

代码示例来源：origin: org.infinispan/infinispan-hibernate-cache-commons

@Test
public void testDefaultPendingPutsCache() {
  Properties p = createProperties();
  TestRegionFactory factory = createRegionFactory(p);
  try {
    Configuration ppConfig = factory.getCacheManager().getCacheConfiguration(DEF_PENDING_PUTS_RESOURCE);
    assertTrue(ppConfig.isTemplate());
    assertFalse(ppConfig.clustering().cacheMode().isClustered());
    assertTrue(ppConfig.simpleCache());
    assertEquals(TransactionMode.NON_TRANSACTIONAL, ppConfig.transaction().transactionMode());
    assertEquals(60000, ppConfig.expiration().maxIdle());
    assertFalse(ppConfig.jmxStatistics().enabled());
    assertFalse(ppConfig.jmxStatistics().available());
  } finally {
    factory.stop();
  }
}

代码示例来源：origin: org.infinispan/infinispan-hibernate-cache-commons

@Test
public void testBuildQueryRegion() {
  final String query = "org.hibernate.cache.internal.StandardQueryCache";
  Properties p = createProperties();
  TestRegionFactory factory = createRegionFactory(p);
  try {
    assertTrue(isDefinedCache(factory, "local-query"));
    InfinispanBaseRegion region = factory.buildQueryResultsRegion(query);
    AdvancedCache cache = region.getCache();
    Configuration cacheCfg = cache.getCacheConfiguration();
    assertEquals( CacheMode.LOCAL, cacheCfg.clustering().cacheMode() );
    assertFalse( cacheCfg.jmxStatistics().enabled() );
  } finally {
    factory.stop();
  }
}

代码示例来源：origin: org.infinispan/infinispan-hibernate-cache-commons

assertEquals(60000, cacheCfg.expiration().lifespan());
  assertEquals(30000, cacheCfg.expiration().maxIdle());
  assertFalse(cacheCfg.jmxStatistics().enabled());
  assertEquals(3000, cacheCfg.expiration().wakeUpInterval());
  assertEquals(20000, cacheCfg.memory().size());
  assertFalse(cacheCfg.jmxStatistics().enabled());
  assertEquals(3000, cacheCfg.expiration().wakeUpInterval());
  assertEquals(20000, cacheCfg.memory().size());
  assertFalse(cacheCfg.jmxStatistics().enabled());
  assertEquals(65000, cacheCfg.expiration().lifespan());
  assertEquals(35000, cacheCfg.expiration().maxIdle());
  assertFalse(cacheCfg.jmxStatistics().enabled());
  assertEquals(3500, cacheCfg.expiration().wakeUpInterval());
  assertEquals(25000, cacheCfg.memory().size());
  assertFalse(cacheCfg.jmxStatistics().enabled());
  assertEquals(3500, cacheCfg.expiration().wakeUpInterval());
  assertEquals(25000, cacheCfg.memory().size());
  assertFalse(cacheCfg.jmxStatistics().enabled());
} finally {
  factory.stop();

代码示例来源：origin: org.infinispan/infinispan-hibernate-cache-commons

@Test
public void testBuildDefaultTimestampsRegion() {
  final String timestamps = "org.hibernate.cache.spi.UpdateTimestampsCache";
  Properties p = createProperties();
  TestRegionFactory factory = createRegionFactory(p);
  try {
    assertTrue(isDefinedCache(factory, DEF_TIMESTAMPS_RESOURCE));
    InfinispanBaseRegion region = factory.buildTimestampsRegion(timestamps);
    AdvancedCache cache = region.getCache();
    assertEquals(timestamps, cache.getName());
    Configuration cacheCfg = cache.getCacheConfiguration();
    assertEquals( CacheMode.REPL_ASYNC, cacheCfg.clustering().cacheMode() );
    assertFalse( cacheCfg.jmxStatistics().enabled() );
  } finally {
    factory.stop();
  }
}

代码示例来源：origin: org.infinispan/infinispan-hibernate-cache-commons

@Test
public void testBuildDiffCacheNameTimestampsRegion() {
  final String timestamps = "org.hibernate.cache.spi.UpdateTimestampsCache";
  final String unrecommendedTimestamps = "unrecommended-timestamps";
  Properties p = createProperties();
  p.setProperty( TIMESTAMPS_CACHE_RESOURCE_PROP, unrecommendedTimestamps);
  TestRegionFactory factory = createRegionFactory(p, m -> {
    ConfigurationBuilder builder = new ConfigurationBuilder();
    builder.clustering().stateTransfer().fetchInMemoryState(true);
    builder.clustering().cacheMode( CacheMode.REPL_SYNC );
    m.defineConfiguration(unrecommendedTimestamps, builder.build() );
  });
  try {
    assertEquals(unrecommendedTimestamps, factory.getBaseConfiguration(InfinispanProperties.TIMESTAMPS));
    InfinispanBaseRegion region = factory.buildTimestampsRegion(timestamps);
    AdvancedCache cache = region.getCache();
    Configuration cacheCfg = cache.getCacheConfiguration();
    assertEquals(CacheMode.REPL_SYNC, cacheCfg.clustering().cacheMode());
    assertTrue(cacheCfg.memory().storageType() != StorageType.BINARY);
    assertFalse(cacheCfg.jmxStatistics().enabled());
  } finally {
    factory.stop();
  }
}

代码示例来源：origin: org.infinispan/infinispan-core

assertTrue(!c.jmxStatistics().enabled());
assertTrue(gc.globalJmxStatistics().enabled());
assertTrue(gc.globalJmxStatistics().allowDuplicateDomains());

代码示例来源：origin: org.infinispan/infinispan-core

assertTrue(c.jmxStatistics().enabled());
assertEquals(CacheMode.LOCAL, c.clustering().cacheMode());
assertEquals(30000, c.locking().lockAcquisitionTimeout());
assertEquals(CacheMode.INVALIDATION_SYNC, c.clustering().cacheMode());
assertTrue(c.invocationBatching().enabled());
assertTrue(c.jmxStatistics().enabled());
assertEquals(30500, c.locking().lockAcquisitionTimeout());
assertEquals(2500, c.locking().concurrencyLevel());
assertEquals(CacheMode.REPL_SYNC, c.clustering().cacheMode());
assertTrue(c.invocationBatching().enabled());
assertTrue(c.jmxStatistics().enabled());
assertEquals(31000, c.locking().lockAcquisitionTimeout());
assertEquals(3000, c.locking().concurrencyLevel());
assertTrue(c.clustering().hash().consistentHashFactory() instanceof SyncConsistentHashFactory);
assertTrue(c.clustering().partitionHandling().enabled());
assertTrue(c.jmxStatistics().enabled());
assertEquals(31500, c.locking().lockAcquisitionTimeout());
assertEquals(3500, c.locking().concurrencyLevel());

内容来源于网络，如有侵权，请联系作者删除！

Configuration

相关文章

    查看更多

    热门标签

    更多
    JavaquerypythonNode开发语言requestUtil数据库Table后端算法LoggerMessageElementParser

    最新文章

    更多
    • 蜀ICP备2022004421号-2 NULL123 https://www.null123.com © All rights reserved
    • 本站内容来源互联网,如果侵犯您的权益请联系我们删除, 联系方式：448109455@qq.com