Middleware

MIddleware can be added between when the message is read from a transport and before it is dispatched to handlers.
Uses in telemetry
Telemetry providers like AWS Xray, New Relic, Data Dog, etc can all be used to profile and report message processing times by using middleware.
This is useful to troubleshoot low message processing rates and identify message types that are taking the longest to process and would benefit from performance tuning.
The following shows how to integrate AWS Xray to profile how messages are handled.
1
import AWSXRay from 'aws-xray-sdk'
2
import { Bus } from '@node-ts/bus-core'
3
import { Message } from '@node-ts/bus-messages'
4
​
5
const bus = await Bus.configure()
6
  .withMessageReadMiddleware(async (context, next) => {
7
    const messageName = (context.domainMessage as Message).$name
8
    const segment = new AWSXRay.Segment('my-service')
9
    const subSegment = segment.addNewSubSegment(messageName)
10
    
11
    await next()
12
    
13
    subSegment.close()
14
    segment.close()
15
  })
16
  .initialize()
Copied!
Uses in logging context
Middleware is also useful when adding context of the message handling scope to each log produced in the handling cycle.
An example of this is appending a message's correlationId to the metadata of each log. This can be done by using async_hooks that attach data to the promise scope that can be accessed by any logging request inside of it.
1
import { Bus } from '@node-ts/bus-core'
2
import * as asyncHooks from 'async_hooks'
3
​
4
type CorrelationId = string
5
// Requests to log() would look up the executionId in this map and attach the correlationId
6
export const handlingContext = new Map<number, CorrelationId>()
7
​
8
const bus = await Bus.configure()
9
  .withMessageReadMiddleware(async (context, next) => {
10
    const correlationId = context.attributes.correlationId
11
    const executionId = asyncHooks.executionAsyncId()
12
    
13
    handlingContext.set(executionId, correlationId)
14
    await next()
15
    handlingContext.delete(executionId)
16
  })
17
  .initialize()
Copied!

Custom loggers

Next - Guide

Lifecycle hooks

Last modified 6mo ago

Copy link

Contents

Uses in telemetry

Uses in logging context