com.arjuna.ats.jta.TransactionManager类的使用及代码示例

x33g5p2x  于2022-01-30 转载在 其他  
字(8.9k)|赞(0)|评价(0)|浏览(171)

本文整理了Java中com.arjuna.ats.jta.TransactionManager类的一些代码示例，展示了TransactionManager类的具体用法。这些代码示例主要来源于Github/Stackoverflow/Maven等平台，是从一些精选项目中提取出来的代码，具有较强的参考意义，能在一定程度帮忙到你。TransactionManager类的具体详情如下：
包路径：com.arjuna.ats.jta.TransactionManager
类名称：TransactionManager

TransactionManager介绍

暂无

代码示例

代码示例来源：origin: kiegroup/drools

  1. final TransactionManager tm = com.arjuna.ats.jta.TransactionManager.transactionManager();
  2. final TransactionSynchronizationRegistry tsr =
  3.     jtaPropertyManager.getJTAEnvironmentBean().getTransactionSynchronizationRegistry();
  4. sanitizedPoolingProperties.setProperty("username", driverProperties.getProperty("user"));
  5. sanitizedPoolingProperties.setProperty("password", driverProperties.getProperty("password"));

代码示例来源：origin: org.jboss.jbossts/jbossjta

  1. protected final boolean transactionRunning() throws SQLException
  2. {
  3.   try
  4.   {
  5.     if (com.arjuna.ats.jta.TransactionManager.transactionManager()
  6.         .getTransaction() != null)
  7.     {
  8.       return true;
  9.     }
  10.     else
  11.     {
  12.       return false;
  13.     }
  14.   }
  15.   catch (Exception e)
  16.   {
  17.     SQLException sqlException = new SQLException(e.toString());
  18.     sqlException.initCause(e);
  19.     throw sqlException;
  20.   }
  21. }

代码示例来源：origin: org.jbpm/jbpm-test

  1. @Deprecated
  2. public static StatefulKnowledgeSession loadStatefulKnowledgeSession(KieBase kbase, int sessionId) {
  3.   Properties properties = getProperties();
  4.   String persistenceEnabled = properties.getProperty("persistence.enabled", "false");
  5.   RuntimeEnvironmentBuilder builder = null;
  6.   if ("true".equals(persistenceEnabled)) {
  7.     String dialect = properties.getProperty("persistence.persistenceunit.dialect", "org.hibernate.dialect.H2Dialect");
  8.     Map<String, String> map = new HashMap<String, String>();
  9.     map.put("hibernate.dialect", dialect);
  10.     EntityManagerFactory emf = Persistence.createEntityManagerFactory(properties.getProperty("persistence.persistenceunit.name", "org.jbpm.persistence.jpa"), map);
  11.     
  12.     
  13.     builder = RuntimeEnvironmentBuilder.Factory.get()
  14.         .newDefaultBuilder()
  15.       .entityManagerFactory(emf)                
  16.       .addEnvironmentEntry(EnvironmentName.TRANSACTION_MANAGER, com.arjuna.ats.jta.TransactionManager.transactionManager());
  17.   } else {            
  18.     builder = RuntimeEnvironmentBuilder.Factory.get()
  19.         .newDefaultInMemoryBuilder();
  20.   }
  21.   builder.knowledgeBase(kbase);
  22.   RuntimeManager manager = RuntimeManagerFactory.Factory.get().newSingletonRuntimeManager(builder.get());
  23.   return (StatefulKnowledgeSession) manager.getRuntimeEngine(EmptyContext.get()).getKieSession();
  24. }

代码示例来源：origin: org.mule.modules/mule-module-jbossts

  1. props.setProperty(PROPERTY_ENVIRONMENT_OBJECTSTORE_DIR, objectStoreDir);
  2. props.setProperty(PROPERTY_OBJECTSTORE_DIR, objectStoreDir);
  3. props.setProperty(PROPERTY_USER_DIR, muleInternalDir);
  4. tm = com.arjuna.ats.jta.TransactionManager.transactionManager();

代码示例来源：origin: jbosstm/narayana

  1. @Test
  2.   public void test() throws Exception
  3.   {
  4.     javax.transaction.TransactionManager transactionManager = com.arjuna.ats.jta.TransactionManager.transactionManager();
  6.     transactionManager.begin();
  8.     Transaction currentTrans = transactionManager.getTransaction();
  10.     TestResource res1, res2;
  11.     currentTrans.enlistResource( res1 = new TestResource() );
  12.     currentTrans.enlistResource( res2 = new TestResource() );
  14.     currentTrans.delistResource( res2, XAResource.TMSUCCESS );
  15.     currentTrans.delistResource( res1, XAResource.TMSUCCESS );
  17.     transactionManager.commit();
  18.   }
  19. }

