Examples of registerProcess()

Examples of org.hibernate.engine.ActionQueue.registerProcess()

95
96
97
98
99
100
101
102
103
104
105
             */
      final ActionQueue actionQueue = eventSource.getActionQueue();
      boolean isLocal = isLocalTransaction();
      if ( isLocal ) {
        //if local tx never use Synchronization
        actionQueue.registerProcess( new DelegateToSynchronizationOnBeforeTx( synchronization ) );
      }
      else {
        //TODO could we remove the action queue registration in this case?
        actionQueue.registerProcess( new DelegateToSynchronizationOnBeforeTx( synchronization ) );
        eventSource.getTransaction().registerSynchronization(
View Full Code Here

Examples of org.hibernate.engine.ActionQueue.registerProcess()

99
100
101
102
103
104
105
106
107
108
109
        //if local tx never use Synchronization
        actionQueue.registerProcess( new DelegateToSynchronizationOnBeforeTx( synchronization ) );
      }
      else {
        //TODO could we remove the action queue registration in this case?
        actionQueue.registerProcess( new DelegateToSynchronizationOnBeforeTx( synchronization ) );
        eventSource.getTransaction().registerSynchronization(
            new BeforeCommitSynchronizationDelegator( synchronization )
        );
      }
View Full Code Here

Examples of org.hibernate.engine.ActionQueue.registerProcess()

106
107
108
109
110
111
112
113
114
115
116
            new BeforeCommitSynchronizationDelegator( synchronization )
        );
      }

      //executed in all environments
      actionQueue.registerProcess( new DelegateToSynchronizationOnAfterTx( synchronization ) );
    }
    else {
      //registerSynchronization is only called if isRealTransactionInProgress or if
      // a flushListener was found; still we might need to find the listener again
      // as it might have been cleared by serialization (is transient).
View Full Code Here

Examples of org.hibernate.engine.ActionQueue.registerProcess()

81
82
83
84
85
86
87
88
89
90
91
  public void registerSynchronization(Synchronization synchronization) {
    if ( isRealTransactionInProgress() ) {
      //use {Before|After}TransactionCompletionProcess instead of registerTransaction because it does not
      //swallow transactions.
      final ActionQueue actionQueue = eventSource.getActionQueue();
      actionQueue.registerProcess( new DelegateToSynchronizationOnBeforeTx( synchronization ) );
      actionQueue.registerProcess( new DelegateToSynchronizationOnAfterTx( synchronization ) );
//      eventSource.getTransaction().registerSynchronization( synchronization );
    }
    else {
      //registerSynchronization is only called if isRealTransactionInProgress or if
View Full Code Here

Examples of org.hibernate.engine.ActionQueue.registerProcess()

82
83
84
85
86
87
88
89
90
91
92
    if ( isRealTransactionInProgress() ) {
      //use {Before|After}TransactionCompletionProcess instead of registerTransaction because it does not
      //swallow transactions.
      final ActionQueue actionQueue = eventSource.getActionQueue();
      actionQueue.registerProcess( new DelegateToSynchronizationOnBeforeTx( synchronization ) );
      actionQueue.registerProcess( new DelegateToSynchronizationOnAfterTx( synchronization ) );
//      eventSource.getTransaction().registerSynchronization( synchronization );
    }
    else {
      //registerSynchronization is only called if isRealTransactionInProgress or if
      // a flushListener was found; still we might need to find the listener again
View Full Code Here

Examples of org.hibernate.engine.ActionQueue.registerProcess()

92
93
94
95
96
97
98
99
100
101
102
             * In a JTA env, the before transaction completion is called before the flush, so not all changes are yet
             * written. However, Synchronization-s do propagate exceptions, so they can be safely used.
             */

      final ActionQueue actionQueue = eventSource.getActionQueue();
      actionQueue.registerProcess( new DelegateToSynchronizationOnBeforeTx( synchronization ) );
      eventSource.getTransaction().registerSynchronization(
          new BeforeCommitSynchronizationDelegator( synchronization )
      );

      //executed in all environments
View Full Code Here

Examples of org.hibernate.engine.ActionQueue.registerProcess()

98
99
100
101
102
103
104
105
106
107
108
      eventSource.getTransaction().registerSynchronization(
          new BeforeCommitSynchronizationDelegator( synchronization )
      );

      //executed in all environments
      actionQueue.registerProcess( new DelegateToSynchronizationOnAfterTx( synchronization ) );
    }
    else {
      //registerSynchronization is only called if isRealTransactionInProgress or if
      // a flushListener was found; still we might need to find the listener again
      // as it might have been cleared by serialization (is transient).
View Full Code Here

Examples of org.hibernate.engine.ActionQueue.registerProcess()

94
95
96
97
98
99
100
101
102
103
104
             */
      final ActionQueue actionQueue = eventSource.getActionQueue();
      boolean isLocal = isLocalTransaction();
      if ( isLocal ) {
        //if local tx never use Synchronization
        actionQueue.registerProcess( new DelegateToSynchronizationOnBeforeTx( synchronization ) );
      }
      else {
        //TODO could we remove the action queue registration in this case?
        actionQueue.registerProcess( new DelegateToSynchronizationOnBeforeTx( synchronization ) );
        eventSource.getTransaction().registerSynchronization(
View Full Code Here

Examples of org.hibernate.engine.ActionQueue.registerProcess()

98
99
100
101
102
103
104
105
106
107
108
        //if local tx never use Synchronization
        actionQueue.registerProcess( new DelegateToSynchronizationOnBeforeTx( synchronization ) );
      }
      else {
        //TODO could we remove the action queue registration in this case?
        actionQueue.registerProcess( new DelegateToSynchronizationOnBeforeTx( synchronization ) );
        eventSource.getTransaction().registerSynchronization(
            new BeforeCommitSynchronizationDelegator( synchronization )
        );
      }
View Full Code Here

Examples of org.hibernate.engine.ActionQueue.registerProcess()

105
106
107
108
109
110
111
112
113
114
115
            new BeforeCommitSynchronizationDelegator( synchronization )
        );
      }

      //executed in all environments
      actionQueue.registerProcess( new DelegateToSynchronizationOnAfterTx( synchronization ) );
    }
    else {
      //registerSynchronization is only called if isRealTransactionInProgress or if
      // a flushListener was found; still we might need to find the listener again
      // as it might have been cleared by serialization (is transient).
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.