Class Consumer

Hierarchy

Consumer

Implements

QueueConsumer

Index

Constructors

constructor

Properties

Methods

Constructors

constructor

new Consumer(kernel: Kernel, pool: Pool, session: string): Consumer

- Defined in lib/consumer.ts:102
Parameters
- kernel: Kernel
- pool: Pool
- session: string
Returns Consumer

Properties

graphileRunner

graphileRunner: null | Runner = null

messagesBeingHandled

messagesBeingHandled: number = 0

Methods

cancel

cancel(): Promise<void>

Implementation of QueueConsumer.cancel
- Defined in lib/consumer.ts:174
Returns Promise<void>

initializeWithEventHandler

initializeWithEventHandler(logContext: LogContext, onMessageEventHandler: OnMessageEventHandler): Promise<void>

Implementation of QueueConsumer.initializeWithEventHandler
- Defined in lib/consumer.ts:108
Parameters
- logContext: LogContext
- onMessageEventHandler: OnMessageEventHandler
Returns Promise<void>

postResults

postResults(_actor: string, logContext: LogContext, actionRequest: ActionRequestContract, results: PostResults): Promise<ExecuteContract>

Implementation of QueueConsumer.postResults
- Defined in lib/consumer.ts:198
summary
Post execution results

function
Parameters
- _actor: string
- logContext: LogContext
  
  log context
- actionRequest: ActionRequestContract
  
  action request
- results: PostResults
  
  action results
Returns Promise<ExecuteContract>
execute event card

run

run(logContext: LogContext, onMessageEventHandler: OnMessageEventHandler, retries?: number): Promise<boolean>

Implementation of QueueConsumer.run
- Defined in lib/consumer.ts:123
Parameters
- logContext: LogContext
- onMessageEventHandler: OnMessageEventHandler
- retries: number = RUN_RETRIES
Returns Promise<boolean>

Generated using TypeDoc