We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
2 parents 0a55ba5 + 14e3af8 commit dae82ccCopy full SHA for dae82cc
1 file changed
Source/events.processing/Internal/EventProcessor.ts
@@ -85,8 +85,7 @@ export abstract class EventProcessor<TIdentifier extends ConceptAs<Guid, string>
85
const failure = new ProcessorFailure();
86
failure.setReason(`${error}`);
87
failure.setRetry(true);
88
- const retryAttempt = (retryProcessingState?.getRetrycount() ?? 0) + 1;
89
- const retrySeconds = Math.min(5 * retryAttempt, 60);
+ const retrySeconds = retryProcessingState === undefined ? 5 : Math.min(5 * (retryProcessingState.getRetrycount() + 2), 60);
90
const retryTimeout = new Duration();
91
retryTimeout.setSeconds(retrySeconds);
92
failure.setRetrytimeout(retryTimeout);
0 commit comments