Package org.infinispan.configuration.global

Examples of org.infinispan.configuration.global.GlobalConfiguration.transport()

396
397
398
399
400
401
402
403
404
405
406
      assertTrue(gc.replicationQueueScheduledExecutor().factory() instanceof DefaultScheduledExecutorFactory);
      assertEquals("ReplicationQueueThread", gc.replicationQueueScheduledExecutor().properties().getProperty("threadNamePrefix"));

      assertTrue(gc.transport().transport() instanceof JGroupsTransport);
      assertEquals("infinispan-cluster", gc.transport().clusterName());
      // Should be "Jalapeno" but it's overriden by the test cache manager factory
      assertTrue(gc.transport().nodeName().contains("Node"));
      assertEquals(50000, gc.transport().distributedSyncTimeout());

      assertEquals(ShutdownHookBehavior.REGISTER, gc.shutdown().hookBehavior());
View Full Code Here
398
399
400
401
402
403
404
405
406
407
408
      assertEquals("ReplicationQueueThread", gc.replicationQueueScheduledExecutor().properties().getProperty("threadNamePrefix"));

      assertTrue(gc.transport().transport() instanceof JGroupsTransport);
      assertEquals("infinispan-cluster", gc.transport().clusterName());
      // Should be "Jalapeno" but it's overriden by the test cache manager factory
      assertTrue(gc.transport().nodeName().contains("Node"));
      assertEquals(50000, gc.transport().distributedSyncTimeout());

      assertEquals(ShutdownHookBehavior.REGISTER, gc.shutdown().hookBehavior());

      assertTrue(gc.serialization().marshaller() instanceof VersionAwareMarshaller);
View Full Code Here
399
400
401
402
403
404
405
406
407
408
409
      assertTrue(gc.transport().transport() instanceof JGroupsTransport);
      assertEquals("infinispan-cluster", gc.transport().clusterName());
      // Should be "Jalapeno" but it's overriden by the test cache manager factory
      assertTrue(gc.transport().nodeName().contains("Node"));
      assertEquals(50000, gc.transport().distributedSyncTimeout());

      assertEquals(ShutdownHookBehavior.REGISTER, gc.shutdown().hookBehavior());

      assertTrue(gc.serialization().marshaller() instanceof VersionAwareMarshaller);
      assertEquals(Version.getVersionShort("1.0"), gc.serialization().version());
View Full Code Here
63
64
65
66
67
68
69
70
71
72
73
               assert globalConfig.asyncListenerExecutor().properties().get("queueSize").equals("1020000");
               assert !defaultConfig.invocationBatching().enabled();
               assert globalConfig.serialization().marshaller().getClass().equals(VersionAwareMarshaller.class);
               assert defaultConfig.storeAsBinary().enabled();

               assert globalConfig.transport().clusterName().equals("JBossCache-cluster");
               assert defaultConfig.clustering().cacheMode().equals(CacheMode.INVALIDATION_SYNC);
               assert defaultConfig.clustering().stateTransfer().timeout() == 2120000;

               assert defaultConfig.clustering().sync().replTimeout() == 22220000;
               assert defaultConfig.eviction().strategy() == EvictionStrategy.LRU;
View Full Code Here
35
36
37
38
39
40
41
42
43
44
45
                  service.cacheManager.getName(), cache.getValue().getName());
            if (cacheProperties != null && !cacheProperties.isEmpty()) {
               configurationMap.put("cache_" + cache.getValue().getName(), cacheProperties);
            }
         }
         String clusterName = global.transport() == null ? "default" : global.transport().clusterName();
         Properties jgroupsProperties = configDumpHelper.dumpJGroups(jmxDomain, clusterName);
         if (!jgroupsProperties.isEmpty()) {
            configurationMap.put("jgroups", jgroupsProperties);
         }
      } catch (Exception e) {
View Full Code Here
35
36
37
38
39
40
41
42
43
44
45
                  service.cacheManager.getName(), cache.getValue().getName());
            if (cacheProperties != null && !cacheProperties.isEmpty()) {
               configurationMap.put("cache_" + cache.getValue().getName(), cacheProperties);
            }
         }
         String clusterName = global.transport() == null ? "default" : global.transport().clusterName();
         Properties jgroupsProperties = configDumpHelper.dumpJGroups(jmxDomain, clusterName);
         if (!jgroupsProperties.isEmpty()) {
            configurationMap.put("jgroups", jgroupsProperties);
         }
      } catch (Exception e) {
View Full Code Here
158
159
160
161
162
163
164
165
166
167
168
         @Override
         public void call() {
            GlobalConfiguration globalCfg = cm.getCacheManagerConfiguration();

            assert globalCfg.transport().transport() instanceof JGroupsTransport;
            assert globalCfg.transport().clusterName().equals("demoCluster");

            Configuration cfg = cm.getDefaultCacheConfiguration();
            assert cfg.clustering().cacheMode() == CacheMode.REPL_SYNC;
         }
View Full Code Here
159
160
161
162
163
164
165
166
167
168
169
         @Override
         public void call() {
            GlobalConfiguration globalCfg = cm.getCacheManagerConfiguration();

            assert globalCfg.transport().transport() instanceof JGroupsTransport;
            assert globalCfg.transport().clusterName().equals("demoCluster");

            Configuration cfg = cm.getDefaultCacheConfiguration();
            assert cfg.clustering().cacheMode() == CacheMode.REPL_SYNC;
         }
View Full Code Here
329
330
331
332
333
334
335
336
337
338
339
      assert gc.evictionScheduledExecutor().properties().getProperty("threadNamePrefix").equals("EvictionThread");

      assert gc.replicationQueueScheduledExecutor().factory() instanceof DefaultScheduledExecutorFactory;
      assert gc.replicationQueueScheduledExecutor().properties().getProperty("threadNamePrefix").equals("ReplicationQueueThread");

      assert gc.transport().transport() instanceof JGroupsTransport;
      assert gc.transport().clusterName().equals("infinispan-cluster");
      // Should be "Jalapeno" but it's overriden by the test cache manager factory
      assert gc.transport().nodeName().contains("Node");
      assert gc.transport().distributedSyncTimeout() == 50000;
View Full Code Here
330
331
332
333
334
335
336
337
338
339
340
      assert gc.replicationQueueScheduledExecutor().factory() instanceof DefaultScheduledExecutorFactory;
      assert gc.replicationQueueScheduledExecutor().properties().getProperty("threadNamePrefix").equals("ReplicationQueueThread");

      assert gc.transport().transport() instanceof JGroupsTransport;
      assert gc.transport().clusterName().equals("infinispan-cluster");
      // Should be "Jalapeno" but it's overriden by the test cache manager factory
      assert gc.transport().nodeName().contains("Node");
      assert gc.transport().distributedSyncTimeout() == 50000;

      assert gc.shutdown().hookBehavior().equals(ShutdownHookBehavior.REGISTER);
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.