projects
/
demos
/
kafka
/
demos-kafka-payment-system-transfer
/ blobdiff
commit
grep
author
committer
pickaxe
?
search:
re
summary
|
shortlog
|
log
|
commit
|
commitdiff
|
tree
raw
|
inline
| side by side
Automatically rebuild the state after a crash / restart
[demos/kafka/demos-kafka-payment-system-transfer]
/
src
/
main
/
java
/
de
/
juplo
/
kafka
/
payment
/
transfer
/
domain
/
TransferService.java
diff --git
a/src/main/java/de/juplo/kafka/payment/transfer/domain/TransferService.java
b/src/main/java/de/juplo/kafka/payment/transfer/domain/TransferService.java
index
7a2349a
..
00c5478
100644
(file)
--- a/
src/main/java/de/juplo/kafka/payment/transfer/domain/TransferService.java
+++ b/
src/main/java/de/juplo/kafka/payment/transfer/domain/TransferService.java
@@
-7,7
+7,8
@@
import lombok.extern.slf4j.Slf4j;
import java.util.Optional;
import java.util.Optional;
-import static de.juplo.kafka.payment.transfer.domain.Transfer.State.*;
+import static de.juplo.kafka.payment.transfer.domain.Transfer.State.CHECKED;
+import static de.juplo.kafka.payment.transfer.domain.Transfer.State.CREATED;
@Slf4j
@Slf4j
@@
-26,6
+27,7
@@
public class TransferService implements CreateTransferUseCase, HandleStateChange
stored -> log.info("transfer already exisits: {}, ignoring: {}", stored, transfer),
() ->
{
stored -> log.info("transfer already exisits: {}, ignoring: {}", stored, transfer),
() ->
{
+ log.info("creating transfer: {}", transfer);
repository.store(transfer);
messagingService.send(transfer.getId(), CREATED);
});
repository.store(transfer);
messagingService.send(transfer.getId(), CREATED);
});