Examples of bindResource()


Examples of org.mule.api.transaction.Transaction.bindResource()

//            {
//                logger.debug("Binding VM queue session " + session + " to current transaction " + tx);
//            }
            try
            {
                tx.bindResource(queueManager, session);
            }
            catch (TransactionException e)
            {
                throw new RuntimeException("Could not bind queue session to current transaction", e);
            }
View Full Code Here

Examples of org.mule.api.transaction.Transaction.bindResource()

        if (tx != null)
        {
            logger.debug("Binding connection " + con + " to current transaction: " + tx);
            try
            {
                tx.bindResource(dataSource, con);
            }
            catch (TransactionException e)
            {
                JdbcUtils.close(con);
                throw new RuntimeException("Could not bind connection to current transaction: " + tx, e);
View Full Code Here

Examples of org.mule.api.transaction.Transaction.bindResource()

            Session session;
            Transaction tx = TransactionCoordination.getInstance().getTransaction();
            if (this.reuseSession && ctx.session != null)
            {
                session = ctx.session;
                tx.bindResource(this.connector.getConnection(), session);
            }
            else
            {
                session = this.connector.getSession(endpoint);
                if (session != null && tx != null)
View Full Code Here

Examples of org.mule.api.transaction.Transaction.bindResource()

                {
                    // Get Transaction & Bind MuleSession
                    Transaction tx = TransactionCoordination.getInstance().getTransaction();
                    if (tx != null)
                    {
                        tx.bindResource(connector.getConnection(), session);
                    }
                    if (tx instanceof JmsClientAcknowledgeTransaction)
                    {
                        tx.bindResource(message, message);
                    }
View Full Code Here

Examples of org.mule.api.transaction.Transaction.bindResource()

                    {
                        tx.bindResource(connector.getConnection(), session);
                    }
                    if (tx instanceof JmsClientAcknowledgeTransaction)
                    {
                        tx.bindResource(message, message);
                    }

                    if (logger.isDebugEnabled())
                    {
                        logger.debug("Message received it is of type: " +
View Full Code Here

Examples of org.mule.api.transaction.Transaction.bindResource()

        if (tx != null)
        {
            logger.debug("Binding session " + session + " to current transaction " + tx);
            try
            {
                tx.bindResource(connection, session);
            }
            catch (TransactionException e)
            {
                closeQuietly(session);
                throw new RuntimeException("Could not bind session to current transaction", e);
View Full Code Here

Examples of org.mule.api.transaction.Transaction.bindResource()

            r = new JpaXaResource(entityManager);
          }
        } else {
          r = entityManager;
        }
        tx.bindResource(entityManagerFactory, r);
      } catch (TransactionException e) {
        throw new RuntimeException("Could not bind connection to current transaction", e);
      }
    }
    return entityManager;
View Full Code Here

Examples of org.mule.api.transaction.Transaction.bindResource()

            else
            {
                Object connectionResource = this.createOperationResource(endpoint);
                if (currentTx.supports(this.getOperationResourceFactory(),connectionResource))
                {
                    currentTx.bindResource(this.getOperationResourceFactory(), connectionResource);
                }
                else if (endpoint.getTransactionConfig().isTransacted())
                {
                    throw new TransactionException(CoreMessages.createStaticMessage("Endpoint is transactional but transaction does not support it"));
                }
View Full Code Here

Examples of org.mule.api.transaction.Transaction.bindResource()

                {
                    // Get Transaction & Bind MuleSession
                    Transaction tx = TransactionCoordination.getInstance().getTransaction();
                    if (tx != null)
                    {
                        tx.bindResource(connector.getConnection(), ReusableSessionWrapperFactory.createWrapper(session));
                    }
                    if (tx instanceof JmsClientAcknowledgeTransaction)
                    {
                        tx.bindResource(message, message);
                    }
View Full Code Here

Examples of org.mule.api.transaction.Transaction.bindResource()

                    {
                        tx.bindResource(connector.getConnection(), ReusableSessionWrapperFactory.createWrapper(session));
                    }
                    if (tx instanceof JmsClientAcknowledgeTransaction)
                    {
                        tx.bindResource(message, message);
                    }

                    if (logger.isDebugEnabled())
                    {
                        logger.debug("Message received it is of type: " +
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.