X-Git-Url: https://juplo.de/gitweb/?a=blobdiff_plain;f=transfer%2Fsrc%2Fmain%2Fjava%2Fde%2Fjuplo%2Fkafka%2Fpayment%2Ftransfer%2Fdomain%2FTransferRepository.java;h=36d027cddfb8997869037193c007b614c35ac221;hb=abea9b5c5ff90b2db1ab7bd577d644c05a4dd37f;hp=ac37192067d71fb51485d70ea6d2f300be1caccb;hpb=5bffe60126c5fa74bff59c91dfbd722d291b1c93;p=demos%2Fkafka%2Fdemos-kafka-payment-system-transfer diff --git a/transfer/src/main/java/de/juplo/kafka/payment/transfer/domain/TransferRepository.java b/transfer/src/main/java/de/juplo/kafka/payment/transfer/domain/TransferRepository.java index ac37192..36d027c 100644 --- a/transfer/src/main/java/de/juplo/kafka/payment/transfer/domain/TransferRepository.java +++ b/transfer/src/main/java/de/juplo/kafka/payment/transfer/domain/TransferRepository.java @@ -1,13 +1,15 @@ package de.juplo.kafka.payment.transfer.domain; -import de.juplo.kafka.payment.transfer.domain.Transfer; - import java.util.Optional; -import java.util.UUID; public interface TransferRepository { - void put(Transfer transfer); - Optional get(UUID uuid); + void store(Transfer transfer); + + Optional get(Long id); + + void update(Long id, Transfer.State oldState, Transfer.State newState) throws IllegalArgumentException; + + void remove(Long id); }