import lombok.extern.slf4j.Slf4j;
import org.apache.kafka.clients.producer.KafkaProducer;
import org.apache.kafka.clients.producer.ProducerRecord;
-import org.springframework.http.ResponseEntity;
-import java.net.URI;
-import java.util.UUID;
+import java.util.Optional;
import static de.juplo.kafka.payment.transfer.domain.Transfer.State.*;
},
() ->
{
- repository.store(transfer);
send(transfer);
+ transfer.setState(SENT);
+ repository.store(transfer);
});
}
throw new RuntimeException("Could not convert " + transfer, e);
}
}
+
+ public Optional<Transfer> get(Long id)
+ {
+ return repository.get(id);
+ }
}