代码示例来源：origin: org.jboss.jbossts.jta/narayana-jta

  1. .transactionManager();
  2. javax.transaction.Transaction tx = tm.getTransaction();
  3.     if (!tx.delistResource(xares, XAResource.TMSUCCESS))
  4.       throw new SQLException(
  5.           jdbcLogger.i18NLogger.get_delisterror());
  6.         tx.registerSynchronization(new ConnectionSynchronization(_theConnection, _recoveryConnection));
  7.     throw new SQLException(jdbcLogger.i18NLogger.get_closeerrorinvalidtx(tx.toString()));
  8. SQLException sqlException = new SQLException(jdbcLogger.i18NLogger.get_closeerror());
  9. sqlException.initCause(e1);
  10. throw sqlException;

代码示例来源：origin: org.nuiton.wikitty/wikitty-jdbc-impl

  1. try {
  2.   TransactionManager transactionManager =
  3.       com.arjuna.ats.jta.TransactionManager.transactionManager();
  4.       for(Entry<Object, Object> properties : conf.getFlatOptions().entrySet()) {
  5.         String propertyName = (String) properties.getKey();
  6.         if (propertyName.startsWith(

代码示例来源：origin: jbosstm/narayana

  1. @Test
  2.   public void test() throws Exception
  3.   {
  4.     javax.transaction.TransactionManager tm = com.arjuna.ats.jta.TransactionManager.transactionManager();
  6.     tm.begin();
  8.     javax.transaction.Transaction theTransaction = tm.getTransaction();
  10.     assertEquals(Status.STATUS_ACTIVE, theTransaction.getStatus());
  12.     theTransaction.rollback();
  14.     assertEquals(Status.STATUS_ROLLEDBACK, theTransaction.getStatus());
  16.     assertEquals(Status.STATUS_ROLLEDBACK, tm.getStatus());
  18.     theTransaction = tm.suspend();
  20.     assertEquals(Status.STATUS_NO_TRANSACTION, tm.getStatus());
  22.     tm.resume(theTransaction);
  24.     assertEquals(Status.STATUS_ROLLEDBACK, tm.getStatus());
  26.     tm.suspend();
  27.   }
  28. }

代码示例来源：origin: jbosstm/narayana

  1. @Test
  2. public void test() throws Exception {
  3.   javax.transaction.TransactionManager tm = com.arjuna.ats.jta.TransactionManager
  4.       .transactionManager();
  5.   tm.begin();
  6.   javax.transaction.Transaction theTransaction = tm.getTransaction();
  7.   assertTrue(theTransaction.enlistResource(new XARMERRXAResource(false)));
  8.   XARMERRXAResource rollbackCalled = new XARMERRXAResource(true);
  9.   assertTrue(theTransaction.enlistResource(rollbackCalled));
  10.   tm.rollback();
  11.   assertTrue(rollbackCalled.getRollbackCalled());
  12. }

代码示例来源：origin: jbosstm/narayana

  1. @Test
  2.   public void test() throws Exception
  3.   {
  4.     javax.transaction.TransactionManager tm = com.arjuna.ats.jta.TransactionManager.transactionManager();
  6.     tm.begin();
  8.     javax.transaction.Transaction theTransaction = tm.getTransaction();
  10.     tm.commit();
  12.     tm.resume(theTransaction);
  13.   }
  14. }

代码示例来源：origin: kiegroup/jbpm

  1. com.arjuna.ats.jta.TransactionManager.transactionManager().begin();
  2. try { 
  3.   EntityManager em = getEmf().createEntityManager();
  4.   query.executeUpdate();
  5.   com.arjuna.ats.jta.TransactionManager.transactionManager().commit();
  6. } catch( Throwable t ) { 
  7.   com.arjuna.ats.jta.TransactionManager.transactionManager().rollback();

代码示例来源：origin: kiegroup/jbpm

  1. @After
  2. public void tearDown() throws Exception {
  3.   javax.transaction.TransactionManager txm = com.arjuna.ats.jta.TransactionManager.transactionManager();
  4.   assertTrue("There is still a transaction running!", txm.getTransaction() == null );
  5.   
  6.   cleanUp(context);
  7. }

代码示例来源：origin: kiegroup/jbpm

  1. Transaction tx = com.arjuna.ats.jta.TransactionManager.transactionManager()
  2.     .getTransaction();
  3. if (tx != null) {
  4.   int testTxState = tx.getStatus();
  5.   if (testTxState != Status.STATUS_NO_TRANSACTION
  6.       && testTxState != Status.STATUS_ROLLEDBACK
  7.       && testTxState != Status.STATUS_COMMITTED) {
  8.     try {
  9.       tx.rollback();
  10.     } catch (Throwable t) {

代码示例来源：origin: jbosstm/narayana

  1. @Test
  2.   public void test() throws Exception
  3.   {
  4.     TransactionManager tm = com.arjuna.ats.jta.TransactionManager.transactionManager();
  6.     tm.begin();
  8.     Transaction tx = tm.getTransaction();
  10.     tx.commit();
  12.     assertEquals(Status.STATUS_COMMITTED, tm.getStatus());
  14.     try {
  15.       tm.begin();
  17.       fail("Begin call completed successfully - this shouldn't have happened");
  18.     }
  19.     catch (NotSupportedException e)
  20.     {
  21.       System.out.println("NotSupportedException \""+e.getMessage()+"\" occurred this is expected and correct");
  22.     }
  23.   }
  24. }

代码示例来源：origin: jbosstm/narayana

  1. @Test
  2.   public void test() throws Exception
  3.   {
  4.     for (int i = 0; i < 1000; i++)
  5.     {
  6.       javax.transaction.TransactionManager tm = com.arjuna.ats.jta.TransactionManager.transactionManager();
  8.       tm.begin();
  10.       tm.getTransaction().rollback();
  12.       tm.suspend();
  13.     }
  14.   }
  15. }

代码示例来源：origin: jbosstm/narayana

  1. @Test
  2. public void test() throws Exception
  3. {
  4.   TransactionManager tm = com.arjuna.ats.jta.TransactionManager.transactionManager();
  5.   tm.begin();
  6.   Transaction tx = tm.suspend();
  7.   tm.begin();
  8.   tx.commit();
  9.   tm.commit();
  10. }

代码示例来源：origin: jbosstm/narayana

  1. @Test
  2.   public void test() throws Exception
  3.   {
  4.     javax.transaction.TransactionManager transactionManager = com.arjuna.ats.jta.TransactionManager.transactionManager();
  6.     transactionManager.setTransactionTimeout(3);
  8.     transactionManager.begin();
  10.     Thread.currentThread().sleep(4000);
  12.     try
  13.     {
  14.       transactionManager.commit();
  15.     }
  16.     catch (final javax.transaction.RollbackException ex)
  17.     {
  18.       // expected
  19.     }
  20.   }
  21. }

代码示例来源：origin: jbosstm/narayana

  1. @Test
  2.   public void test() throws Exception
  3.   {
  4.     javax.transaction.TransactionManager transactionManager = com.arjuna.ats.jta.TransactionManager.transactionManager();
  6.     transactionManager.setTransactionTimeout(3);
  8.     transactionManager.begin();
  10.     Thread.currentThread().sleep(4000);
  12.     transactionManager.rollback();
  13.   }
  14. }

代码示例来源：origin: jbosstm/narayana

  1. @Test
  2.   public void testDisabled () throws Exception
  3.   {
  4.     jtaPropertyManager.getJTAEnvironmentBean().setSupportSubtransactions(false);
  6.     javax.transaction.TransactionManager transactionManager = com.arjuna.ats.jta.TransactionManager.transactionManager();
  8.     transactionManager.begin();
  10.     try
  11.     {
  12.       transactionManager.begin();
  14.       fail();
  15.     }
  16.     catch (final NotSupportedException ex)
  17.     {
  18.     }
  20.     transactionManager.commit();
  21.   }
  22. }

代码示例来源：origin: org.jboss.jbossts/jbosstxbridge

  1. /**
  2.  * Disassociate the JTA transaction from the current Thread.
  3.  * Typically used by a server side outbound handler.
  4.  *
  5.  * @throws XAException
  6.  * @throws SystemException
  7.  * @throws InvalidTransactionException
  8.  */
  9. public void stop() throws XAException, SystemException, InvalidTransactionException
  10. {
  11.   txbridgeLogger.logger.trace("InboundBridge.stop("+xid+")");
  12.   TransactionManager.transactionManager().suspend();
  13. }

内容来源于网络，如有侵权，请联系作者删除！

transactionmanager

相关文章

    查看更多

    热门标签

    更多
    JavaquerypythonNode开发语言requestUtil数据库Table后端算法LoggerMessageElementParser

    最新文章

    更多

    TransactionManager类方法

    • 蜀ICP备13028337号-1 大数据知识库 https://www.saoniuhuo.com © All rights reserved
    • 本站内容来源互联网,如果侵犯您的权益请联系我们删除, 联系方式：448109455@qq.com