Package javax.transaction

Examples of javax.transaction.Synchronization.afterCompletion()

212
213
214
215
216
217
218
219
220
221
222
      if ( synchronization != null ) {
        //first cleanup
        flushSynch.remove( session );
        log.debug( "flush event causing index update out of transaction" );
        synchronization.beforeCompletion();
        synchronization.afterCompletion( Status.STATUS_COMMITTED );
      }
    }
  }

  /**
 
View Full Code Here
248
249
250
251
252
253
254
255
256
257
258
      if ( synchronization != null ) {
        //first cleanup
        flushSynch.remove( session );
        log.debug( "flush event causing index update out of transaction" );
        synchronization.beforeCompletion();
        synchronization.afterCompletion( Status.STATUS_COMMITTED );
      }
    }
  }

  /**
 
View Full Code Here
200
201
202
203
204
205
206
207
208
209
210
    public void afterCompletion(int status)
    { 
        for ( int i=0; i<pmSyncs.size(); i++ ) {
            Synchronization sync = (Synchronization)pmSyncs.elementAt(i);
            try {
                sync.afterCompletion(status);
            } catch ( Exception ex ) {
                _logger.log(Level.SEVERE, "ejb.after_completion_error", ex);
            }
        }
View Full Code Here
232
233
234
235
236
237
238
239
240
241
242
        for ( Iterator iter = timerSyncs.values().iterator();
              iter.hasNext(); ) {
            Synchronization timerSync = (Synchronization) iter.next();
            try {
                timerSync.afterCompletion(status);
            } catch ( Exception ex ) {
                _logger.log(Level.SEVERE, "ejb.after_completion_error", ex);
            }
        }
View Full Code Here
489
490
491
492
493
494
495
496
497
498
499
    private void afterCompletion() {
        // this does not synchronize because nothing can modify our state at this time
        for (Iterator i = syncList.iterator(); i.hasNext();) {
            Synchronization synch = (Synchronization) i.next();
            try {
                synch.afterCompletion(status);
            } catch (Exception e) {
                log.warn("Unexpected exception from afterCompletion; continuing", e);
                continue;
            }
        }
View Full Code Here
141
142
143
144
145
146
147
148
149
150
151
            // Interposed Syncs First and then the regular syncs
            Enumeration e1 = interposedSyncs.elements();
            while (e1.hasMoreElements()) {
                Synchronization sync = (Synchronization) e1.nextElement();
                try {
                    sync.afterCompletion(result);
                } catch (Exception ex) {
          _logger.log(Level.WARNING,
              "jts.unexpected_error_occurred_in_after_completion",ex);
                }
            }
View Full Code Here
151
152
153
154
155
156
157
158
159
160
161
            }
            Enumeration e = syncs.elements();
            while (e.hasMoreElements()) {
                Synchronization sync = (Synchronization) e.nextElement();
                try {
                    sync.afterCompletion(result);
                } catch (Exception ex) {
          _logger.log(Level.WARNING,
              "jts.unexpected_error_occurred_in_after_completion",ex);
                }
            }
View Full Code Here
203
204
205
206
207
208
209
210
211
212
213
   public void afterCompletion(int status)
   {
      if (this.getDatabaseManager() instanceof Synchronization)
      {
         Synchronization dbManager = (Synchronization) this.getDatabaseManager();
         dbManager.afterCompletion(status);
      }

   }

   /**
 
View Full Code Here
159
160
161
162
163
164
165
166
167
168
169
    if ( synchronization != null ) {
      //first cleanup
      flushSynch.remove( session );
      log.debug( "flush event causing index update out of transaction" );
      synchronization.beforeCompletion();
      synchronization.afterCompletion( Status.STATUS_COMMITTED );
    }
  }

  public SearchFactoryImplementor getSearchFactoryImplementor() {
    return searchFactoryImplementor;
View Full Code Here
285
286
287
288
289
290
291
292
293
294
295
      if ( synchronization != null ) {
        //first cleanup
        flushSynch.remove( session );
        log.debug( "flush event causing index update out of transaction" );
        synchronization.beforeCompletion();
        synchronization.afterCompletion( Status.STATUS_COMMITTED );
      }
    }
  }

  /**
 
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.