Java Code Examples for org.apache.commons.lang.StringUtils

private void fixIncludes(HTMLDocument document,Node node,IssueReport report){
  NamedNodeMap attributes=node.getAttributes();
  if ("TD".equals(node.getNodeName()) && (null != attributes.getNamedItem("headers"))) {
    String id=attributes.getNamedItem("headers").getNodeValue();
    Node header=document.findNodeById(id);
    if (null != header) {
      node.appendChild(header.cloneNode(true));
      attributes.removeNamedItem("headers");
    }
  }
  for (  Node current : DomUtils.findAllByAttributeName(document.getDocument(),"class")) {
    if (!DomUtils.hasClassName(current,"include"))     continue;
    current.getAttributes().removeNamedItem("class");
    ArrayList<TextField> res=new ArrayList<TextField>();
    HTMLDocument.readUrlField(res,current);
    TextField id=res.get(0);
    if (null == id)     continue;
    TextField refId=new TextField(StringUtils.substringAfter(id.value(),"#"),id.source());
    Node included=document.findNodeById(refId.value());
    if (null == included)     continue;
    if (DomUtils.isAncestorOf(included,current)) {
      final int[] nodeLocation=DomUtils.getNodeLocation(current);
      report.notifyIssue(IssueReport.IssueLevel.Warning,"Current node tries to include an ancestor node.",nodeLocation[0],nodeLocation[1]);
      continue;
    }
    current.appendChild(included.cloneNode(true));
  }
}
 

@POST @Produces(MediaType.TEXT_PLAIN) @Timed public Response upload(final InputStream body,@QueryParam("path") final String outputPath,@QueryParam("overwrite") @DefaultValue("false") final boolean overwrite,@QueryParam("replication") @DefaultValue("3") final short replication,@QueryParam("blocksize") @DefaultValue("-1") long blocksize,@QueryParam("permission") @DefaultValue("u=rw,go=r") final String permission) throws IOException {
  if (outputPath == null) {
    return Response.status(Response.Status.BAD_REQUEST).header("Warning","199 " + "path cannot be null").cacheControl(cacheControl).build();
  }
  if (blocksize == -1) {
    blocksize=config.getHadoopBlockSize();
  }
  try {
    final URI path=hdfsWriter.write(body,outputPath,overwrite,replication,blocksize,permission);
    return Response.created(path).build();
  }
 catch (  IOException e) {
    final String message;
    if (e.getMessage() != null) {
      message=StringUtils.split(e.getMessage(),'\n')[0];
    }
 else {
      message=e.toString();
    }
    log.warn("Unable to create [{}]: {}",outputPath,message);
    return Response.serverError().header("Warning","199 " + message).cacheControl(cacheControl).build();
  }
}
 

/** 
 * <p> Executes the command wrapped in exception handler. </p> <p> Reacts to exceptions with 'Permission denied' type and try to reexecute the command in this situation. </p> <p> Prints the exception stack trace to help identify the problematic commands. </p>
 */
@Override public void intercept(final CommandContext ctx) throws CommandInterceptorException {
  long end=System.currentTimeMillis() + configuration.getTimeout(TimeoutType.AJAX);
  boolean exceptionLogged=false;
  while (System.currentTimeMillis() < end) {
    try {
      ctx.invoke();
      return;
    }
 catch (    SeleniumException e) {
      final String message=StringUtils.defaultString(e.getMessage());
      if (ArrayUtils.contains(PERMISSION_DENIED,message)) {
        System.err.println(message);
        if (!exceptionLogged) {
          exceptionLogged=true;
          System.err.println(ctx.toString());
          e.printStackTrace();
        }
        wait.waitForTimeout();
        continue;
      }
      throw e;
    }
  }
  throw new PermissionDeniedException("Fails with 'Permission denied' errors when trying to execute jQuery");
}
 

public HashLoginService get(){
  String authConfig=config.getUserAuthFile();
  try {
    if (!StringUtils.isEmpty(authConfig)) {
      HashLoginService service=new HashLoginService(HttpServerModule.REALM_NAME,authConfig);
      service.loadUsers();
      return service;
    }
    return null;
  }
 catch (  IOException e) {
    log.error(e,"Error when loading user auth info from %s",authConfig);
  }
  return null;
}
 

