Lifecycle hooks
@node-ts/bus exposes a number of lifecycle hooks that can be subscribed to. These are EventEmitter instances that follow the standard node .on() and .off() notation.

Hooks

beforeSend
called just before a command is sent to the underlying transport
1
bus.beforeSend.on(({ command, attributes }) => {})
Copied!
beforePublish
called just before a event is published to the underlying transport
1
bus.beforePublish.on(({ event, attributes }) => {})
Copied!
afterReceive
called after a message has been read from the queue, and before it is dispatched to handlers
1
bus.afterReceive.on(transportMessage => {})
Copied!
beforeDispatch
called before a message is dispatched to its handlers
1
bus.beforeDispatch.on(({ message, attributes, handlers }) => {})
Copied!
afterDispatch
called after a message has been successfully handled and the message deleted from the transport
1
bus.afterDispatch.on(({ message, attributes }) => {})
Copied!
onError
called when an error occurred reading/dispatching/handling a message
1
bus.onError.on(({ message, error, attributes, rawMessage }) => {})
Copied!
Copy link
Contents
Hooks