Examples of registerSynchronization()

Examples of javax.transaction.Transaction.registerSynchronization()

61
62
63
64
65
66
67
68
69
70
71
    public void destroyInstance(T instance) {
        final Transaction tx = this.getCurrentTransaction();
        if ((tx != null) && TxUtils.isActive(tx)) {
            try {
                // A transaction is in progress, so register a Synchronization so that the session can be destroyed on tx completion.
                tx.registerSynchronization(new DestroySynchronization<T>(this.factory, instance));
            } catch (RollbackException e) {
                throw EjbMessages.MESSAGES.failedToRegisterTransactionSynchronization(e);
            } catch (SystemException e) {
                throw EjbMessages.MESSAGES.failedToRegisterTransactionSynchronization(e);
            }
View Full Code Here

Examples of javax.transaction.Transaction.registerSynchronization()

59
60
61
62
63
64
65
66
67
68
69
       
        if(transaction != null)
        {
            if (phase.equals(TransactionPhase.AFTER_COMPLETION))
            {
                transaction.registerSynchronization(new AfterCompletion(observer, event, metadata));
            }
            else if (phase.equals(TransactionPhase.AFTER_SUCCESS))
            {
                transaction.registerSynchronization(new AfterCompletionSuccess(observer, event, metadata));
            }
View Full Code Here

Examples of javax.transaction.Transaction.registerSynchronization()

63
64
65
66
67
68
69
70
71
72
73
            {
                transaction.registerSynchronization(new AfterCompletion(observer, event, metadata));
            }
            else if (phase.equals(TransactionPhase.AFTER_SUCCESS))
            {
                transaction.registerSynchronization(new AfterCompletionSuccess(observer, event, metadata));
            }
            else if (phase.equals(TransactionPhase.AFTER_FAILURE))
            {
                transaction.registerSynchronization(new AfterCompletionFailure(observer, event, metadata));
            }
View Full Code Here

Examples of javax.transaction.Transaction.registerSynchronization()

67
68
69
70
71
72
73
74
75
76
77
            {
                transaction.registerSynchronization(new AfterCompletionSuccess(observer, event, metadata));
            }
            else if (phase.equals(TransactionPhase.AFTER_FAILURE))
            {
                transaction.registerSynchronization(new AfterCompletionFailure(observer, event, metadata));
            }
            else if (phase.equals(TransactionPhase.BEFORE_COMPLETION))
            {
                transaction.registerSynchronization(new BeforeCompletion(observer, event, metadata));
            }
View Full Code Here

Examples of javax.transaction.Transaction.registerSynchronization()

71
72
73
74
75
76
77
78
79
80
81
            {
                transaction.registerSynchronization(new AfterCompletionFailure(observer, event, metadata));
            }
            else if (phase.equals(TransactionPhase.BEFORE_COMPLETION))
            {
                transaction.registerSynchronization(new BeforeCompletion(observer, event, metadata));
            }
            else
            {
                throw new IllegalStateException(WebBeansLoggerFacade.getTokenString(OWBLogConst.EXCEPT_0007) + phase);
            }           
View Full Code Here

Examples of javax.transaction.Transaction.registerSynchronization()

67
68
69
70
71
72
73
74
75
76
77
  public void addTransactionListener(TransactionState transactionState, final TransactionListener transactionListener) {
    Transaction transaction = getTransaction();
    CommandContext commandContext = Context.getCommandContext();   
    try {
      transaction.registerSynchronization(new TransactionStateSynchronization(transactionState, transactionListener, commandContext));
    } catch (IllegalStateException e) {
      throw new ProcessEngineException("IllegalStateException while registering synchronization ", e);
    } catch (RollbackException e) {
      throw new ProcessEngineException("RollbackException while registering synchronization ", e);
    } catch (SystemException e) {
View Full Code Here

Examples of org.apache.geronimo.transaction.context.TransactionContext.registerSynchronization()

240
241
242
243
244
245
246
247
248
249
250
    }

    void registerSynchronization(Synchronization sync) throws RollbackException, SystemException {
        TransactionContext transactionContext = transactionContextManager.getContext();
        if (transactionContext != null && transactionContext.isInheritable() && transactionContext.isActive()) {
            transactionContext.registerSynchronization(sync);
        } else {
            sync.beforeCompletion();
            sync.afterCompletion(Status.STATUS_COMMITTED);
        }
    }
View Full Code Here

Examples of org.apache.geronimo.transaction.manager.TransactionImpl.registerSynchronization()

57
58
59
60
61
62
63
64
65
66
67
        if (entityManagerWrapper == null) {
            EntityManager entityManager = createEntityManager();
            entityManagerWrapper = new EntityManagerWrapperTxScoped(entityManager);
            transactionManager.putResource(persistenceUnit, entityManagerWrapper);
            try {
                transaction.registerSynchronization(entityManagerWrapper);
            } catch (javax.transaction.RollbackException e) {
                throw (TransactionRequiredException) new TransactionRequiredException("No active transaction").initCause(e);
            } catch (SystemException e) {
                throw (TransactionRequiredException) new TransactionRequiredException("No active transaction").initCause(e);
            }
View Full Code Here

Examples of org.apache.openejb.core.transaction.TransactionPolicy.registerSynchronization()

815
816
817
818
819
820
821
822
823
824
825
        }

        SessionSynchronizationCoordinator coordinator = (SessionSynchronizationCoordinator) txPolicy.getResource(SessionSynchronizationCoordinator.class);
        if (coordinator == null) {
            coordinator = new SessionSynchronizationCoordinator(txPolicy);
            txPolicy.registerSynchronization(coordinator);
            txPolicy.putResource(SessionSynchronizationCoordinator.class, coordinator);
        }

        // SessionSynchronization are only enabled for beans after CREATE that are not bean-managed and implement the SessionSynchronization interface
        boolean synchronize = callContext.getCurrentOperation() != Operation.CREATE &&
View Full Code Here

Examples of org.apache.openejb.core.transaction.TransactionPolicy.registerSynchronization()

917
918
919
920
921
922
923
924
925
926
927
        }

        SessionSynchronizationCoordinator coordinator = (SessionSynchronizationCoordinator) txPolicy.getResource(SessionSynchronizationCoordinator.class);
        if (coordinator == null) {
            coordinator = new SessionSynchronizationCoordinator(txPolicy);
            txPolicy.registerSynchronization(coordinator);
            txPolicy.putResource(SessionSynchronizationCoordinator.class, coordinator);
        }

        // SessionSynchronization are only enabled for beans after CREATE that are not bean-managed and implement the SessionSynchronization interface
        boolean synchronize = callContext.getCurrentOperation() != Operation.CREATE &&
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.