protected Sink configureSink()

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

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

  protected <T extends Sink> Sink configureSink(final String name, final Class<T> sinkClazz,
                                                final Channel channel,
                                                final Map<String, String> params) {
    T sink;
    try {
      sink = sinkClazz.newInstance();
    } catch (Exception ex) {
      throw new FlumeException("Unable to create sink " + name, ex);
    }
    sink.setName(name);
    Configurables.configure(sink, createContext(params));
    sink.setChannel(channel);
    return sink;
  }