Java 类org.apache.commons.cli.MissingArgumentException 实例源码

项目：gemfirexd-oss 文件：ToolsBase.java

protected boolean handleCommonOption(final GfxdOption opt, final String cmd,
    final String cmdDescKey) throws ParseException {
  if (SYSTEM_PROPERTY.equals(opt.getOpt())) {
    String optValue = opt.getValue();
    int indexOfEquals = optValue.indexOf('=');
    if (indexOfEquals >= 0) {
      System.setProperty(optValue.substring(0, indexOfEquals),
          optValue.substring(indexOfEquals + 1));
    }
    else {
      throw new MissingArgumentException(opt);
    }
  }
  else if (HELP.equals(opt.getOpt())) {
    showUsage(null, cmd, cmdDescKey);
    throw new GemFireTerminateError(null, 0);
  }
  else {
    return false;
  }
  return true;
}

项目：rug-cli 文件：ParseExceptionProcessor.java

@SuppressWarnings("unchecked")
public static String process(ParseException e) {
    if (e instanceof MissingOptionException) {
        StringBuilder sb = new StringBuilder();
        Iterator<String> options = ((MissingOptionException) e).getMissingOptions().iterator();
        while (options.hasNext()) {
            sb.append(options.next());
            if (options.hasNext()) {
                sb.append(", ");
            }
        }
        return String.format("Missing required option(s) %s.", sb.toString());
    }
    else if (e instanceof MissingArgumentException) {
        return String.format("%s is missing a required argument.",
                ((MissingArgumentException) e).getOption());
    }
    else if (e instanceof UnrecognizedOptionException) {
        return String.format("%s is not a valid option.",
                ((UnrecognizedOptionException) e).getOption());
    }
    else {
        return String.format("%s.", e.getMessage());
    }
}

项目：OSTMap 文件：ConnectionAnalysis.java

public static void main(String[] args) throws Exception {
    GraphLoader gl = new GraphLoader();
    Graph<String, UserNodeValues, UserEdgeValues> graph;
    final ExecutionEnvironment env = ExecutionEnvironment.getExecutionEnvironment();
    if(args.length == 0) {
        // read graph from accumulo
        graph = null; // TODO : adapt to gl.getUserGraph();
    } else if (args.length == 1) {
        graph = gl.getUserGraphFromFiles(args[0],env);
    } else {
        throw new MissingArgumentException("Either use no arguments for graph import from accumulo or the path " +
                "to file where the graph is stored.");
    }

    ConnectionAnalysis ca = new ConnectionAnalysis();
    ca.analyze(graph);
}

项目：gemfirexd-oss 文件：ToolsBase.java

protected boolean handleCommonOption(final GfxdOption opt, final String cmd,
    final String cmdDescKey) throws ParseException {
  if (SYSTEM_PROPERTY.equals(opt.getOpt())) {
    String optValue = opt.getValue();
    int indexOfEquals = optValue.indexOf('=');
    if (indexOfEquals >= 0) {
      System.setProperty(optValue.substring(0, indexOfEquals),
          optValue.substring(indexOfEquals + 1));
    }
    else {
      throw new MissingArgumentException(opt);
    }
  }
  else if (HELP.equals(opt.getOpt())) {
    showUsage(null, cmd, cmdDescKey);
    throw new GemFireTerminateError(null, 0);
  }
  else {
    return false;
  }
  return true;
}

项目：hops 文件：RMAdminCLI.java

private int handleReplaceLabelsOnNodes(String[] args, String cmd,
    boolean isHAEnabled) throws IOException, YarnException, ParseException {
  Options opts = new Options();
  opts.addOption("replaceLabelsOnNode", true,
      "Replace label on node.");
  opts.addOption("failOnUnknownNodes", false,
      "Fail on unknown nodes.");
  opts.addOption("directlyAccessNodeLabelStore", false,
      "Directly access node label store.");
  int exitCode = -1;
  CommandLine cliParser = null;
  try {
    cliParser = new GnuParser().parse(opts, args);
  } catch (MissingArgumentException ex) {
    System.err.println(NO_MAPPING_ERR_MSG);
    printUsage(args[0], isHAEnabled);
    return exitCode;
  }

  Map<NodeId, Set<String>> map = buildNodeLabelsMapFromStr(
      cliParser.getOptionValue("replaceLabelsOnNode"));
  return replaceLabelsOnNodes(map,
      cliParser.hasOption("failOnUnknownNodes"),
      cliParser.hasOption("directlyAccessNodeLabelStore"));
}

