Examples of RollbackCommand

com.aragost.javahg.commands.RollbackCommand
Command class for executing hg rollback. Set flags from {@link RollbackCommandFlags} and call the{@link #execute} method.
me.taylorkelly.bigbrother.commands.RollbackCommand
org.apache.axis2.clustering.configuration.commands.RollbackCommand
org.infinispan.commands.tx.RollbackCommand
Command corresponding to a transaction rollback. @author Manik Surtani (manik@jboss.org) @since 4.0
org.jboss.cache.commands.tx.RollbackCommand
The rollback phase of a 2-phase commit. @author Mircea.Markus@jboss.com @since 2.2
org.locationtech.udig.project.internal.commands.edit.RollbackCommand
A command that rollsback current changes. @author jgarnett @since 0.6.0
uk.co.oliwali.HawkEye.commands.RollbackCommand
Rolls back actions according to the player's specified input. Error handling for user input is done using exceptions to keep code neat. @author oliverw92

Examples of org.infinispan.commands.tx.RollbackCommand

            log.tracef("%s global transactions pertain to leavers list %s and need to be killed", toKill.size(), leavers);
      }


      for (GlobalTransaction gtx : toKill) {
         if (trace) log.tracef("Killing remote transaction originating on leaver %s", gtx);
         RollbackCommand rc = new RollbackCommand(gtx);
         rc.init(invoker, icc, TransactionTable.this);
         try {
            rc.perform(null);
            if (trace) log.tracef("Rollback of transaction %s complete.", gtx);
         } catch (Throwable e) {
            log.unableToRollbackGlobalTx(gtx, e);
         } finally {
            removeRemoteTransaction(gtx);

View Full Code Here

Examples of org.infinispan.commands.tx.RollbackCommand

               }


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

View Full Code Here

Examples of org.infinispan.commands.tx.RollbackCommand

      commitCommand.setCacheName(cacheName);
      return commitCommand;
   }


   public RollbackCommand buildRollbackCommand(GlobalTransaction gtx) {
      RollbackCommand rollbackCommand = new RollbackCommand(gtx);
      rollbackCommand.setCacheName(cacheName);
      return rollbackCommand;
   }

View Full Code Here

Examples of org.infinispan.commands.tx.RollbackCommand

            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

Examples of org.infinispan.commands.tx.RollbackCommand

    * Same comment as for {@link #prepare(javax.transaction.xa.Xid)} applies for commit.
    */   
   public void rollback(Xid xid) throws XAException {      
      LocalTransaction localTransaction = getLocalTransactionAndValidate(xid);
      if (trace) log.trace("rollback transaction {0} ", 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

Examples of org.infinispan.commands.tx.RollbackCommand

            log.tracef("%s global transactions pertain to leavers list %s and need to be killed", toKill.size(), leavers);
      }


      for (GlobalTransaction gtx : toKill) {
         if (trace) log.tracef("Killing %s", gtx);
         RollbackCommand rc = new RollbackCommand(gtx);
         rc.init(invoker, icc, TransactionTable.this);
         try {
            rc.perform(null);
            if (trace) log.tracef("Rollback of %s complete.", gtx);
         } catch (Throwable e) {
            log.unableToRollbackGlobalTx(gtx, e);
         } finally {
            removeRemoteTransaction(gtx);

View Full Code Here

Examples of org.infinispan.commands.tx.RollbackCommand

         this.modifications = null;
      }
   }


   public void rollback(Xid xid) throws XAException {
      RollbackCommand rollbackCommand = commandsFactory.buildRollbackCommand(globalTx);
      LocalTxInvocationContext ctx = icc.createTxInvocationContext();
      ctx.setXaCache(this);
      try {
         invoker.invoke(ctx, rollbackCommand);
      } catch (Throwable e) {

View Full Code Here

Examples of org.infinispan.commands.tx.RollbackCommand

   public CommitCommand buildCommitCommand(GlobalTransaction gtx) {
      return new CommitCommand(cacheName, gtx);
   }


   public RollbackCommand buildRollbackCommand(GlobalTransaction gtx) {
      return new RollbackCommand(cacheName, gtx);
   }

View Full Code Here

Examples of org.infinispan.commands.tx.RollbackCommand

            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

Examples of org.infinispan.commands.tx.RollbackCommand

               break;
            case CommitCommand.COMMAND_ID:
               command = new CommitCommand(cacheName);
               break;
            case RollbackCommand.COMMAND_ID:
               command = new RollbackCommand(cacheName);
               break;
            case MultipleRpcCommand.COMMAND_ID:
               command = new MultipleRpcCommand(cacheName);
               break;
            case SingleRpcCommand.COMMAND_ID:

View Full Code Here

0 1 2 3 4 5

TOP

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.