DeadLetterStore
Αυτό το περιεχόμενο δεν είναι ακόμη διαθέσιμο στη γλώσσα σου.
Defined in: packages/pipeline-deadletter/src/interfaces/dead-letter-transport.interface.ts:101
A transport that also keeps its records, so they can be listed, redriven
with DeadLetterRedriver, and resolved. PostgresDeadLetterTransport
implements it; queue transports rely on their broker’s own dead-letter tooling.
Extends
Section titled “Extends”Methods
Section titled “Methods”get(
id):Promise<DeadLetterRecord|undefined>
Defined in: packages/pipeline-deadletter/src/interfaces/dead-letter-transport.interface.ts:103
The record with this id, or undefined.
Parameters
Section titled “Parameters”string
Returns
Section titled “Returns”Promise<DeadLetterRecord | undefined>
list()
Section titled “list()”list(
filter?):Promise<DeadLetterRecord[]>
Defined in: packages/pipeline-deadletter/src/interfaces/dead-letter-transport.interface.ts:105
Records matching the filter, oldest first.
Parameters
Section titled “Parameters”filter?
Section titled “filter?”Returns
Section titled “Returns”markResolved()
Section titled “markResolved()”markResolved(
id):Promise<void>
Defined in: packages/pipeline-deadletter/src/interfaces/dead-letter-transport.interface.ts:109
Closes the record.
Parameters
Section titled “Parameters”string
Returns
Section titled “Returns”Promise<void>
recordAttempt()
Section titled “recordAttempt()”recordAttempt(
id,error):Promise<void>
Defined in: packages/pipeline-deadletter/src/interfaces/dead-letter-transport.interface.ts:107
Counts one failed redrive attempt and keeps its error.
Parameters
Section titled “Parameters”string
Returns
Section titled “Returns”Promise<void>
send()
Section titled “send()”send(
record):Promise<void>
Defined in: packages/pipeline-deadletter/src/interfaces/dead-letter-transport.interface.ts:85
Persist / publish a single dead-letter record.
Implementations should be resilient and fast; a throw here is caught by the behavior and logged, but never masks the original handler error.
Parameters
Section titled “Parameters”record
Section titled “record”The failed request snapshot to forward.
Returns
Section titled “Returns”Promise<void>