Interface QueueProducer

Hierarchy

QueueProducer

Index

Methods

Methods

enqueue

enqueue(actor: string, session: string, options: ProducerOptions): Promise<ActionRequestContract>

- Defined in lib/queue/producer.ts:30
Parameters
- actor: string
- session: string
- options: ProducerOptions
Returns Promise<ActionRequestContract>

getLastExecutionEvent

getLastExecutionEvent(context: Context, originator: string): Promise<null | ExecuteContract>

- Defined in lib/queue/producer.ts:39
Parameters
- context: Context
- originator: string
Returns Promise<null | ExecuteContract>

Optional getNextExecutionDateTime

getNextExecutionDateTime(context: Context, session: string, scheduledActionId: string): Promise<null | string>

- Defined in lib/queue/producer.ts:43
Parameters
- context: Context
- session: string
- scheduledActionId: string
Returns Promise<null | string>

initialize

initialize(context: Context): Promise<void>

- Defined in lib/queue/producer.ts:24
Parameters
- context: Context
Returns Promise<void>

storeRequest

storeRequest(actor: string, session: string, options: ProducerOptions): Promise<ActionRequestContract>

- Defined in lib/queue/producer.ts:25
Parameters
- actor: string
- session: string
- options: ProducerOptions
Returns Promise<ActionRequestContract>

waitResults

waitResults(context: Context, actionRequest: ActionRequestContract): Promise<ProducerResults>

- Defined in lib/queue/producer.ts:35
Parameters
- context: Context
- actionRequest: ActionRequestContract
Returns Promise<ProducerResults>

Generated using TypeDoc