I have similar issue with using RavenDb saga repository. It happens with just two messages and CombinedEvent, the waiting bit was overriding in a race condition. When I turned on RavenDb optimistic concurrency, it started to fail on the wrong instance version. I do have the retry policy configured but this seems to have no effect on saga. At least for me it does not retry, just crashes the whole thing. I do not have any solution for this though, we are now using in memory repository since we are not in production yet but this is not acceptable.
My view on this that messages that are related to one saga instance should not be processed in parallel but rather put in a sequence or queue in memory and not ACKed until saga actually processed them. When saga state gets updated (this includes joins) and messages come fast, parallel processing causes version conflicts.
--
You received this message because you are subscribed to the Google Groups "masstransit-discuss" group.
To unsubscribe from this group and stop receiving emails from it, send an email to masstransit-dis...@googlegroups.com.
To post to this group, send email to masstrans...@googlegroups.com.
To view this discussion on the web visit https://groups.google.com/d/msgid/masstransit-discuss/f4301245-3e36-4bf2-8dc8-e866083b04b9%40googlegroups.com.
You received this message because you are subscribed to a topic in the Google Groups "masstransit-discuss" group.
To unsubscribe from this topic, visit https://groups.google.com/d/topic/masstransit-discuss/IJrc1BG_f80/unsubscribe.
To unsubscribe from this group and all its topics, send an email to masstransit-dis...@googlegroups.com.
To view this discussion on the web visit https://groups.google.com/d/msgid/masstransit-discuss/CAHX4WYcKL8aH9LKW2qcxj_sk8VPxePDvEZ%2BSWaB6ntnP8tfpkA%40mail.gmail.com.
ec.LoadConsumers(context, contextName);
ec.LoadStateMachineSagas(context, contextName);
if (serviceBusSettings.Retries > 0)
{
ec.UseRetry(Retry.Exponential(
serviceBusSettings.Retries,
serviceBusSettings.RetryMinInterval,
serviceBusSettings.RetryMaxInterval,
serviceBusSettings.RetryIntervalDelta));
}
--
You received this message because you are subscribed to the Google Groups "masstransit-discuss" group.
To unsubscribe from this group and stop receiving emails from it, send an email to masstransit-dis...@googlegroups.com.
To post to this group, send email to masstrans...@googlegroups.com.
To view this discussion on the web visit https://groups.google.com/d/msgid/masstransit-discuss/8665fd9d-98b4-4a56-9abc-1b0a6ad5bcf3%40googlegroups.com.
--
You received this message because you are subscribed to the Google Groups "masstransit-discuss" group.
To unsubscribe from this group and stop receiving emails from it, send an email to masstransit-dis...@googlegroups.com.
To post to this group, send email to masstrans...@googlegroups.com.
To view this discussion on the web visit https://groups.google.com/d/msgid/masstransit-discuss/59d80faa-d644-4812-a876-2d1d44b2502a%40googlegroups.com.
You received this message because you are subscribed to a topic in the Google Groups "masstransit-discuss" group.
To unsubscribe from this topic, visit https://groups.google.com/d/topic/masstransit-discuss/IJrc1BG_f80/unsubscribe.
To unsubscribe from this group and all its topics, send an email to masstransit-dis...@googlegroups.com.
To view this discussion on the web visit https://groups.google.com/d/msgid/masstransit-discuss/CAHX4WYdJrHotAoTqg-C8kK2%2BSwVawWLiov%3D8mGVUFLdS4%3DqBRw%40mail.gmail.com.