WIP

[demos/kafka/demos-kafka-payment-system-transfer] / src / main / java / de / juplo / kafka / payment / transfer / ports / MessagingService.java

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 81e7555..b651c20 100644 (file)
--- a/src/main/java/de/juplo/kafka/payment/transfer/ports/MessagingService.java
+++ b/src/main/java/de/juplo/kafka/payment/transfer/ports/MessagingService.java
@@ -7,5 +7,6 @@ import java.util.concurrent.CompletableFuture;
 
 public interface MessagingService
 {
-  CompletableFuture send(Transfer transfer);
+  CompletableFuture<?> send(Transfer transfer);
+  CompletableFuture<?> send(Long id, Transfer.State state);
 }