项目：Izou 文件：AddOnInformationManager.java

/**
 * Registers an addOn with the AddOnInformationManager by extracting all relevant information from the addOn and
 * adding it the the sets.
 *
 * Once an addOn is registered, its public data can be viewed by any other addOn through the context.
 *
 * @param addOn The addOn to register with the AddOnInformationManager.
 */
public void registerAddOn(AddOnModel addOn) {
    PluginDescriptor descriptor = addOn.getPlugin().getDescriptor();

    String name = descriptor.getTitle();
    String version = descriptor.getVersion().toString();
    String provider = descriptor.getProvider();
    String id = descriptor.getPluginId();
    String sdkVersion = descriptor.getSdkVersion().toString();
    String artifactID = descriptor.getArtifactID();
    Optional<Integer> serverID = descriptor.getServerID();

    try {
        AddOnInformation addOnInformation = new AddOnInformationImpl(name, provider, version, id, sdkVersion,
                serverID, artifactID);
        addOnInformations.add(addOnInformation);
        addOns.add(addOn);
    } catch (MissingArgumentException e) {
        error("Unable to register addOn: " + addOn.getID() + " with the AddOnInformationManager", e);
    }
}

项目：Izou 文件：AddOnInformationImpl.java

/**
 * Creates a new instance of AddOnInformation, which holds all the public information of an addOn and is registered
 * in the {@link AddOnInformationManager} with the serverID.
 *
 * @param name The name of the AddOn.
 * @param version The version of the AddOn.
 * @param provider The author of the AddOn.
 * @param id The unique ID of the AddOn.
 * @param sdkVersion The version of the SDK that this addOn uses.
 * @param serverID The serverID of the addOn, if it has one (used to match the addOn with the server).
 * @param artifactID The artifactID of the addOn. This is the maven artifactID.
 *
 * @throws MissingArgumentException Thrown if the config file of an addon is not complete, in other words if
 * an argument is missing in the file
 */
public AddOnInformationImpl(String name, String provider, String version, String id, String sdkVersion,
                            Optional<Integer> serverID, String artifactID) throws MissingArgumentException {

    if (!checkField(name) || !checkField(provider) || !checkField(version) || !checkField(id)
            || !checkField(sdkVersion) || !checkField(artifactID)) {
        throw new MissingArgumentException("AddOnInformation is not complete - an argument is missing");
    }

    this.name = name;
    this.version = new Version(version);
    this.provider = provider;
    this.id = id;
    this.sdkVersion = new Version(sdkVersion);
    this.serverID = serverID;
    this.artifactID = artifactID;
}

项目：cfnassist 文件：CreateKeyPairAction.java

@Override
public void invoke(FacadeFactory factory, ProjectAndEnv projectAndEnv, Collection<Parameter> cfnParams,
                   Collection<Parameter> artifacts, String... argument) throws IOException, InterruptedException,
        CfnAssistException, MissingArgumentException {
    AwsFacade facade = factory.createFacade();

    String filename;
    if (argument==null) {
        String home = System.getenv("HOME");
        String keypairName = format("%s_%s", projectAndEnv.getProject(), projectAndEnv.getEnv());
        filename = format("%s/.ssh/%s.pem", home, keypairName);
    } else {
        filename = argument[0];
    }

    KeyPair keyPair = facade.createKeyPair(projectAndEnv, factory.getSavesFile(), filename);
    System.out.println(format("Created key %s with fingerprint %s", keyPair.getKeyName(),
            keyPair.getKeyFingerprint()));
}

项目：vcloud-client 文件：Configuration.java

public static CommandLine parseCli(ModeType mode, String[] args) {
    CommandLine cli = null;
    Options opt = ConfigModes.getMode(mode);
    try {
        cli = new IgnorePosixParser(true).parse(opt, args);
    } catch (MissingArgumentException me) {
        Formatter.usageError(me.getLocalizedMessage(), mode);
        System.exit(-1);
    } catch (MissingOptionException mo) {
        Formatter.usageError(mo.getLocalizedMessage(), mode);
        System.exit(-1);
    } catch (AlreadySelectedException ase) {
        Formatter.usageError(ase.getLocalizedMessage(), mode);
    } catch (UnrecognizedOptionException uoe) {
        Formatter.usageError(uoe.getLocalizedMessage(), mode);
    } catch (ParseException e) {
        Formatter.printStackTrace(e);
        System.exit(-1);
    }

    return cli;
}

