OCP App SDK / Consumer

Consumer<T>

Type parameters

• T extends JSONEncodable

Index

Constructors

• constructor

Methods

• perform

Constructors

constructor()

Signature

new Consumer<T>(): Consumer<T>;

Type parameters

• T extends JSONEncodable

Returns

Consumer<T>

Methods

perform()

Processes a batch of messages. Consumers should process a batch of messages and return a result containing
the success or failure of batch.
A batch should be processed in a timely manner. This means the batch size needs to be
adjusted to ensure timely processing.

Signature

Abstract perform(batch: Batch<T>): Promise<ConsumerResult>;

Parameters

Returns

Promise<ConsumerResult>

The result of the batch processing.

Defined in: src/app/Consumer.ts:22