Examples of versioning()

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

225
226
227
228
229
230
231
232
233
234
235
            builder.transaction().transactionProtocol(TransactionProtocol.TOTAL_ORDER);
         }
         builder.locking().isolationLevel(IsolationLevel.REPEATABLE_READ).writeSkewCheck(writeSkew);
         builder.clustering().hash().numOwners(1);
         if (writeSkew) {
            builder.versioning().enable().scheme(VersioningScheme.SIMPLE);
         }
         builder.transaction().recovery().disable();
         builder.customInterceptors().addInterceptor().interceptor(new ExtendedStatisticInterceptor())
               .position(InterceptorConfiguration.Position.FIRST);
         addClusterEnabledCacheManager(builder);
View Full Code Here

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

201
202
203
204
205
206
207
208
209
210
211
      for (int i = 0; i < clusterSize; ++i) {
         ConfigurationBuilder builder = getDefaultClusteredCacheConfig(cacheMode, true);
         builder.customInterceptors().addInterceptor()
               .before(TxInterceptor.class)
               .interceptor(new CacheUsageInterceptor());
         builder.versioning().enabled(true).scheme(VersioningScheme.SIMPLE);
         builder.transaction().syncCommitPhase(true).syncRollbackPhase(true);
         builder.locking().isolationLevel(IsolationLevel.REPEATABLE_READ).writeSkewCheck(true).lockAcquisitionTimeout(100);
         addClusterEnabledCacheManager(builder);
      }
      waitForClusterToForm();
View Full Code Here

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

113
114
115
116
117
118
119
120
121
122
123
         builder.locking().isolationLevel(IsolationLevel.REPEATABLE_READ).writeSkewCheck(true)
               .lockAcquisitionTimeout(1000);
         builder.transaction().recovery().disable();
         builder.transaction().lockingMode(LockingMode.OPTIMISTIC);
         builder.deadlockDetection().enable();
         builder.versioning().enable().scheme(VersioningScheme.SIMPLE);
         extendedStatisticInterceptors[i] = new ExtendedStatisticInterceptor();
         builder.customInterceptors().addInterceptor().interceptor(extendedStatisticInterceptors[i])
               .after(TxInterceptor.class);
         addClusterEnabledCacheManager(builder);
      }
View Full Code Here

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

248
249
250
251
252
253
254
255
256
257
258
      cb.clustering().hash().numSegments(0);
   }

   public void testEnableVersioning() {
      ConfigurationBuilder builder = new ConfigurationBuilder();
      builder.versioning().enable();
      org.infinispan.config.Configuration adapt =
            LegacyConfigurationAdaptor.adapt(builder.build());
      assert adapt.isEnableVersioning();
   }
View Full Code Here

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

314
315
316
317
318
319
320
321
322
323
324
            .syncRollbackPhase(syncCommit);
      dcc.locking().isolationLevel(IsolationLevel.REPEATABLE_READ).writeSkewCheck(writeSkew);
      dcc.transaction().useSynchronization(useSynchronization);
      dcc.clustering().hash().numOwners(2);
      if (writeSkew) {
         dcc.versioning().enable().scheme(VersioningScheme.SIMPLE);
      }
      dcc.transaction().recovery().disable();
      createCluster(dcc, clusterSize);
      waitForClusterToForm();
      for (int i = 0; i < clusterSize; ++i) {
View Full Code Here

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

144
145
146
147
148
149
150
151
152
153
154
   protected final void createCacheManagers() throws Throwable {
      ConfigurationBuilder builder = getDefaultClusteredCacheConfig(cacheMode(), true);
      builder.locking()
            .isolationLevel(IsolationLevel.REPEATABLE_READ)
            .writeSkewCheck(true);
      builder.versioning()
            .enabled(true)
            .scheme(VersioningScheme.SIMPLE);
      builder.clustering().hash().numSegments(60);
      amendConfiguration(builder);
      createClusteredCaches(4, builder);
View Full Code Here

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

45
46
47
48
49
50
51
52
53
54
55
   @Override
   protected void createCacheManagers() throws Throwable {
      ConfigurationBuilder dcc = getDefaultClusteredCacheConfig(mode, true);
      dcc.transaction().syncCommitPhase(syncCommit).syncRollbackPhase(syncCommit);
      dcc.locking().isolationLevel(IsolationLevel.REPEATABLE_READ).writeSkewCheck(true);
      dcc.versioning().enable().scheme(VersioningScheme.SIMPLE);
      createCluster(dcc, clusterSize);
      waitForClusterToForm();
   }

   public void testPutIfAbsent() {
View Full Code Here

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

48
49
50
51
52
53
54
55
56
57
58
            .writeSkewCheck(true);
      builder.transaction()
            .lockingMode(LockingMode.OPTIMISTIC);
      builder.clustering().hash()
            .numOwners(2);
      builder.versioning()
            .enable()
            .scheme(VersioningScheme.SIMPLE);
      createClusteredCaches(3, builder);
   }
View Full Code Here

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

212
213
214
215
216
217
218
219
220
221
222
      cb.clustering().hash().numSegments(0);
   }

   public void testEnableVersioning() {
      ConfigurationBuilder builder = new ConfigurationBuilder();
      builder.versioning().enable();
      assert builder.build().versioning().enabled();
   }

   public void testNoneIsolationLevel() {
      ConfigurationBuilder builder = new ConfigurationBuilder();
View Full Code Here

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

216
217
218
219
220
221
222
223
224
225
226
      cb.clustering().hash().numSegments(0);
   }

   public void testEnableVersioning() {
      ConfigurationBuilder builder = new ConfigurationBuilder();
      builder.versioning().enable();
      assert builder.build().versioning().enabled();
   }

   public void testNoneIsolationLevel() {
      ConfigurationBuilder builder = new ConfigurationBuilder();
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.