MessageJobProcessor
Defined in: packages/messaging/src/queue/job.processor.ts:350
Specific processor for message jobs
Extends
섹션 제목: “Extends”Constructors
섹션 제목: “Constructors”Constructor
섹션 제목: “Constructor”new MessageJobProcessor(
provider,options?,jobQueue?):MessageJobProcessor
Defined in: packages/messaging/src/queue/job.processor.ts:351
Parameters
섹션 제목: “Parameters”provider
섹션 제목: “provider”options?
섹션 제목: “options?”Partial<JobProcessorOptions> = {}
jobQueue?
섹션 제목: “jobQueue?”JobQueue<any>
Returns
섹션 제목: “Returns”MessageJobProcessor
Overrides
섹션 제목: “Overrides”Methods
섹션 제목: “Methods”add()
섹션 제목: “add()”add<
T>(jobType,data,options?):Promise<string>
Defined in: packages/messaging/src/queue/job.processor.ts:107
Add a job to the queue
Type Parameters
섹션 제목: “Type Parameters”T
Parameters
섹션 제목: “Parameters”jobType
섹션 제목: “jobType”string
data
섹션 제목: “data”T
options?
섹션 제목: “options?”delay?
섹션 제목: “delay?”number
maxAttempts?
섹션 제목: “maxAttempts?”number
metadata?
섹션 제목: “metadata?”Record<string, any>
priority?
섹션 제목: “priority?”number
Returns
섹션 제목: “Returns”Promise<string>
Inherited from
섹션 제목: “Inherited from”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”cleanup()
섹션 제목: “cleanup()”cleanup():
Promise<number>
Defined in: packages/messaging/src/queue/job.processor.ts:191
Remove completed jobs from queue
Returns
섹션 제목: “Returns”Promise<number>
Inherited from
섹션 제목: “Inherited from”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”getJob()
섹션 제목: “getJob()”getJob(
jobId):Promise<Job<any> |undefined>
Defined in: packages/messaging/src/queue/job.processor.ts:202
Get specific job by ID
Parameters
섹션 제목: “Parameters”jobId
섹션 제목: “jobId”string
Returns
섹션 제목: “Returns”Promise<Job<any> | undefined>
Inherited from
섹션 제목: “Inherited from”getMetrics()
섹션 제목: “getMetrics()”getMetrics():
JobProcessorMetrics
Defined in: packages/messaging/src/queue/job.processor.ts:165
Get current metrics
Returns
섹션 제목: “Returns”Inherited from
섹션 제목: “Inherited from”getQueueStatus()
섹션 제목: “getQueueStatus()”getQueueStatus():
Promise<{failed:number;pending:number;processing:number;totalProcessed:number; }>
Defined in: packages/messaging/src/queue/job.processor.ts:172
Get queue status
Returns
섹션 제목: “Returns”Promise<{ failed: number; pending: number; processing: number; totalProcessed: number; }>
Inherited from
섹션 제목: “Inherited from”handle()
섹션 제목: “handle()”handle<
T>(jobType,handler):void
Defined in: packages/messaging/src/queue/job.processor.ts:100
Register a job handler
Type Parameters
섹션 제목: “Type Parameters”T
Parameters
섹션 제목: “Parameters”jobType
섹션 제목: “jobType”string
handler
섹션 제목: “handler”JobHandler<T>
Returns
섹션 제목: “Returns”void
Inherited from
섹션 제목: “Inherited from”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”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”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”queueBulkMessages()
섹션 제목: “queueBulkMessages()”queueBulkMessages(
messageRequests,options?):Promise<string>
Defined in: packages/messaging/src/queue/job.processor.ts:589
Add bulk messages to the processing queue
Parameters
섹션 제목: “Parameters”messageRequests
섹션 제목: “messageRequests”options?
섹션 제목: “options?”delay?
섹션 제목: “delay?”number
metadata?
섹션 제목: “metadata?”Record<string, any>
priority?
섹션 제목: “priority?”number
Returns
섹션 제목: “Returns”Promise<string>
queueMessage()
섹션 제목: “queueMessage()”queueMessage(
messageRequest,options?):Promise<string>
Defined in: packages/messaging/src/queue/job.processor.ts:561
Add a message to the processing queue
Parameters
섹션 제목: “Parameters”messageRequest
섹션 제목: “messageRequest”options?
섹션 제목: “options?”delay?
섹션 제목: “delay?”number
metadata?
섹션 제목: “metadata?”Record<string, any>
priority?
섹션 제목: “priority?”number
Returns
섹션 제목: “Returns”Promise<string>
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”JobProcessor.removeAllListeners
removeJob()
섹션 제목: “removeJob()”removeJob(
jobId):Promise<boolean>
Defined in: packages/messaging/src/queue/job.processor.ts:209
Remove job from queue
Parameters
섹션 제목: “Parameters”jobId
섹션 제목: “jobId”string
Returns
섹션 제목: “Returns”Promise<boolean>
Inherited from
섹션 제목: “Inherited from”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”scheduleMessage()
섹션 제목: “scheduleMessage()”scheduleMessage(
messageRequest,scheduledAt,options?):Promise<string>
Defined in: packages/messaging/src/queue/job.processor.ts:607
Schedule a message for future delivery
Parameters
섹션 제목: “Parameters”messageRequest
섹션 제목: “messageRequest”scheduledAt
섹션 제목: “scheduledAt”Date
options?
섹션 제목: “options?”metadata?
섹션 제목: “metadata?”Record<string, any>
Returns
섹션 제목: “Returns”Promise<string>
start()
섹션 제목: “start()”start():
void
Defined in: packages/messaging/src/queue/job.processor.ts:133
Start processing jobs
Returns
섹션 제목: “Returns”void
Inherited from
섹션 제목: “Inherited from”stop()
섹션 제목: “stop()”stop():
Promise<void>
Defined in: packages/messaging/src/queue/job.processor.ts:146
Stop processing jobs
Returns
섹션 제목: “Returns”Promise<void>