public void setPreviousBrokerApi()

in src/main/java/com/googlesource/gerrit/plugins/kinesis/Module.java [59:63]

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

  public void setPreviousBrokerApi(DynamicItem<BrokerApi> previousBrokerApi) {
    if (previousBrokerApi != null && previousBrokerApi.get() != null) {
      this.activeConsumers = previousBrokerApi.get().topicSubscribers();
    }
  }