Interface QueueManager<T>

Interface defining the operations available for a queue manager. Allows producing and consuming messages from a queue.

interface QueueManager<T> {
consume(): Observable<T>;
produce(messages: T[]): Promise<void>;
}

Type Parameters

T

Index

Methods

consume produce

Methods

consume

consume(): Observable<T>
Consume messages from the queue

Returns Observable<T>

produce

produce(messages: T[]): Promise<void>
Publish messages to the queue
Parameters
- messages: T[]
Returns Promise<void>