Skip to content

Commit d9e3d41

Browse files
committed
fetching entries up to the retry count limit.
1 parent 5ad155f commit d9e3d41

File tree

1 file changed

+11
-0
lines changed

1 file changed

+11
-0
lines changed

packages/outbox-prisma-adapter/test/outbox-prisma-adapter.spec.ts

Lines changed: 11 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -242,4 +242,15 @@ describe('outbox-prisma-adapter', () => {
242242
},
243243
])
244244
})
245+
246+
it('should not fetch entries that exceed retry limit', async () => {
247+
const failedEntry = { ...ENTRY_1, retryCount: 6, status: 'FAILED' } satisfies OutboxEntry<
248+
SupportedEvents[number]
249+
>
250+
await outboxPrismaAdapter.createEntry(failedEntry)
251+
252+
const entries = await outboxPrismaAdapter.getEntries(5)
253+
254+
expect(entries).toEqual([])
255+
})
245256
})

0 commit comments

Comments
 (0)