Hi,
First of all, thank you for great job. I have a problem for withReply() saga method. I check everything according to your project but i could not find it. I'll be happy if you can help me. Thanks..
private Message createMail(CommandMessage cm) {
......
return withLock(Mail.class, mail.getId()).withSuccess(reply); // this method is called but no message is passed to kafka. I trace it
// on kafdrop.
}
so the following method did not handle because there is no message from kafka..
......
.onReply(CreateMailCommandReply.class, CreateObligedSagaState::handleCreateMailCommandReply)
........
Hi, First of all, thank you for great job. I have a problem for withReply() saga method. I check everything according to your project but i could not find it. I'll be happy if you can help me. Thanks..
private Message createMail(CommandMessage cm) {
......
return withLock(Mail.class, mail.getId()).withSuccess(reply); // this method is called but no message is passed to kafka. I trace it
// on kafdrop.
}
so the following method did not handle because there is no message from kafka.. ......
.onReply(CreateMailCommandReply.class, CreateObligedSagaState::handleCreateMailCommandReply) ........