X-Git-Url: https://juplo.de/gitweb/?p=demos%2Fkafka%2Fdemos-kafka-payment-system-transfer;a=blobdiff_plain;f=src%2Fmain%2Fjava%2Fde%2Fjuplo%2Fkafka%2Fpayment%2Ftransfer%2Fadapter%2FKafkaMessagingService.java;fp=src%2Fmain%2Fjava%2Fde%2Fjuplo%2Fkafka%2Fpayment%2Ftransfer%2Fadapter%2FKafkaMessagingService.java;h=3161af32ab0d932715d4b8ee374c3fcbced4f7dc;hp=0f8cf2b7cc0042f62f5b6693527205ad55868966;hb=fae41770a1f65b4ddfe8d51d09a8a8cdc35a5bdd;hpb=4467c5240397a47b181106a0ae902ed1b71d0c5d diff --git a/src/main/java/de/juplo/kafka/payment/transfer/adapter/KafkaMessagingService.java b/src/main/java/de/juplo/kafka/payment/transfer/adapter/KafkaMessagingService.java index 0f8cf2b..3161af3 100644 --- a/src/main/java/de/juplo/kafka/payment/transfer/adapter/KafkaMessagingService.java +++ b/src/main/java/de/juplo/kafka/payment/transfer/adapter/KafkaMessagingService.java @@ -23,7 +23,7 @@ public class KafkaMessagingService implements MessagingService @Override - public CompletableFuture send(Transfer transfer) + public CompletableFuture send(Transfer transfer) { try {