Install the npm package into your application.

npm i @node-ts/bus-core @node-ts/bus-messages --save

Configure and initialize the bus when your application starts up.

import { Bus } from '@node-ts/bus-core'

async function run () {
  const bus = await Bus.configure().initialize()

This is the most basic of setups and your app is running an in memory queue capable of receiving messages from itself. In production, it's strongly recommended to configure a transport so that your application can be distributed and survive restarts.

Last updated