[SDCISA-16207, swisspost#583] Remove unneccessary Future.

hiddenalpha · Jun 17, 2024 · 5a8f462 · 5a8f462
1 parent e2f576b
commit 5a8f462
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/gateleen-kafka/src/main/java/org/swisspush/gateleen/kafka/KafkaProducerRecordBuilder.java b/gateleen-kafka/src/main/java/org/swisspush/gateleen/kafka/KafkaProducerRecordBuilder.java
@@ -52,7 +52,7 @@ class KafkaProducerRecordBuilder {
      * @throws ValidationException when the payload is not valid (missing properties, wrong types, etc.)
      */
     Future<List<KafkaProducerRecord<String, String>>> buildRecordsAsync(String topic, Buffer payload) {
-        return Future.<Void>succeededFuture().compose((Void v) -> vertx.executeBlocking(() -> {
+        return vertx.executeBlocking(() -> {
             long beginEpchMs = currentTimeMillis();
             JsonObject payloadObj;
             try {
@@ -76,7 +76,7 @@ Future<List<KafkaProducerRecord<String, String>>> buildRecordsAsync(String topic
             long durationMs = currentTimeMillis() - beginEpchMs;
             log.debug("Parsing and Serializing JSON did block thread for {}ms", durationMs);
             return kafkaProducerRecords;
-        }));
+        });
     }
 
     /** @deprecated Use {@link #buildRecordsAsync(String, Buffer)}. */