public void output(Resource resource) throws IOException {
  StreamCopy.readToEOF(resource.getInputStream());
  List<List<String>> data=view.apply(resource.getMetaData().getTopMetaData());
  if (data != null) {
    for (    List<String> d : data) {
      out.println(StringUtils.join(d,"\t"));
    }
  }
}
 

@Override public String transform(TreatmentDefinition input){
  List<String> names=new ArrayList<String>();
  for (  Category category : input.getContents()) {
    names.add(getCleanName(category));
  }
  return StringUtils.join(names,"_");
}
 

public String toString(){
  String toStr="";
  toStr+=String.format("FamilyName: %s\n",name);
  toStr+=String.format("Supply: %d\n",supply);
  toStr+=String.format("Power: %d\n",curPower);
  toStr+=String.format("Iron: %d\n",ironRank);
  toStr+=String.format("Blade: %d\n",bladeRank);
  toStr+=String.format("Raven: %d\n",ravenRank);
  toStr+=String.format("Territories: %s\n",StringUtils.join(conquerTerritories,","));
  toStr+=String.format("Character: %s\n",battleCharacter);
  toStr+=String.format("Address: %s\n",address);
  return toStr;
}
 

/** 
 * Constructor which takes the id of a case.
 * @param aCase Needs to be already saved (have an id).
 */
public AlphaCard(final AlphaCase aCase){
  if (StringUtils.isEmpty(aCase.getCaseId()))   throw new IllegalStateException("AlphaCard cannot be initialized with an unsaved case!");
  this.setAlphaCardIdentifier(new AlphaCardIdentifier(aCase.getCaseId()));
  this.setAlphaCardDescriptor(new AlphaCardDescriptor(this));
  this.setAlphaCase(aCase);
}
 

@Override public void validate() throws CommandValidationException {
  List<String> messages=constructMessages();
  messages.add(validateInputFile("Pattern",getPatternFile()));
  messages.add(validateInputFile("Sample",getSampleFile()));
  messages.add(validateOutputFile("Output",output));
  if (!messages.isEmpty()) {
    throw new CommandValidationException(StringUtils.join(messages,'\n'));
  }
}
 

public void setValue(String s) throws InvalidValueException {
  if (s == null) {
    value=null;
  }
 else {
    try {
      setValue(DateUtil.parseDate(StringUtils.trim(s)));
    }
 catch (    Exception pe) {
      throw new InvalidValueException(buildExceptionMessage(s,propField),pe);
    }
  }
}
 

public String getFileNameTemplate(){
  if (StringUtils.isNotEmpty(fileNameTemplate)) {
    return fileNameTemplate;
  }
 else {
    return DEFAULT_FILE_NAME_TEMPLATE;
  }
}
 

/** 
 * collects a chain of property methods that are called sequentially to get the final result.
 * @param clazz
 * @param propertyNamesList
 * @param readOnly only look for a getter
 * @return the chain of methods.
 */
protected List<PropertyAdaptor> getMethods(Class<?> clazz,String[] propertyNamesList,boolean readOnly){
  Class<?>[] parameterTypes=new Class<?>[0];
  List<PropertyAdaptor> propertyMethodChain=new ArrayList<PropertyAdaptor>();
  for (Iterator<String> iter=Arrays.asList(propertyNamesList).iterator(); iter.hasNext(); ) {
    String propertyName=iter.next();
    PropertyAdaptor propertyAdaptor=new PropertyAdaptor(propertyName);
    propertyAdaptor.setGetter(clazz,parameterTypes);
    if (!iter.hasNext() && !readOnly) {
      propertyAdaptor.initSetter(clazz);
    }
    if (propertyAdaptor.isExists()) {
      clazz=propertyAdaptor.getReturnType();
      propertyMethodChain.add(propertyAdaptor);
    }
 else {
      throw new IllegalArgumentException(StringUtils.join(propertyNamesList) + " has bad property " + propertyName);
    }
  }
  return propertyMethodChain;
}
 

