public ListenableFuture publish()

in src/main/java/com/googlesource/gerrit/plugins/kafka/session/KafkaSession.java [93:98]

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

  public ListenableFuture<Boolean> publish(String topic, String messageBody) {
    if (properties.isSendAsync()) {
      return publishAsync(topic, messageBody);
    }
    return publishSync(topic, messageBody);
  }