Package Exports

@node-ts/bus-core
@node-ts/bus-core/dist/index.js
@node-ts/bus-core/dist/service-bus
@node-ts/bus-core/dist/service-bus/index.js
@node-ts/bus-core/dist/transport
@node-ts/bus-core/dist/transport/index.js
@node-ts/bus-core/dist/util/class-constructor
@node-ts/bus-core/dist/util/class-constructor.js

This package does not declare an exports field, so the exports above have been automatically detected and optimized by JSPM instead. If any package subpath is missing, it is recommended to post an issue to the original package (@node-ts/bus-core) to support the "exports" field. If that is not possible, create a JSPM override to customize the exports field for this package.

Readme

@node-ts/bus-core

The core messaging framework. This package provides an in-memory queue and persistence by default, but is designed to be used with other @node-ts/bus-* packages that provide compatibility with other transports (SQS, RabbitMQ, Azure Queues) and persistence technologies (PostgreSQL, SQL Server, Oracle).

🔥 View our docs at https://bus.node-ts.com 🔥

🤔 Have a question? Join the Discussion 🤔

Installation

Download and install the packages:

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()

  // Start listening for messages and dispatch them to handlers when read
  await bus.start()
}

For more information, visit our docs at https://bus.node-ts.com