protected SourceRunner configureSource()

in flume-spring-boot/src/main/java/org/apache/flume/spring/boot/config/AbstractFlumeConfiguration.java [53:65]

• 13 lines of code
• 2 McCabe index (conditional complexity)

  protected <T extends Source> SourceRunner configureSource(final String name, final Class<T> clazz,
      final ChannelSelector selector, final Map<String, String> params) {
    T source;
    try {
      source = clazz.newInstance();
    } catch (Exception ex) {
      throw new FlumeException("Unable to create source " + name, ex);
    }
    source.setName(name);
    Configurables.configure(source, createContext(params));
    source.setChannelProcessor(new ChannelProcessor(selector));
    return SourceRunner.forSource(source);
  }