integrationspackages/integrations/event-bus
event-bus package
In-process pub/sub with cross-app fanout. Used by audit, billing, and notifications to react to commerce events without circular imports.
- Stability
- Stable
- Scope
- Global
- Boundary
- packages/integrations/event-bus
event-buspackages/integrations/event-bus
Provider-agnostic
Available providers
NATSstandby
KafkaActive
Inngeststandby
Inbound requestevent-bus
{ topic: "orders.created", v: 1 }
Adapter resolve3ms
event-bus Dispatch100ms
Acked2ms
Provider
Kafka
Latency p50
110 ms
Success rate
98%
+0.7%
Volume today
6,028
packages/integrations/event-busprovider-agnostic
Usageevent-bus.ts
typescriptevent-bus.ts
1import { getEventBusProvider } from "@nebutra/event-bus";
2
3// Provider-agnostic — backend chosen from env at runtime.
4const eventBus = await getEventBusProvider();
5
6await eventBus.connect({ tenantId: org.id });