Class default<TContent>

Handles subscriptions to RabbitMQ queues and processing of messages using provided message handler and middleware functions.

Type Parameters

TContent

Index

Constructors

Properties

Methods

handleMessage subscribe

Constructors

constructor

new default<TContent>(
    handler: MessageHandler<TContent>,
    broker: BrokerAsPromised,
    middleware?: OnMessageMiddleware<TContent>[],
    logger: Logger,
): default<TContent>
Type Parameters
- TContent
Parameters
- handler: MessageHandler<TContent>
- broker: BrokerAsPromised
- middleware: OnMessageMiddleware<TContent>[] = []
- logger: Logger
Returns default<TContent>

Properties

`Readonly`handler

handler: MessageHandler<TContent>

Methods

handleMessage

handleMessage(
    message: Message,
    envelope: MessageEnvelope<TContent>,
    ackOrNack: AckOrNack,
): Promise<void>
Wrapper to call onMessage of a MessageHandler and make sure that message processing is completed.
Parameters
- message: Message
- envelope: MessageEnvelope<TContent>
- ackOrNack: AckOrNack
Returns Promise<void>

subscribe(): Promise<SubscriberSessionAsPromised>
Initializes a subscription and attaches session event handlers to it.

Returns Promise<SubscriberSessionAsPromised>