Class default<TContent>

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

Type Parameters

TContent

Hierarchy

default

Index

Constructors

Properties

broker handler logger middleware session

Methods

attachEventHandlers getCurrentAttempt getMessageContent getMiddleware getRecovery handleMessage messageFailure onError onInvalidContent onRedeliveriesError onRedeliveriesExceeded subscribe

Constructors

constructor

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

Properties

`Private` `Readonly` broker

broker: BrokerAsPromised

`Readonly` handler

handler: MessageHandler<TContent>

`Private` `Readonly` logger

logger: Logger

`Private` `Readonly` middleware

middleware: OnMessageMiddleware<TContent>[] = []

`Private` session

session: undefined | SubscriberSessionAsPromised

Methods

`Private` attachEventHandlers

attachEventHandlers(): void
Returns void

`Private` getCurrentAttempt

getCurrentAttempt(message): number
Parameters
- message: Message
Returns number

`Private` getMessageContent

getMessageContent(content): string | Record<string, unknown>
Parameters
- content: Buffer
Returns string | Record<string, unknown>

`Private` getMiddleware

getMiddleware(): OnMessageMiddleware<TContent>
Returns OnMessageMiddleware<TContent>

`Private` getRecovery

getRecovery(): Recovery | Recovery[]
Returns Recovery | Recovery[]

handleMessage

handleMessage(message, envelope, 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>

`Private` messageFailure

messageFailure(envelope, messageInfo, error): Promise<void>
Parameters
- envelope: MessageEnvelope<TContent>
- messageInfo: MessageInfo<TContent>
- error: Error
Returns Promise<void>

`Private` onError

onError(error): Promise<void>
Parameters
- error: Error
Returns Promise<void>

`Private` onInvalidContent

onInvalidContent(error, message, ackOrNack): Promise<void>
Parameters
- error: Error
- message: Message
- ackOrNack: AckOrNack
Returns Promise<void>

`Private` onRedeliveriesError

onRedeliveriesError(error, message, ackOrNack): Promise<void>
Parameters
- error: Error
- message: Message
- ackOrNack: AckOrNack
Returns Promise<void>

`Private` onRedeliveriesExceeded

onRedeliveriesExceeded(error, message, ackOrNack): Promise<void>
Parameters
- error: Error
- message: Message
- ackOrNack: AckOrNack
Returns Promise<void>

subscribe

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

Returns Promise<SubscriberSessionAsPromised>

Generated using TypeDoc