Examples of remoteCallTimeout()

Examples of org.infinispan.configuration.cache.ClusterLoaderConfiguration.remoteCallTimeout()

463
464
465
466
467
468
469
470
471
472
473
      assertEquals(700, loaderCfg.async().modificationQueueSize());

      c = cm.getCacheConfiguration("withClusterLoader");
      assertEquals(1, c.persistence().stores().size());
      ClusterLoaderConfiguration clusterLoaderCfg = (ClusterLoaderConfiguration) c.persistence().stores().get(0);
      assertEquals(15000, clusterLoaderCfg.remoteCallTimeout());

      c = cm.getCacheConfiguration("withLoaderDefaults");
      loaderCfg = (SingleFileStoreConfiguration) c.persistence().stores().get(0);
      assertEquals("/tmp/Another-FileCacheStore-Location", loaderCfg.location());
View Full Code Here

Examples of org.infinispan.configuration.cache.ClusterLoaderConfiguration.remoteCallTimeout()

517
518
519
520
521
522
523
524
525
526
527
      assertEquals(700, loaderCfg.async().modificationQueueSize());

      c = cm.getCacheConfiguration("withClusterLoader");
      assertEquals(1, c.persistence().stores().size());
      ClusterLoaderConfiguration clusterLoaderCfg = (ClusterLoaderConfiguration) c.persistence().stores().get(0);
      assertEquals(15000, clusterLoaderCfg.remoteCallTimeout());

      c = cm.getCacheConfiguration("withLoaderDefaults");
      loaderCfg = (SingleFileStoreConfiguration) c.persistence().stores().get(0);
      assertEquals("/tmp/Another-FileCacheStore-Location", loaderCfg.location());
View Full Code Here

Examples of org.infinispan.configuration.cache.ClusterLoaderConfiguration.remoteCallTimeout()

215
216
217
218
219
220
221
222
223
224
225
            assertEquals(12, c.expiration().maxIdle());
            assertFalse(c.clustering().stateTransfer().fetchInMemoryState());
            assertEquals(60000, c.clustering().stateTransfer().timeout());
            assertEquals(10000, c.clustering().stateTransfer().chunkSize());
            ClusterLoaderConfiguration clusterLoader = (ClusterLoaderConfiguration) c.persistence().stores().get(1);
            assertEquals(35000, clusterLoader.remoteCallTimeout());
            assertTrue(clusterLoader.preload());
            assertEquals(Index.NONE, c.indexing().index());

            c = cm.getCache("dist").getCacheConfiguration();
            assertEquals(CacheMode.DIST_SYNC, c.clustering().cacheMode());
View Full Code Here

Examples of org.infinispan.configuration.cache.ClusterLoaderConfiguration.remoteCallTimeout()

484
485
486
487
488
489
490
491
492
493
494
      assertEquals(700, loaderCfg.async().modificationQueueSize());

      c = cm.getCacheConfiguration("withClusterLoader");
      assertEquals(1, c.persistence().stores().size());
      ClusterLoaderConfiguration clusterLoaderCfg = (ClusterLoaderConfiguration) c.persistence().stores().get(0);
      assertEquals(15000, clusterLoaderCfg.remoteCallTimeout());

      c = cm.getCacheConfiguration("withLoaderDefaults");
      loaderCfg = (SingleFileStoreConfiguration) c.persistence().stores().get(0);
      assertEquals("/tmp/Another-FileCacheStore-Location", loaderCfg.location());
View Full Code Here

Examples of org.infinispan.configuration.cache.ClusterLoaderConfiguration.remoteCallTimeout()

215
216
217
218
219
220
221
222
223
224
225
            assertEquals(12, c.expiration().maxIdle());
            assertFalse(c.clustering().stateTransfer().fetchInMemoryState());
            assertEquals(60000, c.clustering().stateTransfer().timeout());
            assertEquals(10000, c.clustering().stateTransfer().chunkSize());
            ClusterLoaderConfiguration clusterLoader = (ClusterLoaderConfiguration) c.persistence().stores().get(1);
            assertEquals(35000, clusterLoader.remoteCallTimeout());
            assertTrue(clusterLoader.preload());
            assertEquals(Index.NONE, c.indexing().index());

            c = cm.getCache("dist").getCacheConfiguration();
            assertEquals(CacheMode.DIST_SYNC, c.clustering().cacheMode());
