Package org.infinispan.configuration.global

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

61
62
63
64
65
66
67
68
69
70
71
            assertEquals(1, g.globalJmxStatistics().properties().size());
            assertEquals("value", g.globalJmxStatistics().properties().getProperty("key"));

            // Transport
            assertEquals("maximal-cluster", g.transport().clusterName());
            assertEquals(120000, g.transport().distributedSyncTimeout());
            assertEquals("udp", g.transport().properties().getProperty("stack-udp"));
            assertEquals("tcp", g.transport().properties().getProperty("stack-tcp"));
            assertEquals("jgroups-udp.xml", g.transport().properties().getProperty("stackFilePath-udp"));
            assertEquals("jgroups-tcp.xml", g.transport().properties().getProperty("stackFilePath-tcp"));
            assertEquals("tcp", g.transport().properties().getProperty("stack"));
View Full Code Here
62
63
64
65
66
67
68
69
70
71
72
            assertEquals("value", g.globalJmxStatistics().properties().getProperty("key"));

            // Transport
            assertEquals("maximal-cluster", g.transport().clusterName());
            assertEquals(120000, g.transport().distributedSyncTimeout());
            assertEquals("udp", g.transport().properties().getProperty("stack-udp"));
            assertEquals("tcp", g.transport().properties().getProperty("stack-tcp"));
            assertEquals("jgroups-udp.xml", g.transport().properties().getProperty("stackFilePath-udp"));
            assertEquals("jgroups-tcp.xml", g.transport().properties().getProperty("stackFilePath-tcp"));
            assertEquals("tcp", g.transport().properties().getProperty("stack"));
View Full Code Here
63
64
65
66
67
68
69
70
71
72
73
            // Transport
            assertEquals("maximal-cluster", g.transport().clusterName());
            assertEquals(120000, g.transport().distributedSyncTimeout());
            assertEquals("udp", g.transport().properties().getProperty("stack-udp"));
            assertEquals("tcp", g.transport().properties().getProperty("stack-tcp"));
            assertEquals("jgroups-udp.xml", g.transport().properties().getProperty("stackFilePath-udp"));
            assertEquals("jgroups-tcp.xml", g.transport().properties().getProperty("stackFilePath-tcp"));
            assertEquals("tcp", g.transport().properties().getProperty("stack"));

            DefaultThreadFactory threadFactory =
View Full Code Here
64
65
66
67
68
69
70
71
72
73
74
            // Transport
            assertEquals("maximal-cluster", g.transport().clusterName());
            assertEquals(120000, g.transport().distributedSyncTimeout());
            assertEquals("udp", g.transport().properties().getProperty("stack-udp"));
            assertEquals("tcp", g.transport().properties().getProperty("stack-tcp"));
            assertEquals("jgroups-udp.xml", g.transport().properties().getProperty("stackFilePath-udp"));
            assertEquals("jgroups-tcp.xml", g.transport().properties().getProperty("stackFilePath-tcp"));
            assertEquals("tcp", g.transport().properties().getProperty("stack"));

            DefaultThreadFactory threadFactory =
                  cm.getCacheManagerConfiguration().listenerThreadPool().threadFactory();
View Full Code Here
65
66
67
68
69
70
71
72
73
74
75
            assertEquals("maximal-cluster", g.transport().clusterName());
            assertEquals(120000, g.transport().distributedSyncTimeout());
            assertEquals("udp", g.transport().properties().getProperty("stack-udp"));
            assertEquals("tcp", g.transport().properties().getProperty("stack-tcp"));
            assertEquals("jgroups-udp.xml", g.transport().properties().getProperty("stackFilePath-udp"));
            assertEquals("jgroups-tcp.xml", g.transport().properties().getProperty("stackFilePath-tcp"));
            assertEquals("tcp", g.transport().properties().getProperty("stack"));

            DefaultThreadFactory threadFactory =
                  cm.getCacheManagerConfiguration().listenerThreadPool().threadFactory();
            assertEquals("infinispan", threadFactory.threadGroup().getName());
View Full Code Here
66
67
68
69
70
71
72
73
74
75
76
            assertEquals(120000, g.transport().distributedSyncTimeout());
            assertEquals("udp", g.transport().properties().getProperty("stack-udp"));
            assertEquals("tcp", g.transport().properties().getProperty("stack-tcp"));
            assertEquals("jgroups-udp.xml", g.transport().properties().getProperty("stackFilePath-udp"));
            assertEquals("jgroups-tcp.xml", g.transport().properties().getProperty("stackFilePath-tcp"));
            assertEquals("tcp", g.transport().properties().getProperty("stack"));

            DefaultThreadFactory threadFactory =
                  cm.getCacheManagerConfiguration().listenerThreadPool().threadFactory();
            assertEquals("infinispan", threadFactory.threadGroup().getName());
            assertEquals("%G %i", threadFactory.threadNamePattern());
View Full Code Here
82
83
84
85
86
87
88
89
90
91
92
         @Override
         public void call() {
            GlobalConfiguration globalCfg = cm.getCacheManagerConfiguration();

            assertTrue(globalCfg.transport().transport() instanceof JGroupsTransport);
            assertEquals("demoCluster", globalCfg.transport().clusterName());

            Configuration cfg = cm.getDefaultCacheConfiguration();
            assertEquals(CacheMode.REPL_SYNC, cfg.clustering().cacheMode());
         }
View Full Code Here
83
84
85
86
87
88
89
90
91
92
93
         @Override
         public void call() {
            GlobalConfiguration globalCfg = cm.getCacheManagerConfiguration();

            assertTrue(globalCfg.transport().transport() instanceof JGroupsTransport);
            assertEquals("demoCluster", globalCfg.transport().clusterName());

            Configuration cfg = cm.getDefaultCacheConfiguration();
            assertEquals(CacheMode.REPL_SYNC, cfg.clustering().cacheMode());
         }
View Full Code Here
364
365
366
367
368
369
370
371
372
373
374
      DefaultThreadFactory replicationQueueThreadFactory =
            cm.getCacheManagerConfiguration().replicationQueueThreadPool().threadFactory();
      assertEquals("ReplicationQueueThread", replicationQueueThreadFactory.threadNamePattern());

      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());
View Full Code Here
365
366
367
368
369
370
371
372
373
374
375
      DefaultThreadFactory replicationQueueThreadFactory =
            cm.getCacheManagerConfiguration().replicationQueueThreadPool().threadFactory();
      assertEquals("ReplicationQueueThread", replicationQueueThreadFactory.threadNamePattern());

      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
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.