Class AsyncOutboxConsumer<Message>

Type Parameters

Message extends JSONValue

Implements

IAsyncOutboxConsumer<Message>

Index

Constructors

Methods

send start stop

Constructors

constructor

new AsyncOutboxConsumer<Message extends JSONValue>(
_params: ConsumerCreationParams<Message>,
): AsyncOutboxConsumer<Message>
Type Parameters
- Message extends JSONValue
Parameters
- _params: ConsumerCreationParams<Message>
Returns AsyncOutboxConsumer<Message>
- Defined in asyncOutbox/AsyncOutboxConsumer.ts:72

Methods

send

send(
message: MessageEnvelope<Message> | MessageEnvelope<Message>[],
options?: PublishOptions,
): Promise<void>
Parameters
- message: MessageEnvelope<Message> | MessageEnvelope<Message>[]
- Optionaloptions: PublishOptions
Returns Promise<void>
Implementation of IAsyncOutboxConsumer.send
- Defined in asyncOutbox/AsyncOutboxConsumer.ts:77

start

start(): Stop
Returns Stop
Implementation of IAsyncOutboxConsumer.start
- Defined in asyncOutbox/AsyncOutboxConsumer.ts:101

stop

stop(): Promise<void>
Returns Promise<void>
Implementation of IAsyncOutboxConsumer.stop
- Defined in asyncOutbox/AsyncOutboxConsumer.ts:112