public void testReadPilgrimKeys() throws Exception {
  Book book=getBook("Pilgrim");
  Key globalKeyList=book.getGlobalKeyList();
  System.out.println("Global key list");
  for (  Key key : globalKeyList) {
    if (StringUtils.isNotEmpty(key.getName())) {
      String rawText=book.getRawText(key);
      System.out.println(key.getName() + " has " + rawText.length()+ " chars content");
      if (rawText.length() < 30) {
        System.out.println(rawText);
      }
    }
  }
  assertEquals("Incorrect number of keys in master list",29,globalKeyList.getCardinality());
  System.out.println("\nChildren");
  for (int i=0; i < globalKeyList.getChildCount(); i++) {
    System.out.println(globalKeyList.get(i));
  }
  assertEquals("Incorrect number of top level keys",6,globalKeyList.getChildCount());
}
 

private static String getTranslatedFilePath(File file,String localeString,String pathToStoreFile){
  StringBuilder stringBuilder=new StringBuilder(pathToStoreFile);
  String locale=StringUtils.isNotBlank(localeString) ? localeString.replace(LOCALE_SEPERATOR,LOCALE_FILENAME_SEPERATOR) : StringUtils.EMPTY;
  stringBuilder.append(file.getName().replace(PROPERTY_FILE_EXT,LOCALE_FILENAME_SEPERATOR + locale + PROPERTY_FILE_EXT));
  return stringBuilder.toString();
}
 

/** 
 * Spawns multiple threads, one for each controller in the list of controllers, and within each thread, delegates to the controller's handleRequest() method. Once all the threads are complete, the ModelAndView objects returned from each of the handleRequest() methods are merged into a single view. The view name for the model is set to the specified view name. If an exception is thrown by any of the controllers in the chain, this exception is propagated up from the handleRequest() method of the ChainedController.
 * @param request  the HttpServletRequest object.
 * @param response the HttpServletResponse object.
 * @return a merged ModelAndView object.
 * @throws Exception if one is thrown from the controllers in the chain.
 */
@SuppressWarnings("unchecked") private ModelAndView handleRequestParallely(HttpServletRequest request,HttpServletResponse response) throws Exception {
  ExecutorService service=Executors.newCachedThreadPool();
  int numberOfControllers=controllers.size();
  CallableController[] callables=new CallableController[numberOfControllers];
  Future<ModelAndView>[] futures=new Future[numberOfControllers];
  for (int i=0; i < numberOfControllers; i++) {
    callables[i]=new CallableController(controllers.get(i),request,response);
    futures[i]=service.submit(callables[i]);
  }
  ModelAndView mergedModel=new ModelAndView();
  for (  Future<ModelAndView> future : futures) {
    ModelAndView model=future.get();
    if (model != null) {
      mergedModel.addAllObjects(model.getModel());
    }
  }
  if (StringUtils.isNotEmpty(this.viewName)) {
    mergedModel.setViewName(this.viewName);
  }
  return mergedModel;
}
 

public boolean equalsConfig(Config cmpConfig){
  if (!StringUtils.equals(this.host,cmpConfig.host))   return false;
  if (!StringUtils.equals(this.eventType,cmpConfig.eventType))   return false;
  if (!StringUtils.equals(this.eventAttributeType,cmpConfig.eventAttributeType))   return false;
  if (!StringUtils.equals(this.monitoringTypesString,cmpConfig.monitoringTypesString))   return false;
  if (!StringUtils.equals(this.deployedEnv,cmpConfig.deployedEnv))   return false;
  if (!StringUtils.equals(this.deployedVersion,cmpConfig.deployedVersion))   return false;
  if (!StringUtils.equals(this.deployedType,cmpConfig.deployedType))   return false;
  if (!StringUtils.equals(this.deployedConfigSubPath,cmpConfig.deployedConfigSubPath))   return false;
  if (!this.pollingInterval.equals(cmpConfig.pollingInterval))   return false;
  return true;
}
 

