OCP App SDK / Consumer
new Consumer<T>(): Consumer<T>;
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.
Abstract perform(batch: Batch<T>): Promise<ConsumerResult>;
|The batch of messages to process.|
The result of the batch processing.
Defined in: src/app/Consumer.ts:22
Updated 11 days ago