test: assert blocked Kafka rows cannot be claimed
This commit is contained in:
@@ -36,8 +36,9 @@ try {
|
||||
const appendB = store.appendEvent(runB.id, "backend_status", { phase: "pg-order-b", orderMarker: "B" })
|
||||
.finally(() => { appendBSettled = true; });
|
||||
await delay(250);
|
||||
const preReleaseClaim = await store.claimKafkaEventOutbox({ owner: "pre-release", leaseMs: 60_000, limit: 1 });
|
||||
assert.equal(preReleaseClaim.length, 0, "same-session event B became relay-claimable while event A was still uncommitted");
|
||||
assert.equal(appendBSettled, false, "same-session event B committed before blocked event A");
|
||||
assert.deepEqual(await store.claimKafkaEventOutbox({ owner: "pre-release", leaseMs: 60_000, limit: 1 }), [], "uncommitted event A must not be bypassed by event B");
|
||||
|
||||
await gateClient.query("SELECT pg_advisory_unlock($1::bigint)", [gate]);
|
||||
gateHeld = false;
|
||||
|
||||
Reference in New Issue
Block a user