List of transaction() Examples

Examples of transaction()

com.alibaba.wasp.client.ClientProtocol.transaction()
com.spotify.helios.servicescommon.coordination.ZooKeeperClient.transaction()
org.apache.zookeeper.ZooKeeper.transaction()
A Transaction is a thin wrapper on the {@link #multi} methodwhich provides a builder object that can be used to construct and commit an atomic set of operations. @since 3.4.0 @return a Transaction builder object
org.cruxframework.crux.core.client.db.websql.SQLDatabase.transaction()
org.infinispan.config.FluentConfiguration.transaction()
org.infinispan.configuration.cache.Configuration.transaction()
org.infinispan.configuration.cache.ConfigurationBuilder.transaction()
org.switchyard.annotations.Requires.transaction()

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




      Configuration c = cm.getCacheConfiguration("transactional");
      assert !c.clustering().cacheMode().isClustered();
      assert c.transaction().transactionManagerLookup() instanceof GenericTransactionManagerLookup;
      assert c.transaction().useEagerLocking();
      assert c.transaction().eagerLockingSingleNode();
      assert !c.transaction().syncRollbackPhase();
      if (!deprecated) {
         assertReaperAndTimeoutInfo(defaultCfg);
      }

View Full Code Here

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


      Configuration c = cm.getCacheConfiguration("transactional");
      assert !c.clustering().cacheMode().isClustered();
      assert c.transaction().transactionManagerLookup() instanceof GenericTransactionManagerLookup;
      assert c.transaction().useEagerLocking();
      assert c.transaction().eagerLockingSingleNode();
      assert !c.transaction().syncRollbackPhase();
      if (!deprecated) {
         assertReaperAndTimeoutInfo(defaultCfg);
      }

View Full Code Here

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

      Configuration c = cm.getCacheConfiguration("transactional");
      assert !c.clustering().cacheMode().isClustered();
      assert c.transaction().transactionManagerLookup() instanceof GenericTransactionManagerLookup;
      assert c.transaction().useEagerLocking();
      assert c.transaction().eagerLockingSingleNode();
      assert !c.transaction().syncRollbackPhase();
      if (!deprecated) {
         assertReaperAndTimeoutInfo(defaultCfg);
      }


      c = cm.getCacheConfiguration("transactional2");

View Full Code Here

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

      if (!deprecated) {
         assertReaperAndTimeoutInfo(defaultCfg);
      }


      c = cm.getCacheConfiguration("transactional2");
      assert c.transaction().transactionManagerLookup() instanceof TestLookup;
      assert c.transaction().cacheStopTimeout() == 10000;
      assert c.transaction().lockingMode().equals(LockingMode.PESSIMISTIC);
      assert !c.transaction().autoCommit();


      c = cm.getCacheConfiguration("syncRepl");

View Full Code Here

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

         assertReaperAndTimeoutInfo(defaultCfg);
      }


      c = cm.getCacheConfiguration("transactional2");
      assert c.transaction().transactionManagerLookup() instanceof TestLookup;
      assert c.transaction().cacheStopTimeout() == 10000;
      assert c.transaction().lockingMode().equals(LockingMode.PESSIMISTIC);
      assert !c.transaction().autoCommit();


      c = cm.getCacheConfiguration("syncRepl");

View Full Code Here

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

      }


      c = cm.getCacheConfiguration("transactional2");
      assert c.transaction().transactionManagerLookup() instanceof TestLookup;
      assert c.transaction().cacheStopTimeout() == 10000;
      assert c.transaction().lockingMode().equals(LockingMode.PESSIMISTIC);
      assert !c.transaction().autoCommit();


      c = cm.getCacheConfiguration("syncRepl");


      assert c.clustering().cacheMode() == CacheMode.REPL_SYNC;

View Full Code Here

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


      c = cm.getCacheConfiguration("transactional2");
      assert c.transaction().transactionManagerLookup() instanceof TestLookup;
      assert c.transaction().cacheStopTimeout() == 10000;
      assert c.transaction().lockingMode().equals(LockingMode.PESSIMISTIC);
      assert !c.transaction().autoCommit();


      c = cm.getCacheConfiguration("syncRepl");


      assert c.clustering().cacheMode() == CacheMode.REPL_SYNC;
      assert !c.clustering().stateTransfer().fetchInMemoryState();

View Full Code Here

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

      assert !c.clustering().async().asyncMarshalling();
      assert !c.clustering().stateTransfer().fetchInMemoryState();


      c = cm.getCacheConfiguration("txSyncRepl");


      assert c.transaction().transactionManagerLookup() instanceof GenericTransactionManagerLookup;
      assert c.clustering().cacheMode() == CacheMode.REPL_SYNC;
      assert !c.clustering().stateTransfer().fetchInMemoryState();
      assert c.clustering().sync().replTimeout() == 15000;


      c = cm.getCacheConfiguration("overriding");

View Full Code Here

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

@Test(groups = "functional", testName = "query.indexedembedded.BooksExampleTest")
public class BooksExampleTest extends SingleCacheManagerTest {


   protected EmbeddedCacheManager createCacheManager() throws Exception {
      ConfigurationBuilder cfg = getDefaultStandaloneCacheConfig(true);
      cfg
         .transaction()
            .transactionMode(TransactionMode.TRANSACTIONAL)
         .indexing()
            .enable()
            .indexLocalOnly(false)

View Full Code Here

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

public class DynamicPropertiesTest extends SingleCacheManagerTest {


   @Override
   protected EmbeddedCacheManager createCacheManager() throws Exception {
      ConfigurationBuilder cfg = getDefaultStandaloneCacheConfig(true);
      cfg
         .transaction()
            .transactionMode(TransactionMode.TRANSACTIONAL)
         .indexing()
            .enable()
            .indexLocalOnly(false)

View Full Code Here

0 1 2 3 4 5

TOP

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.