public ListenableFuture send()

in src/main/java/com/googlesource/gerrit/plugins/pubsub/PubSubBrokerApi.java [46:48]

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

  public ListenableFuture<Boolean> send(String topic, Event message) {
    return publishers.computeIfAbsent(topic, t -> publisherFactory.create(t)).publish(message);
  }