private ListenableFuture publishSync()

in src/main/java/com/googlesource/gerrit/plugins/kinesis/KinesisPublisher.java [71:88]

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

  private ListenableFuture<Boolean> publishSync(
      String streamName, String stringEvent, String partitionKey) {
    SettableFuture<Boolean> resultFuture = SettableFuture.create();
    try {
      resultFuture.set(
          publishAsync(streamName, stringEvent, partitionKey)
              .get(configuration.getPublishTimeoutMs(), TimeUnit.MILLISECONDS));
    } catch (CancellationException
        | ExecutionException
        | InterruptedException
        | TimeoutException futureException) {
      logger.atSevere().withCause(futureException).log(
          "KINESIS PRODUCER - Failed publishing event %s [PK: %s]", stringEvent, partitionKey);
      resultFuture.set(false);
    }

    return resultFuture;
  }