Skip to main content

Interface: QueueManager<T>

Type parameters​

Name
T

Methods​

consume​

▸ consume(): Observable<T>

Consume messages from the queue

Returns​

Observable<T>

produce​

▸ produce(messages): Promise<void>

Publish messages to the queue

Parameters​

NameType
messagesT[]

Returns​

Promise<void>