File tree Expand file tree Collapse file tree 1 file changed +6
-0
lines changed Expand file tree Collapse file tree 1 file changed +6
-0
lines changed Original file line number Diff line number Diff line change @@ -26,6 +26,7 @@ export type OutboxEntry<SupportedEvent extends CommonEventDefinition> = {
26
26
created : Date
27
27
updated ?: Date
28
28
retryCount : number
29
+ lockedUntil ?: Date
29
30
}
30
31
31
32
/**
@@ -53,6 +54,11 @@ export interface OutboxStorage<SupportedEvents extends CommonEventDefinition[]>
53
54
getEntries ( maxRetryCount : number ) : Promise < OutboxEntry < SupportedEvents [ number ] > [ ] >
54
55
}
55
56
57
+ /**
58
+ * Main logic for handling outbox entries.
59
+ *
60
+ * If entry is rejected, it is NOT going to be handled during the same execution. Next execution will pick it up.
61
+ */
56
62
export class OutboxProcessor < SupportedEvents extends CommonEventDefinition [ ] > {
57
63
constructor (
58
64
private readonly outboxStorage : OutboxStorage < SupportedEvents > ,
You can’t perform that action at this time.
0 commit comments