protected SourceRunner configureSource()

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

• 5 lines of code
• 1 McCabe index (conditional complexity)

  protected <T extends Source> SourceRunner configureSource(final T source,
      final ChannelSelector selector, final Map<String, String> params) {
    source.setChannelProcessor(new ChannelProcessor(selector));
    return SourceRunner.forSource(source);
  }