public static String getBuildUrl(AbstractBuild build){
  String root=Hudson.getInstance().getRootUrl();
  if (StringUtils.isBlank(root)) {
    return "";
  }
  return root + build.getUrl();
}
 

public static String[] buildProcessParams(final IAsAdminCmd cmd,final IAsAdminConfig config) throws AsAdminException {
  final List<String> pbParams=new ArrayList<String>();
  pbParams.add(ASADMIN_COMMAND_NAME);
  if (!Deployment.UNDEPLOY.equals(cmd.getActionCommand()) && !Deployment.DEPLOY.equals(cmd.getActionCommand()) && !"add-resources".equals(cmd.getActionCommand()))   pbParams.add(cmd.getActionCommand());
  if (!StringUtils.isEmpty(config.getHost()) && !Domain.START.equals(cmd.getActionCommand()) && !Domain.STOP.equals(cmd.getActionCommand())&& !Database.STOP.equals(cmd.getActionCommand())&& !Database.START.equals(cmd.getActionCommand())) {
    pbParams.add(HOST_OPT);
    pbParams.add(config.getHost());
  }
  if (!StringUtils.isEmpty(config.getPort()) && !Domain.START.equals(cmd.getActionCommand()) && !Domain.STOP.equals(cmd.getActionCommand())&& !Database.STOP.equals(cmd.getActionCommand())&& !Database.START.equals(cmd.getActionCommand())) {
    pbParams.add(PORT_OPT);
    pbParams.add(config.getPort());
  }
  if (config.isSecure()) {
    pbParams.add(SECURE_OPT);
  }
  if (cmd.needCredentials()) {
    pbParams.add(USER_OPT);
    pbParams.add(config.getUser());
    pbParams.add(PASSWORDFILE_OPT);
    pbParams.add(cmd.handlePasswordFile(config.getPasswordFile()));
  }
  if (Deployment.UNDEPLOY.equals(cmd.getActionCommand()) || Deployment.DEPLOY.equals(cmd.getActionCommand()) || "add-resources".equals(cmd.getActionCommand()))   pbParams.add(cmd.getActionCommand());
  pbParams.addAll(Arrays.asList(cmd.getParameters()));
  return pbParams.toArray(new String[pbParams.size()]);
}
 

public <T>AstyanaxContext<Keyspace> buildKeyspace(AstyanaxTypeFactory<T> factory){
  ConnectionPool<T> cp=createConnectionPool(factory.createConnectionFactory(asConfig,cpConfig,tracerFactory,monitor));
  this.cp=cp;
  final Keyspace keyspace=factory.createKeyspace(keyspaceName,cp,asConfig,tracerFactory);
  Supplier<Map<BigInteger,List<Host>>> supplier=null;
switch (getNodeDiscoveryType()) {
case DISCOVERY_SERVICE:
    Preconditions.checkNotNull(hostSupplier,"Missing host name supplier");
  supplier=hostSupplier;
break;
case RING_DESCRIBE:
supplier=new RingDescribeHostSupplier(keyspace,cpConfig.getPort());
break;
case TOKEN_AWARE:
if (hostSupplier == null) {
supplier=new RingDescribeHostSupplier(keyspace,cpConfig.getPort());
}
 else {
supplier=new FilteringHostSupplier(new RingDescribeHostSupplier(keyspace,cpConfig.getPort()),hostSupplier);
}
break;
case NONE:
supplier=null;
break;
}
if (supplier != null) {
discovery=new NodeDiscoveryImpl(StringUtils.join(Arrays.asList(clusterName,keyspaceName),"_"),asConfig.getDiscoveryDelayInSeconds() * 1000,supplier,cp);
}
return new AstyanaxContext<Keyspace>(this,keyspace);
}
 

@Override public SessionBean getSessionBean(final String sessionId){
  if (StringUtils.isBlank(sessionId)) {
    return null;
  }
  Iterable<SessionBean> iterable=Iterables.filter(getAllSessionBeans(),new Predicate<SessionBean>(){
    @Override public boolean apply(    @Nullable SessionBean input){
      return StringUtils.equals(sessionId,input.getSessionId());
    }
  }
);
  return iterable.iterator().hasNext() ? iterable.iterator().next() : null;
}
 