项目：cfnassist 文件：DiagramsElement.java

@Override
public void execute(FacadeFactory factory, ProjectAndEnv projectAndEnv,
        Collection<Parameter> cfnParams, Collection<Parameter> artifacts)
        throws IOException, InterruptedException,
        CfnAssistException, CommandLineException, MissingArgumentException {
    String path = target.getAbsolutePath();

    if (!target.isDirectory()) {
        throw new BuildException(
                String.format("Target %s was not a directory, please provide a directory for the diagrams to be saved into", path));
    }

    CreateDiagramAction action = new CreateDiagramAction();

    action.validate(projectAndEnv, cfnParams, artifacts, path);
    action.invoke(factory, projectAndEnv, cfnParams, artifacts, path);

}

项目：cfnassist 文件：TemplatesElement.java

@Override
public void execute(FacadeFactory factory, ProjectAndEnv projectAndEnv, Collection<Parameter> cfnParams, Collection<Parameter> artifacts) 
        throws IOException, InterruptedException, CfnAssistException,
        CommandLineException, MissingArgumentException {
    String absolutePath = target.getAbsolutePath();
    CommandLineAction actionToInvoke = null;
    if (target.isDirectory()) {
        actionToInvoke = new DirAction();
    } else if (target.isFile()) {
        actionToInvoke = new FileAction();
    } 

    if (actionToInvoke==null) {
        throw new BuildException("Unable to action on path, expect file or folder, path was: " + absolutePath);
    } 
    actionToInvoke.validate(projectAndEnv, cfnParams, artifacts, absolutePath);
    actionToInvoke.invoke(factory, projectAndEnv, cfnParams, artifacts, absolutePath);      
}

项目：cfnassist 文件：SNSEventSource.java

@Override
public void init() throws MissingArgumentException, FailedToCreateQueueException, InterruptedException {
    if (init) {
        logger.warn("SNSMonitor init called again");
        return;
    }
    logger.info("Init SNSMonitor");
    topicSnsArn = getOrCreateSNSARN();
    queueURL = getOrCreateQueue();

    Map<String, String> queueAttributes = getQueueAttributes(queueURL);
    queueArn = queueAttributes.get(QUEUE_ARN_KEY);
    checkOrCreateQueuePermissions(queueAttributes, topicSnsArn, queueArn, queueURL);

    createOrGetSQSSubscriptionToSNS();
    init = true;
}

项目：cfnassist 文件：FacadeFactory.java

public AwsFacade createFacade() throws MissingArgumentException, CfnAssistException, InterruptedException {     
    if (awsFacade==null) {
        init();
        SNSEventSource eventSource = new SNSEventSource(snsClient, sqsClient);
        MonitorStackEvents monitor;
        if (snsMonitoring) {    
            monitor = new SNSMonitor(eventSource, cfnRepository);
        } else {
            monitor = new PollingStackMonitor(cfnRepository);
        }

        monitor.init();
           AwsRegionProvider regionProvider = new DefaultAwsRegionProviderChain();
           awsFacade = new AwsFacade(monitor, cfnRepository, vpcRepository, elbRepository,
                cloudRepository, notificationSender, identityProvider);
    }   
    return awsFacade;   
}

项目：cfnassist 文件：TestSNSEventSource.java

@Test
public void shouldCreateSNSAndSQSPlusPolicyAsNeeded() throws MissingArgumentException, NotReadyException, FailedToCreateQueueException, InterruptedException {
    eventSource.init();
    String existingSNSARN = eventSource.getSNSArn();

    // reset the queue, sns and subscription (this forces policy recreation as well)
    String sub = eventSource.getARNofSQSSubscriptionToSNS();
    if (sub!=null) {
        snsClient.unsubscribe(sub);
    }
    snsClient.deleteTopic(existingSNSARN);
    sqsClient.deleteQueue(eventSource.getQueueURL());

    // now recreate the source and make sure we can send/receive
    SNSEventSource anotherEventSource = new SNSEventSource(snsClient, sqsClient);
    anotherEventSource.init();
    // should be able to send via sns and then receive from sqs if everything worked ok
    snsClient.publish(anotherEventSource.getSNSArn(), "aMessage");
    ReceiveMessageRequest request = new ReceiveMessageRequest().
            withQueueUrl(anotherEventSource.getQueueURL()).
            withWaitTimeSeconds(10);
    ReceiveMessageResult result = sqsClient.receiveMessage(request);
    assertTrue(result.getMessages().size()>0);
}