protected SinkRunner createSinkRunner()

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

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

  protected SinkRunner createSinkRunner(SinkProcessor sinkProcessor) {
    SinkRunner runner = new SinkRunner(sinkProcessor);
    runner.setSink(sinkProcessor);
    return runner;
  }