Appearance

Connectum API Reference / @connectum/events / createEventBus

Function: createEventBus() ​

createEventBus(options): EventBus & EventBusLike

Defined in: packages/events/src/EventBus.ts:71

Create an EventBus instance.

Parameters ​

options ​

EventBusOptions

EventBus configuration

Returns ​

EventBus & EventBusLike

EventBus instance implementing EventBusLike for server integration

Example ​

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

const eventBus = createEventBus({
  adapter: MemoryAdapter(),
  routes: [myEventRoutes],
  middleware: {
    retry: { maxRetries: 3, backoff: 'exponential' },
    dlq: { topic: 'my-service.dlq' },
  },
});

await eventBus.start();
await eventBus.publish(UserCreatedSchema, { id: '1', email: '[email protected]', name: 'Test' });
await eventBus.stop();