Examples of transaction()

Examples of org.infinispan.configuration.cache.ConfigurationBuilder.transaction()

96
97
98
99
100
101
102
103
104
105
106
      }
   }

   private ConfigurationBuilder configuration() {
      ConfigurationBuilder configurationBuilder = getDefaultClusteredCacheConfig(CacheMode.REPL_SYNC, true);
      configurationBuilder.transaction()
            .transactionMode(TransactionMode.TRANSACTIONAL)
            .lockingMode(LockingMode.OPTIMISTIC)
            .locking().lockAcquisitionTimeout(100l)
            .isolationLevel(IsolationLevel.REPEATABLE_READ).writeSkewCheck(true)
            .versioning().enable().scheme(VersioningScheme.SIMPLE)
View Full Code Here

Examples of org.infinispan.configuration.cache.ConfigurationBuilder.transaction()

53
54
55
56
57
58
59
60
61
62
63
            .stateTransfer().timeout(180000).fetchInMemoryState(true)
            .hash().numOwners(1);

      // transactions

      cb.transaction()
            .transactionMode(TransactionMode.TRANSACTIONAL)
            .lockingMode(LockingMode.PESSIMISTIC)
            .syncCommitPhase(true)
            .syncRollbackPhase(true);
View Full Code Here

Examples of org.infinispan.configuration.cache.ConfigurationBuilder.transaction()

91
92
93
94
95
96
97
98
99
100
101
   protected ConfigurationBuilder buildConfiguration() {
      ConfigurationBuilder configuration = getDefaultClusteredCacheConfig(sync ? CacheMode.DIST_SYNC : CacheMode.DIST_ASYNC, tx);
      configuration.clustering().stateTransfer().fetchInMemoryState(performRehashing);
      if (lockingMode != null) {
         configuration.transaction().lockingMode(lockingMode);
      }
      configuration.clustering().hash().numOwners(numOwners);
      if (!testRetVals) {
         configuration.unsafe().unreliableReturnValues(true);
         // we also need to use repeatable read for tests to work when we dont have reliable return values, since the
View Full Code Here

Examples of org.infinispan.configuration.cache.ConfigurationBuilder.transaction()

105
106
107
108
109
110
111
112
113
114
115
   }

   @Test
   public void testDummyTMGetCache() throws Exception {
      ConfigurationBuilder cb = new ConfigurationBuilder();
      cb.transaction().use1PcForAutoCommitTransactions(true)
            .transactionManagerLookup(new DummyTransactionManagerLookup());
      withCacheManager(new CacheManagerCallable(createCacheManager()) {
         @Override
         public void call() {
            cm.getCache();
View Full Code Here

Examples of org.infinispan.configuration.cache.ConfigurationBuilder.transaction()

32
33
34
35
36
37
38
39
40
41
42
@Test(groups = "functional", testName = "api.SimpleConditionalOperationsWriteSkewTest")
public class SimpleConditionalOperationsWriteSkewTest extends MultipleCacheManagersTest {

   protected ConfigurationBuilder getConfig() {
      ConfigurationBuilder dcc = getDefaultClusteredCacheConfig(CacheMode.DIST_SYNC, true);
      dcc.transaction().locking().writeSkewCheck(true);
      dcc.transaction().locking().isolationLevel(IsolationLevel.REPEATABLE_READ);
      dcc.transaction().versioning().enable().scheme(VersioningScheme.SIMPLE);
      return dcc;
   }
View Full Code Here

Examples of org.infinispan.configuration.cache.ConfigurationBuilder.transaction()

33
34
35
36
37
38
39
40
41
42
43
public class SimpleConditionalOperationsWriteSkewTest extends MultipleCacheManagersTest {

   protected ConfigurationBuilder getConfig() {
      ConfigurationBuilder dcc = getDefaultClusteredCacheConfig(CacheMode.DIST_SYNC, true);
      dcc.transaction().locking().writeSkewCheck(true);
      dcc.transaction().locking().isolationLevel(IsolationLevel.REPEATABLE_READ);
      dcc.transaction().versioning().enable().scheme(VersioningScheme.SIMPLE);
      return dcc;
   }

   @Override
View Full Code Here

Examples of org.infinispan.configuration.cache.ConfigurationBuilder.transaction()

161
162
163
164
165
166
167
168
169
170
171
   }

   @Test(expectedExceptions = IllegalStateException.class)
   public void testInvocationBatchingAndNonTransactional() throws Exception {
      ConfigurationBuilder cb = new ConfigurationBuilder();
      cb.transaction()
            .transactionMode(NON_TRANSACTIONAL)
            .invocationBatching()
            .enable();
      withCacheManager(new CacheManagerCallable(createCacheManager(cb)));
   }
View Full Code Here

Examples of org.infinispan.configuration.cache.ConfigurationBuilder.transaction()

34
35
36
37
38
39
40
41
42
43
44
   protected ConfigurationBuilder getConfig() {
      ConfigurationBuilder dcc = getDefaultClusteredCacheConfig(CacheMode.DIST_SYNC, true);
      dcc.transaction().locking().writeSkewCheck(true);
      dcc.transaction().locking().isolationLevel(IsolationLevel.REPEATABLE_READ);
      dcc.transaction().versioning().enable().scheme(VersioningScheme.SIMPLE);
      return dcc;
   }

   @Override
   protected void createCacheManagers() throws Throwable {
View Full Code Here

Examples of org.infinispan.configuration.cache.ConfigurationBuilder.transaction()

36
37
38
39
40
41
42
43
44
45
46
public abstract class BaseAtomicHashMapAPITest extends MultipleCacheManagersTest {

   @Override
   protected void createCacheManagers() throws Throwable {
      ConfigurationBuilder configurationBuilder = getDefaultClusteredCacheConfig(CacheMode.REPL_SYNC, true);
      configurationBuilder.transaction()
            .transactionMode(TransactionMode.TRANSACTIONAL).transactionManagerLookup(new DummyTransactionManagerLookup())
            .lockingMode(LockingMode.PESSIMISTIC)
            .locking().lockAcquisitionTimeout(100l);
      createClusteredCaches(2, "atomic", configurationBuilder);
   }
View Full Code Here

Examples of org.infinispan.configuration.cache.ConfigurationBuilder.transaction()

96
97
98
99
100
101
102
103
104
105
106
      }
   }

   private ConfigurationBuilder configuration() {
      ConfigurationBuilder configurationBuilder = getDefaultClusteredCacheConfig(CacheMode.DIST_SYNC, true);
      configurationBuilder.transaction()
            .transactionMode(TransactionMode.TRANSACTIONAL)
            .lockingMode(LockingMode.OPTIMISTIC)
            .locking().lockAcquisitionTimeout(100l)
            .isolationLevel(IsolationLevel.REPEATABLE_READ).writeSkewCheck(true)
            .versioning().enable().scheme(VersioningScheme.SIMPLE)
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.