Examples of registerSynchronization()

Examples of javax.transaction.Transaction.registerSynchronization()

78
79
80
81
82
83
84
85
86
87
88
    if ( currentSession == null ) {
      currentSession = buildOrObtainSession();

      try {
        txn.registerSynchronization( buildCleanupSynch( txn ) );
      }
      catch ( Throwable t ) {
        try {
          currentSession.close();
        }
View Full Code Here

Examples of javax.transaction.Transaction.registerSynchronization()

109
110
111
112
113
114
115
116
117
118
119
    if ( currentSession == null ) {
      currentSession = buildOrObtainSession();

      try {
        txn.registerSynchronization( buildCleanupSynch( txnIdentifier ) );
      }
      catch ( Throwable t ) {
        try {
          currentSession.close();
        }
View Full Code Here

Examples of javax.transaction.Transaction.registerSynchronization()

65
66
67
68
69
70
71
72
73
74
75
      cache.put("/one/two/three", "key1", "val1");
      numLocks = cache.getNumberOfLocksHeld();
      assertEquals(4, numLocks);

      // we register *second*
      tx.registerSynchronization(new Synchronization()
      {

         public void beforeCompletion()
         {
            try
View Full Code Here

Examples of javax.transaction.Transaction.registerSynchronization()

119
120
121
122
123
124
125
126
127
128
129
      cache.put("/one/two/three", "key1", "val1");
      numLocks = cache.getNumberOfLocksHeld();
      assertEquals(4, numLocks);

      // we register *second*
      tx.registerSynchronization(new Synchronization()
      {

         public void beforeCompletion()
         {
         }
View Full Code Here

Examples of javax.transaction.Transaction.registerSynchronization()

86
87
88
89
90
91
92
93
94
95
96
      cacheB.put("/1/A/I", "2", "B");
      cacheB.put("/EXISTS", "KEY", "B");

      Object monitor = new Object();
      HangSync sync = new HangSync(monitor);
      tx.registerSynchronization(sync);

      Thread t = new Thread()
      {
         public void run()
         {
View Full Code Here

Examples of javax.transaction.Transaction.registerSynchronization()

348
349
350
351
352
353
354
355
356
357
358
      System.out.println("cache1 (before commit):\n" + CachePrinter.printCacheLockingInfo(cache1));
      System.out.println("cache2 (before commit):\n" + CachePrinter.printCacheLockingInfo(cache2));

      // this will rollback the transaction
      Transaction tx = tm.getTransaction();
      tx.registerSynchronization(new TransactionAborter(tx));

      try
      {
         tm.commit();
         fail("commit should throw a RollbackException, we should not get here");
View Full Code Here

Examples of javax.transaction.Transaction.registerSynchronization()

1214
1215
1216
1217
1218
1219
1220
1221
1222
1223
1224
            {
               Transaction tx = callbackTM.getTransaction();
               if (tx != null && tx.getStatus() == Status.STATUS_ACTIVE)
               {
                  // this will rollback the transaction
                  tx.registerSynchronization(new TransactionAborter(tx));
               }
               else
               {
                  super.nodeModified(ne);
               }
View Full Code Here

Examples of javax.transaction.Transaction.registerSynchronization()

85
86
87
88
89
90
91
92
93
94
95
      TransactionManager tm = cache.getConfiguration().getRuntimeConfig().getTransactionManager();

      tm.begin();
      Transaction tx = tm.getTransaction();
      UpdateTimestampsSynchronization sync = new UpdateTimestampsSynchronization(ENTITY_TYPE_FQN, cache, tm);
      tx.registerSynchronization(sync);

      Fqn fqn = Fqn.fromRelativeFqn(REGION_PREFIX_FQN, ENTITY_TYPE_FQN);
      fqn = Fqn.fromRelativeElements(fqn, "1");
      cache.put(fqn, ITEM, "value");
View Full Code Here

Examples of javax.transaction.Transaction.registerSynchronization()

95
96
97
98
99
100
101
102
103
104
105
            assertNotNull("TransactionManager not null", tm);

            Transaction tx = tm.getTransaction();
            assertNotNull("Transaction not null", tx);

            tx.registerSynchronization(txObj);

            txObj.setMessage("Donate $1.000.000");
            assertNull("Uncommited message null", txObj.getMessage());

            userTx.commit();
View Full Code Here

Examples of javax.transaction.Transaction.registerSynchronization()

719
720
721
722
723
724
725
726
727
728
729
    private void registerSynchronization(Synchronization synchronization) {
        try {
            final Transaction tx = this.getTransaction();
            // register for lifecycle events of transaction
            tx.registerSynchronization(synchronization);
        } catch (RollbackException e) {
            throw new EJBException(e);
        } catch (SystemException e) {
            throw new EJBException(e);
        }
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.