Package javax.transaction

Examples of javax.transaction.UserTransaction.commit()

212
213
214
215
216
217
218
219
220
221
222
        // check we rolled back the state changes from the 3rd insert
        ut = (UserTransaction) new InitialContext().lookup( "java:comp/UserTransaction" );
        ut.begin();
        ksession.fireAllRules();
        ut.commit();
        assertEquals( 2,
                      list.size() );

        // insert and commit
        ut = (UserTransaction) new InitialContext().lookup( "java:comp/UserTransaction" );
View Full Code Here
221
222
223
224
225
226
227
228
229
230
231
        // insert and commit
        ut = (UserTransaction) new InitialContext().lookup( "java:comp/UserTransaction" );
        ut.begin();
        ksession.insert( 3 );
        ksession.insert( 4 );
        ut.commit();

        // rollback again, this is testing that we can do consecutive rollbacks and commits without issue
        ut = (UserTransaction) new InitialContext().lookup( "java:comp/UserTransaction" );
        ut.begin();
        ksession.insert( 5 );
View Full Code Here
242
243
244
245
246
247
248
249
250
251
252
       
        ut = (UserTransaction) new InitialContext().lookup( "java:comp/UserTransaction" );
        ut.begin();
        ksession.insert( 7 );
        ksession.insert( 8 );
        ut.commit();

        ksession.fireAllRules();

        assertEquals( 6,
                      list.size() );
View Full Code Here
91
92
93
94
95
96
97
98
99
100
101
            out.println("WR1 sees " + thisIsWhatTx1Sees + "<br>");
            System.out.println("WR1 sees " + thisIsWhatTx1Sees);
            out.println("WR2 sees this before commit" + thisIsWhatTx2Sees + "<br>");
            System.out.println("WR2 sees this before commit " + thisIsWhatTx2Sees);

            tx.commit();
           
            thisIsWhatTx2Sees = wr2.getMethodDataAsString(HOST+"/file1");
            out.println("WR2 sees this after commit " + thisIsWhatTx2Sees + "<br>");
            System.out.println("WR2 sees this after commit " + thisIsWhatTx2Sees);
           
View Full Code Here
216
217
218
219
220
221
222
223
224
225
226
            log.warn("begin");
            tx.begin();
            log.warn("put");
            srcCache.put("/Node", Boolean.FALSE, Boolean.TRUE);
            log.warn("commit");
            tx.commit();
            log.warn("leave");
         }
         catch (Exception e)
         {
            log.error("caught exception " + e, e);
View Full Code Here
347
348
349
350
351
352
353
354
355
356
357
                     {
                     }
                     return;
                  }
               }
               tx.commit();
               if (checkAndSetState())
               {
                  return;
               }
               time = System.currentTimeMillis() - time;
View Full Code Here
133
134
135
136
137
138
139
140
141
142
143
                     dst++;
               }

               tx.begin();
               HashMap<Object, Integer> accounts = getAccounts();// read lock on NODE
               tx.commit();// releases read lock

               int sum = sumAccounts(accounts);
               log(anz + ": " + accounts + " Summe: " + sum);
               // the sum of all accounts always has to be 3000
               if (sum != 3000)
View Full Code Here
149
150
151
152
153
154
155
156
157
158
159
               try
               {
                  tx.begin();
                  deposit(customer[src], customer[dst], amo, tx);// gets write lock
                  tx.commit();// releases write lock
                  again = false;
               }
               catch (TimeoutException timeout_ex)
               {
                  System.out.println("transaction is rolled back, will try again (ex=" + timeout_ex.getClass() + ")");
View Full Code Here
95
96
97
98
99
100
101
102
103
104
105
     */
    @Test
    public void testEmptyTxCommit() throws Exception {
        final UserTransaction userTransaction = EJBClient.getUserTransaction(nodeName);
        userTransaction.begin();
        userTransaction.commit();
    }

    /**
     * Tests a empty begin()/rollback()
     *
 
View Full Code Here
137
138
139
140
141
142
143
144
145
146
147
        final CMTRemote cmtRemoteBean = EJBClient.createProxy(cmtRemoteBeanLocator);

        final UserTransaction userTransaction = EJBClient.getUserTransaction(nodeName);
        userTransaction.begin();
        cmtRemoteBean.mandatoryTxOp();
        userTransaction.commit();
    }

    /**
     * Tests various possibilities with a user initiated UserTransaction and subsequent bean invocations
     *
 
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.