basic-lib/src/main/java/com/streamsets/pipeline/stage/origin/http/HttpClientConfigBean.java
public void init(Source.Context context, String groupName, String prefix, List<Stage.ConfigIssue> issues) {

    // Validate the ELs for string configs
    List<String> elConfigs = ImmutableList.of("resourceUrl", "requestBody");
    for (String configName : elConfigs) {
      ELVars vars = context.createELVars();
      vars.addVariable(START_AT, 0);
      ELEval eval = context.createELEval(configName);
      try {
        eval.eval(vars, (String)getClass().getField(configName).get(this), String.class);
      } catch (ELEvalException | NoSuchFieldException | IllegalAccessException e) {
        LOG.error(Errors.HTTP_06.getMessage(), e.toString(), e);
        issues.add(context.createConfigIssue(groupName, prefix + configName, Errors.HTTP_06, e.toString()));
      }
    }

    client.init(context, Groups.PROXY.name(), prefix + "client.", issues);

    // Validate the EL for each header entry
    ELVars headerVars = context.createELVars();
    ELEval headerEval = context.createELEval("headers");
    for (String headerValue : headers.values()) {
      try {
        headerEval.eval(headerVars, headerValue, String.class);
      } catch (ELEvalException e) {
        LOG.error(Errors.HTTP_06.getMessage(), e.toString(), e);
        issues.add(context.createConfigIssue(groupName, prefix + "headers", Errors.HTTP_06, e.toString()));
      }
    }
  }
public void init(Source.Context context, String groupName, String prefix, List<Stage.ConfigIssue> issues) {

    // Validate the ELs for string configs
    List<String> elConfigs = ImmutableList.of("resourceUrl", "requestBody");
    for (String configName : elConfigs) {
      ELVars vars = context.createELVars();
      vars.addVariable(START_AT, 0);
      ELEval eval = context.createELEval(configName);
      try {
        eval.eval(vars, (String)getClass().getField(configName).get(this), String.class);
      } catch (ELEvalException | NoSuchFieldException | IllegalAccessException e) {
        LOG.error(Errors.HTTP_06.getMessage(), e.toString(), e);
        issues.add(context.createConfigIssue(groupName, prefix + configName, Errors.HTTP_06, e.toString()));
      }
    }

    client.init(context, Groups.PROXY.name(), prefix + "client.", issues);

    // Validate the EL for each header entry
    ELVars headerVars = context.createELVars();
    ELEval headerEval = context.createELEval("headers");
    for (String headerValue : headers.values()) {
      try {
        headerEval.eval(headerVars, headerValue, String.class);
      } catch (ELEvalException e) {
        LOG.error(Errors.HTTP_06.getMessage(), e.toString(), e);
        issues.add(context.createConfigIssue(groupName, prefix + "headers", Errors.HTTP_06, e.toString()));
      }
    }
  }
public void init ( Source . Context context , String groupName , String prefix , List < Stage . ConfigIssue > issues ) { // Validate the ELs for string configs List < String > elConfigs = ImmutableList . of ( "resourceUrl" , "requestBody" ) ; for ( String configName : elConfigs ) { ELVars vars = context . createELVars ( ) ; vars . addVariable ( START_AT , 0 ) ; ELEval eval = context . createELEval ( configName ) ; try { eval . eval ( vars , ( String ) getClass ( ) . getField ( configName ) . get ( this ) , String . class ) ; } catch ( ELEvalException | NoSuchFieldException | IllegalAccessException e ) { LOG . error ( Errors . HTTP_06 . getMessage ( ) , e . toString ( ) , e ) ; issues . add ( context . createConfigIssue ( groupName , prefix + configName , Errors . HTTP_06 , e . toString ( ) ) ) ; } } client . init ( context , Groups . PROXY . name ( ) , prefix + "client." , issues ) ; // Validate the EL for each header entry ELVars headerVars = context . createELVars ( ) ; ELEval headerEval = context . createELEval ( "headers" ) ; for ( String headerValue : headers . values ( ) ) { try { headerEval . eval ( headerVars , headerValue , String . class ) ; } catch ( ELEvalException e ) { LOG . error ( Errors . HTTP_06 . getMessage ( ) , e . toString ( ) , e ) ; issues . add ( context . createConfigIssue ( groupName , prefix + "headers" , Errors . HTTP_06 , e . toString ( ) ) ) ; } } }
Validates the parameters for this config bean.
@param context Stage Context
@param groupName Group name this bean is used in
@param prefix Prefix to the parameter names (e.g. parent beans)
@param issues List of issues to augment
Validates the parameters for this config bean .