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%2Fdomain%2FTransferService.java;h=00c54787a9cfa681e6a948198ff701221360001f;hp=7a2349ae90f38f15c39b9889feefa627f7214b4b;hb=edc88d6eac8c502ab0297380489ccc9ba706b5f0;hpb=26809d379a0e024017f70db8c70382f94faf98b6

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
--- 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 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
@@ -26,6 +27,7 @@ public class TransferService implements CreateTransferUseCase, HandleStateChange
             stored -> log.info("transfer already exisits: {}, ignoring: {}", stored, transfer),
             () ->
             {
+              log.info("creating transfer: {}", transfer);
               repository.store(transfer);
               messagingService.send(transfer.getId(), CREATED);
             });