Package org.infinispan.config

Examples of org.infinispan.config.Configuration.fluent()

52
53
54
55
56
57
58
59
60
61
62
   private AdvancedCache<Object, Object> skipListenerCache;

   @BeforeMethod
   public void setUp() throws Exception {
      Configuration c = new Configuration();
      c.fluent().transaction().transactionMode(TransactionMode.NON_TRANSACTIONAL);
      c.setCacheMode(Configuration.CacheMode.LOCAL);
      c.setIsolationLevel(IsolationLevel.REPEATABLE_READ);
      cm = TestCacheManagerFactory.createCacheManager(c);

      cache = cm.getCache();
View Full Code Here
34
35
36
37
38
39
40
41
42
43
44
      key = new MagicKey("Key mapped to Cache2", cm2.getCache());
   }

   protected Configuration createConfig() {
      Configuration cfg = getDefaultClusteredConfig(Configuration.CacheMode.DIST_SYNC, true);
      cfg.fluent().transaction().lockingMode(LockingMode.PESSIMISTIC);
      cfg.setL1CacheEnabled(false); // no L1 enabled
      cfg.setLockAcquisitionTimeout(100);
      cfg.setNumOwners(1);
      cfg.setSyncCommitPhase(true);
      cfg.setSyncRollbackPhase(true);
View Full Code Here
20
21
22
23
24
25
26
27
28
29
30
   EmbeddedCacheManager cm;

   @BeforeClass
   public void createCacheManager() {
      final Configuration defaultConfiguration = TestCacheManagerFactory.getDefaultConfiguration(true);
      defaultConfiguration.fluent().invocationBatching();
      defaultConfiguration.fluent().transaction().autoCommit(false);
      cm = TestCacheManagerFactory.createCacheManager(defaultConfiguration);
   }

   @AfterClass
View Full Code Here
21
22
23
24
25
26
27
28
29
30
31
   @BeforeClass
   public void createCacheManager() {
      final Configuration defaultConfiguration = TestCacheManagerFactory.getDefaultConfiguration(true);
      defaultConfiguration.fluent().invocationBatching();
      defaultConfiguration.fluent().transaction().autoCommit(false);
      cm = TestCacheManagerFactory.createCacheManager(defaultConfiguration);
   }

   @AfterClass
   public void destroyCacheManager() {
View Full Code Here
182
183
184
185
186
187
188
189
190
191
192
      }
   }

   private CacheContainer getContainerWithCacheLoader() {
      Configuration cfg = new Configuration();
      cfg.fluent().transaction().transactionMode(TransactionMode.TRANSACTIONAL);
      cfg.getCacheLoaderManagerConfig().addCacheLoaderConfig(csConfig);
      return TestCacheManagerFactory.createCacheManager(cfg);
   }

   private void assertCacheEntry(Cache cache, String key, String value, long lifespanMillis, long maxIdleMillis) {
View Full Code Here
20
21
22
23
24
25
26
27
28
29
30
public class InDoubtXidReturnedOnceTest extends MultipleCacheManagersTest {

   @Override
   protected void createCacheManagers() throws Throwable {
      Configuration configuration = getDefaultClusteredConfig(Configuration.CacheMode.DIST_SYNC, true);
      configuration.fluent().locking().useLockStriping(false);
      configuration.fluent().transaction()
         .transactionManagerLookupClass(RecoveryDummyTransactionManagerLookup.class)
         .recovery();
      configuration.fluent().clustering().hash().rehashEnabled(false);
      configuration.fluent().hash().numOwners(3);
View Full Code Here
21
22
23
24
25
26
27
28
29
30
31
   @Override
   protected void createCacheManagers() throws Throwable {
      Configuration configuration = getDefaultClusteredConfig(Configuration.CacheMode.DIST_SYNC, true);
      configuration.fluent().locking().useLockStriping(false);
      configuration.fluent().transaction()
         .transactionManagerLookupClass(RecoveryDummyTransactionManagerLookup.class)
         .recovery();
      configuration.fluent().clustering().hash().rehashEnabled(false);
      configuration.fluent().hash().numOwners(3);
      configuration.fluent().transaction().recovery();
View Full Code Here
24
25
26
27
28
29
30
31
32
33
34
      Configuration configuration = getDefaultClusteredConfig(Configuration.CacheMode.DIST_SYNC, true);
      configuration.fluent().locking().useLockStriping(false);
      configuration.fluent().transaction()
         .transactionManagerLookupClass(RecoveryDummyTransactionManagerLookup.class)
         .recovery();
      configuration.fluent().clustering().hash().rehashEnabled(false);
      configuration.fluent().hash().numOwners(3);
      configuration.fluent().transaction().recovery();

      createCluster(configuration, 4);
      waitForClusterToForm();
View Full Code Here
25
26
27
28
29
30
31
32
33
34
35
      configuration.fluent().locking().useLockStriping(false);
      configuration.fluent().transaction()
         .transactionManagerLookupClass(RecoveryDummyTransactionManagerLookup.class)
         .recovery();
      configuration.fluent().clustering().hash().rehashEnabled(false);
      configuration.fluent().hash().numOwners(3);
      configuration.fluent().transaction().recovery();

      createCluster(configuration, 4);
      waitForClusterToForm();
   }
View Full Code Here
26
27
28
29
30
31
32
33
34
35
36
      configuration.fluent().transaction()
         .transactionManagerLookupClass(RecoveryDummyTransactionManagerLookup.class)
         .recovery();
      configuration.fluent().clustering().hash().rehashEnabled(false);
      configuration.fluent().hash().numOwners(3);
      configuration.fluent().transaction().recovery();

      createCluster(configuration, 4);
      waitForClusterToForm();
   }
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.