1 package de.juplo.kafka.payment.transfer.ports;
3 import de.juplo.kafka.payment.transfer.domain.Transfer;
5 import java.util.concurrent.CompletableFuture;
8 public interface MessagingService
10 CompletableFuture<?> send(Transfer transfer);
11 CompletableFuture<?> send(Long id, Transfer.State state);