protected void configure()

in src/main/java/com/googlesource/gerrit/plugins/kafka/Module.java [41:52]

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

  protected void configure() {
    DynamicSet.bind(binder(), LifecycleListener.class).to(Manager.class);

    if (configuration.isSendStreamEvents()) {
      DynamicSet.bind(binder(), EventListener.class).to(KafkaPublisher.class);
    }

    bind(new TypeLiteral<KafkaProducer<String, String>>() {})
        .toProvider(KafkaProducerProvider.class);

    install(kafkaBrokerModule);
  }