Package org.mule.api.transaction

Examples of org.mule.api.transaction.TransactionException

30
31
32
33
34
35
36
37
38
39
40
            // Verify transaction has begun.
            Transaction currentTx = context.getCurrentTransaction();
            if (currentTx == null || !currentTx.isBegun())
            {   
                context.setStopFurtherProcessing(true);
                throw new TransactionException(MessageFactory.createStaticMessage("Trying to roll back transaction but no transaction is underway."));
            }           

            if (rollback)
            {
                // Mark the transaction for rollback.
View Full Code Here
47
48
49
50
51
52
53
54
55
                con.setAutoCommit(false);
            }
        }
        catch (SQLException e)
        {
            throw new TransactionException(DbMessages.transactionSetAutoCommitFailed(), e);
        }
        super.bindResource(key, resource);
    }
View Full Code Here
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
        {
            logger.warn(CoreMessages.commitTxButNoResource(this));
            return;
        }

        TransactionException transactionException = null;
        try
        {
            ((Connection) resource).commit();
        }
        catch (SQLException e)
        {
            transactionException = new TransactionException(CoreMessages.transactionCommitFailed(), e);
        }
        finally
        {
            closeConnection(transactionException);
        }
View Full Code Here
91
92
93
94
95
96
97
98
99
100
101
        {
            logger.warn(CoreMessages.rollbackTxButNoResource(this));
            return;
        }

        TransactionException transactionException = null;
        try
        {
            ((Connection) resource).rollback();
        }
        catch (SQLException e)
View Full Code Here
116
117
118
119
120
121
122
123
124
125
126
        }
        catch (SQLException e)
        {
            if (transactionException == null)
            {
                transactionException = new TransactionException(CoreMessages.createStaticMessage("Cannot close connection."), e);
            }
            else
            {
                logger.info("Cannot close connection.");
            }
View Full Code Here
73
74
75
76
77
78
79
80
81
82
83
        {
            ((Session) resource).commit();
        }
        catch (JMSException e)
        {
            throw new TransactionException(CoreMessages.transactionCommitFailed(), e);
        }
        finally
        {
            try
            {
View Full Code Here
106
107
108
109
110
111
112
113
114
115
116
            }
            ((Session) resource).rollback();
        }
        catch (JMSException e)
        {
            throw new TransactionException(CoreMessages.transactionRollbackFailed(), e);
        }
        finally
        {
            try
            {
View Full Code Here
89
90
91
92
93
94
95
96
97
98
99
    @Override
    public void bindResource(Object key, Object resource) throws TransactionException
    {
        if (!(this.delegate instanceof NullTransaction))
        {
            throw new TransactionException(CoreMessages.createStaticMessage("Single resource transaction has already a resource bound"));
        }
        TransactionFactory transactionFactory = muleContext.getTransactionFactoryManager().getTransactionFactoryFor(key.getClass());
        this.unbindTransaction();
        this.delegate = transactionFactory.beginTransaction(muleContext);
        delegate.bindResource(key, resource);
View Full Code Here
145
146
147
148
149
150
151
152
    @Test
    public void testCommitDoesntFailOnException() throws Exception
    {
        assertThat(tc.getTransaction(), IsNull.<Object>nullValue());
        Transaction tx = mock(Transaction.class);
        doThrow(new TransactionException((Throwable) null)).when(tx).commit();
        TransactionCoordination.getInstance().commitCurrentTransaction();
    }
View Full Code Here
187
188
189
190
191
192
193
194
    @Test
    public void testRollbackDoesntFailOnException() throws Exception
    {
        assertThat(tc.getTransaction(), IsNull.<Object>nullValue());
        Transaction tx = mock(Transaction.class);
        doThrow(new TransactionException((Throwable) null)).when(tx).rollback();
        TransactionCoordination.getInstance().rollbackCurrentTransaction();
    }
View Full Code Here
TOP

Related Classes of org.mule.api.transaction.TransactionException

  • es.twentymobile.mule.modules.jpa.xa.JpaXaResourceForTomcatAndOpenJpa
  • org.mule.construct.builder.BridgeBuilder
  • org.mule.module.db.internal.domain.transaction.DbTransaction
  • org.mule.module.db.internal.domain.xa.ConnectionWrapper
  • org.mule.processor.DelegateTransaction
  • org.mule.tck.functional.TransactionalFunctionalTestComponent
  • org.mule.transaction.ExternalXaTransaction
  • org.mule.transaction.TransactionCoordinationTestCase
  • org.mule.transaction.XaTransaction
  • org.mule.transaction.XaTransactionFactory
    • Copyright © 2018 www.massapicom. 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.