@connectum/events

Proto-first publish/subscribe with routes, middleware, retries, dead letters, and pluggable adapters.

Install

npm install @connectum/events

pnpm add @connectum/events

bun add @connectum/events

Start Here

import { createEventBus, MemoryAdapter } from '@connectum/events';

const eventBus = createEventBus({
  adapter: MemoryAdapter(),
  routes: [orderEvents],
  group: 'orders-service',
});

await eventBus.start();

For a complete, source-verified workflow, continue with the focused guide below.

Key Entry Points

Entry point	Use it to
createEventBus	Create the lifecycle-managed event bus.
MemoryAdapter	Run deterministic in-memory event tests.
createBroadcastSubscribers	Create explicit one-to-many reactor subscribers.

Runtime boundaries and extension seams remain in Connectum Runtime Architecture.

Learn / Configure / API Reference

• Learn: Focused guide
• Configure: Task and configuration guidance
• API reference: Exact options and symbols
• Package API index: Generated TypeDoc
• Source: @connectum/events on GitHub

Related Modules

Compare all Connectum packages by capability.