/** 
 * Returns a list of MigrationListeners for the systemName specified in the properties.
 * @param systemName The name of the system to load MigrationListeners for.
 * @param properties The properties that has migration listeners specified.
 * @return A List of zero or more MigrationListeners
 * @throws MigrationException if unable to load listeners.
 */
protected List loadMigrationListeners(String systemName,Properties properties) throws MigrationException {
  try {
    List listeners=new ArrayList();
    String[] listenerClassNames=null;
    String commaSeparatedList=properties.getProperty(systemName + ".listeners");
    if (StringUtils.isNotBlank(commaSeparatedList)) {
      listenerClassNames=commaSeparatedList.split(",");
      for (Iterator it=Arrays.asList(listenerClassNames).iterator(); it.hasNext(); ) {
        String className=((String)it.next()).trim();
        if (StringUtils.isNotBlank(className)) {
          Class c=Class.forName(className);
          MigrationListener listener=(MigrationListener)c.newInstance();
          listener.initialize(systemName,properties);
          listeners.add(listener);
        }
      }
    }
    return listeners;
  }
 catch (  Exception e) {
    throw new MigrationException("Exception while loading migration listeners",e);
  }
}
 

@Override public String getName(){
  return StringUtils.join(Iterables.transform(Arrays.asList(flows),new Function<Flow,String>(){
    @Override public String apply(    Flow flow){
      return flow.getName();
    }
  }
).iterator()," + ");
}
 

/** 
 * Parses the specified schedule into  {@link #period execution period}.
 * @param schedule the specified schedule
 */
private void parse(final String schedule){
  final int num=Integer.valueOf(StringUtils.substringBetween(schedule," "," "));
  final String timeUnit=StringUtils.substringAfterLast(schedule," ");
  LOGGER.log(Level.FINEST,"Parsed cron job[schedule={0}]: [num={1}, timeUnit={2}]",new Object[]{schedule,num,timeUnit});
  if ("hours".equals(timeUnit)) {
    period=num * SIXTY * SIXTY* THOUSAND;
  }
 else   if ("minutes".equals(timeUnit)) {
    period=num * SIXTY * THOUSAND;
  }
}
 

@Override public void action(final Event<JSONObject> event) throws EventException {
  final JSONObject eventData=event.getData();
  String articleTitle=null;
  try {
    final JSONObject article=eventData.getJSONObject(Article.ARTICLE);
    articleTitle=article.getString(Article.ARTICLE_TITLE);
    final JSONObject preference=PreferenceQueryService.getInstance().getPreference();
    final String blogTitle=preference.getString(Preference.BLOG_TITLE);
    String blogHost=preference.getString(Preference.BLOG_HOST).toLowerCase().trim();
    if ("localhost".equals(blogHost.split(":")[0].trim())) {
      LOGGER.log(Level.INFO,"Blog Solo runs on local server, so should not ping " + "Google Blog Search Service for the article[title={0}]",new Object[]{article.getString(Article.ARTICLE_TITLE)});
      return;
    }
    blogHost=StringUtils.removeEnd("http://" + blogHost,"/");
    final String articlePermalink=blogHost + article.getString(Article.ARTICLE_PERMALINK);
    final String spec="http://blogsearch.google.com/ping?name=" + URLEncoder.encode(blogTitle,"UTF-8") + "&url="+ URLEncoder.encode(blogHost,"UTF-8")+ "&changesURL="+ URLEncoder.encode(articlePermalink,"UTF-8");
    LOGGER.log(Level.FINER,"Request Google Blog Search Service API[{0}] while adding an " + "article[title=" + articleTitle + "]",spec);
    final HTTPRequest request=new HTTPRequest();
    request.setURL(new URL(spec));
    URL_FETCH_SERVICE.fetchAsync(request);
  }
 catch (  final Exception e) {
    LOGGER.log(Level.SEVERE,"Ping Google Blog Search Service fail while adding an article[title=" + articleTitle + "]",e);
  }
}