View Full Code Here

Examples of org.infinispan.configuration.cache.ClusterLoaderConfiguration.remoteCallTimeout()

28
29
30
31
32
33
34
35
      List<StoreConfiguration> stores = cacheManager.getCache("customLoaderCache").getCacheConfiguration().persistence().stores();
      assertEquals(stores.size(), 1);
      StoreConfiguration storeConfiguration = stores.get(0);
      assertTrue(storeConfiguration instanceof ClusterLoaderConfiguration);
      ClusterLoaderConfiguration csc = (ClusterLoaderConfiguration) storeConfiguration;
      assertEquals(csc.remoteCallTimeout(), 1222);
   }
}
View Full Code Here

Examples of org.infinispan.configuration.cache.ClusterLoaderConfiguration.remoteCallTimeout()

214
215
216
217
218
219
220
221
222
223
224
            assertEquals(12, c.expiration().maxIdle());
            assertFalse(c.clustering().stateTransfer().fetchInMemoryState());
            assertEquals(60000, c.clustering().stateTransfer().timeout());
            assertEquals(10000, c.clustering().stateTransfer().chunkSize());
            ClusterLoaderConfiguration clusterLoader = (ClusterLoaderConfiguration) c.persistence().stores().get(1);
            assertEquals(35000, clusterLoader.remoteCallTimeout());
            assertTrue(clusterLoader.preload());
            assertEquals(Index.NONE, c.indexing().index());

            c = cm.getCache("dist").getCacheConfiguration();
            assertEquals(CacheMode.DIST_SYNC, c.clustering().cacheMode());
View Full Code Here

Examples of org.infinispan.configuration.cache.ClusterLoaderConfigurationBuilder.remoteCallTimeout()

605
606
607
608
609
610
611
612
613
614
615
    private StoreConfigurationBuilder<?, ?> buildCacheLoader(PersistenceConfigurationBuilder persistenceBuilder, ModelNode loader, String loaderKey) throws OperationFailedException {
        if (loaderKey.equals(ModelKeys.CLUSTER_LOADER)) {
            final ClusterLoaderConfigurationBuilder builder = persistenceBuilder.addClusterLoader();

            if (loader.hasDefined(ModelKeys.REMOTE_TIMEOUT)) {
                builder.remoteCallTimeout(loader.require(ModelKeys.REMOTE_TIMEOUT).asLong());
            }
            return builder;
        } else if (loaderKey.equals(ModelKeys.LOADER)) {
           String className = loader.require(ModelKeys.CLASS).asString();
           try {
View Full Code Here

Examples of org.infinispan.loaders.cluster.ClusterCacheLoaderConfig.remoteCallTimeout()

48
49
50
51
52
53
54
55
56
57
58
   }

   @Override
   public ClusterCacheLoaderConfig adapt() {
      ClusterCacheLoaderConfig config = new ClusterCacheLoaderConfig();
      config.remoteCallTimeout(remoteCallTimeout);
      XmlConfigHelper.setValues(config, properties(), false, true);
      return config;
   }

View Full Code Here

Examples of org.infinispan.loaders.cluster.ClusterCacheLoaderConfig.remoteCallTimeout()

30
31
32
33
34
35
36
37
38
39
40
   }

   @Override
   public ClusterCacheLoaderConfig adapt() {
      ClusterCacheLoaderConfig config = new ClusterCacheLoaderConfig();
      config.remoteCallTimeout(remoteCallTimeout);
      XmlConfigHelper.setValues(config, properties(), false, true);
      return config;
   }

View Full Code Here
TOP
Copyright © 2018 www.massapi.com. All rights reserved.
All source code are property of their respective owners. Java is a trademark of Sun Microsystems, Inc and owned by ORACLE Inc. Contact coftware#gmail.com.