Interface MessageQueueEvents<TMessage>

interface MessageQueueEvents<TMessage extends WithOptionalObjectId> {
    deadLetter: (
        err: Error,
        message: WithId<TMessage>,
        group: string,
    ) => void;
    drained: (group: string) => void;
    error: (err: Error, message?: TMessage, group?: string) => void;
    [key: string]: GenericListener;
}

Type Parameters

Hierarchy (View Summary)

Indexable

  • [key: string]: GenericListener

Properties

deadLetter: (err: Error, message: WithId<TMessage>, group: string) => void
drained: (group: string) => void
error: (err: Error, message?: TMessage, group?: string) => void