protected ChannelSelector createChannelSelector()

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

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

  protected ChannelSelector createChannelSelector(Class<? extends ChannelSelector> clazz,
                                                  Map<String, String> params) {
    ChannelSelector selector;
    try {
      selector = clazz.newInstance();
    } catch (Exception ex) {
      throw new FlumeException("Unable to create channel selector " + clazz.getName(), ex);
    }
    Configurables.configure(selector, createContext(params));
    return selector;
  }