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
stored -> log.info("transfer already exisits: {}, ignoring: {}", stored, transfer),
() ->
{
+ log.info("creating transfer: {}", transfer);
repository.store(transfer);
messagingService.send(transfer.getId(), CREATED);
});