@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

Peer dependencies: @connectum/core, @bufbuild/protobuf ^2.16.0 and @connectrpc/connect ^2.2.0, shared with your application. npm 7+, pnpm and Bun install missing peers automatically; on Yarn, add them yourself — see Peer dependencies on protobuf and Connect.

Start Here

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

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

await eventBus.start();

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.
EventAdapterFactory	Give each broadcast reactor its own broker connection; see Adapter instances and factories.

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.