Package javax.transaction

Examples of javax.transaction.Synchronization.afterCompletion()

317
318
319
320
321
322
323
324
325
326
327
    tmControl.replay();
    type.nullSafeSet(ps, content, 1);
    Synchronization synch = transaction.getSynchronization();
    assertNotNull(synch);
    synch.beforeCompletion();
    synch.afterCompletion(Status.STATUS_COMMITTED);
    tmControl.verify();
  }

  public void testBlobStringTypeWithJtaSynchronizationAndRollback() throws Exception {
    MockControl tmControl = MockControl.createControl(TransactionManager.class);
View Full Code Here
346
347
348
349
350
351
352
353
354
355
356
    assertEquals(content, type.nullSafeGet(rs, new String[] {"column"}, null));
    tmControl.replay();
    type.nullSafeSet(ps, content, 1);
    Synchronization synch = transaction.getSynchronization();
    assertNotNull(synch);
    synch.afterCompletion(Status.STATUS_ROLLEDBACK);
    tmControl.verify();
  }

  public void testBlobByteArrayType() throws Exception {
    byte[] content = "content".getBytes();
View Full Code Here
407
408
409
410
411
412
413
414
415
416
417
    tmControl.replay();
    type.nullSafeSet(ps, content, 1);
    Synchronization synch = transaction.getSynchronization();
    assertNotNull(synch);
    synch.beforeCompletion();
    synch.afterCompletion(Status.STATUS_COMMITTED);
    tmControl.verify();
  }

  public void testBlobByteArrayTypeWithJtaSynchronizationAndRollback() throws Exception {
    MockControl tmControl = MockControl.createControl(TransactionManager.class);
View Full Code Here
435
436
437
438
439
440
441
442
443
444
445
    assertEquals(content, type.nullSafeGet(rs, new String[] {"column"}, null));
    tmControl.replay();
    type.nullSafeSet(ps, content, 1);
    Synchronization synch = transaction.getSynchronization();
    assertNotNull(synch);
    synch.afterCompletion(Status.STATUS_ROLLEDBACK);
    tmControl.verify();
  }

  public void testBlobSerializableType() throws Exception {
    ByteArrayOutputStream baos = new ByteArrayOutputStream();
View Full Code Here
529
530
531
532
533
534
535
536
537
538
539
    tmControl.replay();
    type.nullSafeSet(ps, "content", 1);
    Synchronization synch = transaction.getSynchronization();
    assertNotNull(synch);
    synch.beforeCompletion();
    synch.afterCompletion(Status.STATUS_COMMITTED);
    tmControl.verify();
  }

  public void testBlobSerializableTypeWithJtaSynchronizationAndRollback() throws Exception {
    MockControl tmControl = MockControl.createControl(TransactionManager.class);
View Full Code Here
566
567
568
569
570
571
572
573
574
575
576
    assertEquals("content", type.nullSafeGet(rs, new String[] {"column"}, null));
    tmControl.replay();
    type.nullSafeSet(ps, "content", 1);
    Synchronization synch = transaction.getSynchronization();
    assertNotNull(synch);
    synch.afterCompletion(Status.STATUS_ROLLEDBACK);
    tmControl.verify();
  }

  public void testHbm2JavaStyleInitialization() throws Exception {
    rsControl.reset();
View Full Code Here
532
533
534
535
536
537
538
539
540
541
542
            }
        }
        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
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
99
100
101
102
103
104
105
106
107
108
109
        // commit
        for (Synchronization synchronization : synchronizations) {
            synchronization.beforeCompletion();
        }
        for (Synchronization synchronization : synchronizations) {
            synchronization.afterCompletion(Status.STATUS_COMMITTED);
        }
        synchronizations.clear();

        when(transactionSynchronizationRegistry.getTransactionKey()).thenReturn("TX2");
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
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.