Fixed validation for converge methods
This commit is contained in:
parent
d1048b0959
commit
51ebfd62b4
@ -104,9 +104,7 @@ namespace Tapeti.Flow.Default
|
|||||||
if (convergeMethodInfo == null)
|
if (convergeMethodInfo == null)
|
||||||
throw new InvalidDataException($"Flow ID {flowId} references converge method '{metadata.ConvergeMethodName}' which no longer exists (continuation Id = {continuationId})");
|
throw new InvalidDataException($"Flow ID {flowId} references converge method '{metadata.ConvergeMethodName}' which no longer exists (continuation Id = {continuationId})");
|
||||||
|
|
||||||
var convergeBinding = config.Bindings.ForMethod(convergeMethodInfo);
|
// Converge methods are not message handlers themselves
|
||||||
if (convergeBinding == null)
|
|
||||||
throw new InvalidDataException($"Flow ID {flowId} references converge method '{metadata.ConvergeMethodName}' which no longer has a binding as a message handler (continuation Id = {continuationId})");
|
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|
||||||
|
Loading…
Reference in New Issue
Block a user