MessageRetryHandler
Defined in: packages/messaging/src/queue/retry.handler.ts:71
Extends
섹션 제목: “Extends”EventEmitter
Constructors
섹션 제목: “Constructors”Constructor
섹션 제목: “Constructor”new MessageRetryHandler(
options):MessageRetryHandler
Defined in: packages/messaging/src/queue/retry.handler.ts:93
Parameters
섹션 제목: “Parameters”options
섹션 제목: “options”Returns
섹션 제목: “Returns”MessageRetryHandler
Overrides
섹션 제목: “Overrides”EventEmitter.constructor
Methods
섹션 제목: “Methods”addForRetry()
섹션 제목: “addForRetry()”addForRetry(
deliveryReport):Promise<boolean>
Defined in: packages/messaging/src/queue/retry.handler.ts:143
Add a failed delivery for retry
Parameters
섹션 제목: “Parameters”deliveryReport
섹션 제목: “deliveryReport”Returns
섹션 제목: “Returns”Promise<boolean>
addListener()
섹션 제목: “addListener()”addListener(
eventName,listener):this
Defined in: packages/messaging/src/shared/event-emitter.ts:16
Parameters
섹션 제목: “Parameters”eventName
섹션 제목: “eventName”string
listener
섹션 제목: “listener”Listener
Returns
섹션 제목: “Returns”this
Inherited from
섹션 제목: “Inherited from”EventEmitter.addListener
cancelRetry()
섹션 제목: “cancelRetry()”cancelRetry(
messageId):boolean
Defined in: packages/messaging/src/queue/retry.handler.ts:188
Cancel retry for a specific message
Parameters
섹션 제목: “Parameters”messageId
섹션 제목: “messageId”string
Returns
섹션 제목: “Returns”boolean
cleanup()
섹션 제목: “cleanup()”cleanup():
number
Defined in: packages/messaging/src/queue/retry.handler.ts:224
Clean up completed/exhausted retry items
Returns
섹션 제목: “Returns”number
emit()
섹션 제목: “emit()”emit(
eventName, …args):boolean
Defined in: packages/messaging/src/shared/event-emitter.ts:44
Parameters
섹션 제목: “Parameters”eventName
섹션 제목: “eventName”string
args
섹션 제목: “args”…unknown[]
Returns
섹션 제목: “Returns”boolean
Inherited from
섹션 제목: “Inherited from”EventEmitter.emit
getMetrics()
섹션 제목: “getMetrics()”getMetrics():
RetryHandlerMetrics
Defined in: packages/messaging/src/queue/retry.handler.ts:217
Get metrics
Returns
섹션 제목: “Returns”getRetryQueue()
섹션 제목: “getRetryQueue()”getRetryQueue():
RetryQueueItem[]
Defined in: packages/messaging/src/queue/retry.handler.ts:210
Get all retry queue items
Returns
섹션 제목: “Returns”getRetryStatus()
섹션 제목: “getRetryStatus()”getRetryStatus(
messageId):RetryQueueItem|undefined
Defined in: packages/messaging/src/queue/retry.handler.ts:203
Get retry status for a message
Parameters
섹션 제목: “Parameters”messageId
섹션 제목: “messageId”string
Returns
섹션 제목: “Returns”RetryQueueItem | undefined
off()
섹션 제목: “off()”off(
eventName,listener):this
Defined in: packages/messaging/src/shared/event-emitter.ts:20
Parameters
섹션 제목: “Parameters”eventName
섹션 제목: “eventName”string
listener
섹션 제목: “listener”Listener
Returns
섹션 제목: “Returns”this
Inherited from
섹션 제목: “Inherited from”EventEmitter.off
on()
섹션 제목: “on()”on(
eventName,listener):this
Defined in: packages/messaging/src/shared/event-emitter.ts:9
Parameters
섹션 제목: “Parameters”eventName
섹션 제목: “eventName”string
listener
섹션 제목: “listener”Listener
Returns
섹션 제목: “Returns”this
Inherited from
섹션 제목: “Inherited from”EventEmitter.on
once()
섹션 제목: “once()”once(
eventName,listener):this
Defined in: packages/messaging/src/shared/event-emitter.ts:35
Parameters
섹션 제목: “Parameters”eventName
섹션 제목: “eventName”string
listener
섹션 제목: “listener”Listener
Returns
섹션 제목: “Returns”this
Inherited from
섹션 제목: “Inherited from”EventEmitter.once
removeAllListeners()
섹션 제목: “removeAllListeners()”removeAllListeners(
eventName?):this
Defined in: packages/messaging/src/shared/event-emitter.ts:57
Parameters
섹션 제목: “Parameters”eventName?
섹션 제목: “eventName?”string
Returns
섹션 제목: “Returns”this
Inherited from
섹션 제목: “Inherited from”EventEmitter.removeAllListeners
removeListener()
섹션 제목: “removeListener()”removeListener(
eventName,listener):this
Defined in: packages/messaging/src/shared/event-emitter.ts:31
Parameters
섹션 제목: “Parameters”eventName
섹션 제목: “eventName”string
listener
섹션 제목: “listener”Listener
Returns
섹션 제목: “Returns”this
Inherited from
섹션 제목: “Inherited from”EventEmitter.removeListener
start()
섹션 제목: “start()”start():
void
Defined in: packages/messaging/src/queue/retry.handler.ts:111
Start the retry handler
Returns
섹션 제목: “Returns”void
stop()
섹션 제목: “stop()”stop():
Promise<void>
Defined in: packages/messaging/src/queue/retry.handler.ts:124
Stop the retry handler
Returns
섹션 제목: “Returns”Promise<void>