public void start()

in src/main/java/com/googlesource/gerrit/plugins/rabbitmq/Manager.java [72:85]

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

  public void start() {
    List<Properties> propList = load();
    for (Properties properties : propList) {
      Publisher publisher = publisherFactory.create(properties);
      publisher.start();
      String listenAs = properties.getSection(Gerrit.class).listenAs;
      if (!listenAs.isEmpty()) {
        userEventWorker.addPublisher(pluginName, publisher, listenAs);
      } else {
        defaultEventWorker.addPublisher(publisher);
      }
      publisherList.add(publisher);
    }
  }