Examples of CommitCommand


Examples of com.aragost.javahg.commands.CommitCommand

                return createdNewChangeset ? repo.tip() : null;
            } finally {
                repo.unlock();
            }
        } else {
            CommitCommand cmd = CommitCommand.on(repo);
            cmd.user(this.rollbackChangeset.getUser());
            cmd.date(this.rollbackChangeset.getTimestamp());
            cmd.message(this.rollbackChangeset.getMessage());
            cmd.extra("source", getSource().getNode());
            return cmd.execute();
        }
    }
View Full Code Here

Examples of org.apache.axis2.clustering.configuration.commands.CommitCommand

        log.debug("Exit: DefaultConfigurationManager::applyPolicy");
    }

    public void commit() throws ClusteringFault {
        CommitCommand command = new CommitCommand();
        send(command);
    }
View Full Code Here

Examples of org.apache.jackrabbit.mongomk.impl.command.CommitCommand

        NodeAssert.assertEquals(expecteds, actuals);
    }

    private Long addNode(String nodeName) throws Exception {
        Commit commit = CommitBuilder.build("/", "+\"" + nodeName + "\" : {}", "Add /" + nodeName);
        CommitCommand command = new CommitCommand(getNodeStore(), commit);
        return command.execute();
    }
View Full Code Here

Examples of org.eclipse.jgit.api.CommitCommand

  private List<String> paths = new ArrayList<String>();

  @Override
  protected void run() throws NoHeadException, NoMessageException,
      ConcurrentRefUpdateException, JGitInternalException, Exception {
    CommitCommand commitCmd = new Git(db).commit();
    if (author != null)
      commitCmd.setAuthor(RawParseUtils.parsePersonIdent(author));
    if (message != null)
      commitCmd.setMessage(message);
    if (only && paths.isEmpty())
      throw die(CLIText.get().pathsRequired);
    if (only && all)
      throw die(CLIText.get().onlyOneOfIncludeOnlyAllInteractiveCanBeUsed);
    if (!paths.isEmpty())
      for (String p : paths)
        commitCmd.setOnly(p);
    commitCmd.setAmend(amend);
    commitCmd.setAll(all);
    Ref head = db.getRef(Constants.HEAD);
    RevCommit commit;
    try {
      commit = commitCmd.call();
    } catch (JGitInternalException e) {
      throw die(e.getMessage());
    }

    String branchName;
View Full Code Here

Examples of org.infinispan.commands.tx.CommitCommand

      command.setCacheName(cacheName);
      return command;
   }

   public CommitCommand buildCommitCommand(GlobalTransaction gtx) {
      CommitCommand commitCommand = new CommitCommand(gtx);
      commitCommand.setCacheName(cacheName);
      return commitCommand;
   }
View Full Code Here

Examples of org.infinispan.commands.tx.CommitCommand

            pc.initialize(notifier);
            if (pc.getModifications() != null)
               for (ReplicableCommand nested : pc.getModifications()) initializeReplicableCommand(nested);
            break;
         case CommitCommand.COMMAND_ID:
            CommitCommand commitCommand = (CommitCommand) c;
            commitCommand.init(interceptorChain, icc, txTable);
            break;
         case RollbackCommand.COMMAND_ID:
            RollbackCommand rollbackCommand = (RollbackCommand) c;
            rollbackCommand.init(interceptorChain, icc, txTable);
            break;
View Full Code Here

Examples of org.infinispan.commands.tx.CommitCommand

               break;
            case TotalOrderVersionedPrepareCommand.COMMAND_ID:
               command = new TotalOrderVersionedPrepareCommand(cacheName);
               break;
            case CommitCommand.COMMAND_ID:
               command = new CommitCommand(cacheName);
               break;
            case VersionedCommitCommand.COMMAND_ID:
               command = new VersionedCommitCommand(cacheName);
               break;
            case TotalOrderCommitCommand.COMMAND_ID:
View Full Code Here

Examples of org.infinispan.commands.tx.CommitCommand

               log.errorProcessing1pcPrepareCommand(e);
               throw new XAException(XAException.XAER_RMERR);
            }
         } else {
            handleTopologyChanges(localTransaction);
            CommitCommand commitCommand = commandsFactory.buildCommitCommand(localTransaction.getGlobalTransaction());
            try {
               invoker.invoke(ctx, commitCommand);
               txTable.removeLocalTransaction(localTransaction);
            } catch (Throwable e) {
               txTable.failureCompletingTransaction(ctx.getTransaction());
View Full Code Here

Examples of org.infinispan.commands.tx.CommitCommand

      command.setCacheName(cacheName);
      return command;
   }

   public CommitCommand buildCommitCommand(GlobalTransaction gtx) {
      CommitCommand commitCommand = new CommitCommand(gtx);
      commitCommand.setCacheName(cacheName);
      return commitCommand;
   }
View Full Code Here

Examples of org.infinispan.commands.tx.CommitCommand

               DldGlobalTransaction transaction = (DldGlobalTransaction) pc.getGlobalTransaction();
               transaction.setLocksHeldAtOrigin(pc.getAffectedKeys());
            }
            break;
         case CommitCommand.COMMAND_ID:
            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);
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.