protected T configureChannel()

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

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

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