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%2Fports%2FMessagingService.java;fp=src%2Fmain%2Fjava%2Fde%2Fjuplo%2Fkafka%2Fpayment%2Ftransfer%2Fports%2FMessagingService.java;h=b651c20a1c74d965a558ee8fe4ee3cfe7ba7e5ff;hp=4037a904a6f245ce20bdb3bda4860d147fdaa677;hb=26809d379a0e024017f70db8c70382f94faf98b6;hpb=78721edb87827a1837f298f24761af8be640c58b diff --git a/src/main/java/de/juplo/kafka/payment/transfer/ports/MessagingService.java b/src/main/java/de/juplo/kafka/payment/transfer/ports/MessagingService.java index 4037a90..b651c20 100644 --- a/src/main/java/de/juplo/kafka/payment/transfer/ports/MessagingService.java +++ b/src/main/java/de/juplo/kafka/payment/transfer/ports/MessagingService.java @@ -8,4 +8,5 @@ import java.util.concurrent.CompletableFuture; public interface MessagingService { CompletableFuture send(Transfer transfer); + CompletableFuture send(Long id, Transfer.State state); }