Package org.infinispan.commands.tx

Examples of org.infinispan.commands.tx.RollbackCommand

72
73
74
75
76
77
78
79
80
81
82
            break;
         case CommitCommand.METHOD_ID:
            command = new CommitCommand();
            break;
         case RollbackCommand.METHOD_ID:
            command = new RollbackCommand();
            break;
         case MultipleRpcCommand.COMMAND_ID:
            command = new MultipleRpcCommand();
            break;
         case SingleRpcCommand.COMMAND_ID:
View Full Code Here
119
120
121
122
123
124
125
   public CommitCommand buildCommitCommand(GlobalTransaction gtx) {
      return new CommitCommand(gtx);
   }

   public RollbackCommand buildRollbackCommand(GlobalTransaction gtx) {
      return new RollbackCommand(gtx);
   }
View Full Code Here
222
223
224
225
226
227
228
229
230
      commitCommand.setCacheName(cacheName);
      return commitCommand;
   }

   public RollbackCommand buildRollbackCommand(GlobalTransaction gtx) {
      RollbackCommand rollbackCommand = new RollbackCommand(gtx);
      rollbackCommand.setCacheName(cacheName);
      return rollbackCommand;
   }
View Full Code Here
301
302
303
304
305
306
307
308
309
310
311
312
313
            CommitCommand commitCommand = (CommitCommand) c;
            commitCommand.init(interceptorChain, icc, txTable);
            commitCommand.markTransactionAsRemote(isRemote);
            break;
         case RollbackCommand.COMMAND_ID:
            RollbackCommand rollbackCommand = (RollbackCommand) c;
            rollbackCommand.init(interceptorChain, icc, txTable);
            rollbackCommand.markTransactionAsRemote(isRemote);
            break;
         case ClearCommand.COMMAND_ID:
            ClearCommand cc = (ClearCommand) c;
            cc.init(notifier);
            break;
View Full Code Here
199
200
201
202
203
204
205
206
207
      commitCommand.setCacheName(cacheName);
      return commitCommand;
   }

   public RollbackCommand buildRollbackCommand(GlobalTransaction gtx) {
      RollbackCommand rollbackCommand = new RollbackCommand(gtx);
      rollbackCommand.setCacheName(cacheName);
      return rollbackCommand;
   }
View Full Code Here
278
279
280
281
282
283
284
285
286
287
288
289
290
            CommitCommand commitCommand = (CommitCommand) c;
            commitCommand.init(interceptorChain, icc, txTable);
            commitCommand.markTransactionAsRemote(isRemote);
            break;
         case RollbackCommand.COMMAND_ID:
            RollbackCommand rollbackCommand = (RollbackCommand) c;
            rollbackCommand.init(interceptorChain, icc, txTable);
            rollbackCommand.markTransactionAsRemote(isRemote);
            break;
         case ClearCommand.COMMAND_ID:
            ClearCommand cc = (ClearCommand) c;
            cc.init(notifier);
            break;
View Full Code Here
187
188
189
190
191
192
193
194
195
196
197
198
199
200
                        log.trace("%s global transactions pertain to leavers list %s and need to be killed", toKill.size(), leavers);
                  }

                  for (GlobalTransaction gtx : toKill) {
                     if (trace) log.trace("Killing %s", gtx);
                     RollbackCommand rc = new RollbackCommand(gtx);
                     rc.init(invoker, icc, TransactionTable.this);
                     try {
                        rc.perform(null);
                        if (trace) log.trace("Rollback of %s complete.", gtx);
                     } catch (Throwable e) {
                        log.warn("Unable to roll back gtx " + gtx, e);
                     } finally {
                        removeRemoteTransaction(gtx);
View Full Code Here
132
133
134
135
136
137
138
139
140
141
142
   }

   public static void rollbackImpl(Xid xid, CommandsFactory commandsFactory, InvocationContextContainer icc, InterceptorChain invoker, TransactionTable txTable) throws XAException {
      LocalTransaction localTransaction = getLocalTransactionAndValidateImpl(xid, txTable);
      if (trace) log.trace("rollback transaction %s ", localTransaction.getGlobalTransaction());
      RollbackCommand rollbackCommand = commandsFactory.buildRollbackCommand(localTransaction.getGlobalTransaction());
      LocalTxInvocationContext ctx = icc.createTxInvocationContext();
      ctx.setLocalTransaction(localTransaction);
      try {
         invoker.invoke(ctx, rollbackCommand);
      } catch (Throwable e) {
View Full Code Here
223
224
225
226
227
228
229
230
231
232
233
      throw new XAException(XAException.XA_HEURRB); //this is a heuristic rollback
   }

   private void rollbackInternal(LocalTransaction localTransaction) throws Throwable {
      if (trace) log.tracef("rollback transaction %s ", localTransaction.getGlobalTransaction());
      RollbackCommand rollbackCommand = commandsFactory.buildRollbackCommand(localTransaction.getGlobalTransaction());
      LocalTxInvocationContext ctx = icc.createTxInvocationContext();
      ctx.setLocalTransaction(localTransaction);
      invoker.invoke(ctx, rollbackCommand);
      txTable.removeLocalTransaction(localTransaction);
   }
View Full Code Here
134
135
136
137
138
139
140
141
142
143
144
145
146
147
            }

            // if the transaction doesn't touch local keys any more, we can roll it back
            if (!txHasLocalKeys) {
               log.tracef("Killing remote transaction without any local keys %s", gtx);
               RollbackCommand rc = new RollbackCommand(cacheName, gtx);
               rc.init(invoker, transactionTable.icc, transactionTable);
               try {
                  rc.perform(null);
                  log.tracef("Rollback of transaction %s complete.", gtx);
               } catch (Throwable e) {
                  log.unableToRollbackGlobalTx(gtx, e);
               } finally {
                  transactionTable.removeRemoteTransaction(gtx);
View Full Code Here
TOP

Related Classes of org.infinispan.commands.tx.RollbackCommand

  • org.infinispan.commands.CommandsFactoryImpl
  • org.infinispan.commands.RemoteCommandFactory
  • org.infinispan.commands.RemoteCommandsFactory
  • org.infinispan.interceptors.TxInterceptor
  • org.infinispan.marshall.jboss.JBossMarshallerTest
  • org.infinispan.marshall.MarshallersTest
  • org.infinispan.marshall.VersionAwareMarshallerTest
  • org.infinispan.transaction.impl.TransactionCoordinator
  • org.infinispan.transaction.impl.TransactionTable
  • org.infinispan.transaction.StaleTransactionCleanupService
    • Copyright © 2018 www.massapicom. 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.