protected T configureSinkProcessor()

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

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

  protected <T extends SinkProcessor> T configureSinkProcessor(final Map<String, String> params,
      final Class<T> clazz, final List<Sink> sinks) {
    T processor;
    try {
      processor = clazz.newInstance();
    } catch (Exception ex) {
      throw new FlumeException("Unable to create SinkProcessor of type: " + clazz.getName(), ex);
    }
    processor.setSinks(sinks);
    Configurables.configure(processor, createContext(params));
    return processor;
  }