Examples of registerSynchronization()

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

757
758
759
760
761
762
763
764
765
766
767
        }

        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 sessionSynchronization = callContext.getCurrentOperation() != Operation.CREATE &&
View Full Code Here

Examples of org.hibernate.Transaction.registerSynchronization()

51
52
53
54
55
56
57
58
59
60
61
        if (verSync == null) {
            // No worries about registering a transaction twice - a transaction is single thread
            verSync = new AuditSync(this, session, revisionInfoGenerator);
            auditSyncs.put(transaction, verSync);

            transaction.registerSynchronization(verSync);
        }

        return verSync;
    }
View Full Code Here

Examples of org.hibernate.ejb.transaction.JoinableCMTTransaction.registerSynchronization()

465
466
467
468
469
470
471
472
473
474
475
            throw new AssertionFailure( "Transaction MARKED_FOR_JOINED after isOpen() call" );
          }
          //flush before completion and
          //register clear on rollback
          log.trace( "Adding flush() and close() synchronization" );
          joinableCMTTransaction.registerSynchronization(
              new Synchronization() {
                public void beforeCompletion() {
                  boolean flush = false;
                  TransactionFactory.Context ctx = null;
                  try {
View Full Code Here

Examples of org.hibernate.ejb.transaction.JoinableCMTTransaction.registerSynchronization()

838
839
840
841
842
843
844
845
846
847
848
            throw new AssertionFailure( "Transaction MARKED_FOR_JOINED after isOpen() call" );
          }
          //flush before completion and
          //register clear on rollback
          log.trace( "Adding flush() and close() synchronization" );
          joinableCMTTransaction.registerSynchronization(
              new Synchronization() {
                public void beforeCompletion() {
                  boolean flush = false;
                  TransactionFactory.Context ctx = null;
                  try {
View Full Code Here

Examples of org.hibernate.engine.transaction.jta.platform.spi.JtaPlatform.registerSynchronization()

250
251
252
253
254
255
256
257
258
259
260
    if ( !transactionFactory().isJoinableJtaTransaction( this, currentHibernateTransaction ) ) {
      LOG.trace( "TransactionFactory reported no JTA transaction to join; skipping Synchronization registration" );
      return;
    }

    jtaPlatform.registerSynchronization( new RegisteredSynchronization( getSynchronizationCallbackCoordinator() ) );
    getSynchronizationCallbackCoordinator().synchronizationRegistered();
    synchronizationRegistered = true;
    LOG.debug( "successfully registered Synchronization" );
  }
View Full Code Here

Examples of org.hibernate.service.jta.platform.spi.JtaPlatform.registerSynchronization()

244
245
246
247
248
249
250
251
252
253
254
    if ( ! transactionFactory().isJoinableJtaTransaction( this, currentHibernateTransaction ) ) {
      LOG.trace( "TransactionFactory reported no JTA transaction to join; skipping Synchronization registration" );
      return;
    }

    jtaPlatform.registerSynchronization( new RegisteredSynchronization( getSynchronizationCallbackCoordinator() ) );
    synchronizationRegistered = true;
    LOG.debug( "successfully registered Synchronization" );
  }

  @Override
View Full Code Here

Examples of org.jboss.seam.transaction.SeamTransaction.registerSynchronization()

127
128
129
130
131
132
133
134
135
136
137
      {
         synchronizationRegistered = true;
         transaction.enlist(delegate);
         try
         {
            transaction.registerSynchronization(this);
         }
         catch (Exception e)
         {
            // synchronizationRegistered =
            // PersistenceProvider.instance().registerSynchronization(this,
View Full Code Here

Examples of org.jboss.seam.transaction.SeamTransaction.registerSynchronization()

162
163
164
165
166
167
168
169
170
171
172
      if (transaction.isActive())
      {
         delegate.isOpen();
         try
         {
            transaction.registerSynchronization(this);
            synchronizationRegistered = true;
         }
         catch (Exception e)
         {
            throw new RuntimeException(e);
View Full Code Here

Examples of org.jboss.seam.transaction.UserTransaction.registerSynchronization()

120
121
122
123
124
125
126
127
128
129
130
      if ( transaction.isActive() )
      {
         transaction.enlist(entityManager);
         try
         {
            transaction.registerSynchronization(this);
            synchronizationRegistered = true;
         }
         catch (Exception e)
         {
            synchronizationRegistered = PersistenceProvider.instance().registerSynchronization(this, entityManager);
View Full Code Here

Examples of org.jboss.soa.esb.common.TransactionStrategy.registerSynchronization()

232
233
234
235
236
237
238
239
240
241
242
                if (!transactionStrategy.isActive())
                {
                    throw new JMSException("No active transaction") ;
                }
               
                transactionStrategy.registerSynchronization(this) ;
                setSuspect(true) ;
                final XAResource resource = xaSessionDelegate.getXAResource() ;
                transactionStrategy.enlistResource(resource) ;
            }
            catch (final TransactionStrategyException tse)
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.