Skip to content

Connectum API Reference / @connectum/events / types / EventBusOptions

Interface: EventBusOptions

Defined in: packages/events/src/types.ts:279

EventBus configuration options for createEventBus()

Properties

adapter

adapter: EventAdapter

Defined in: packages/events/src/types.ts:281

Adapter instance (e.g., NatsAdapter, KafkaAdapter, MemoryAdapter)


drainTimeout?

optional drainTimeout: number

Defined in: packages/events/src/types.ts:310

Maximum time in milliseconds to wait for in-flight event handlers to complete during shutdown. After this timeout, remaining handlers are force-aborted via AbortSignal.

Default: 30000 (30 seconds). Set to 0 for immediate abort.


group?

optional group: string

Defined in: packages/events/src/types.ts:285

Consumer group name


handlerTimeout?

optional handlerTimeout: number

Defined in: packages/events/src/types.ts:302

Per-event handler timeout in milliseconds.

Each event handler invocation gets an AbortSignal that fires after this duration. Default: 30000 (30 seconds).


middleware?

optional middleware: MiddlewareConfig

Defined in: packages/events/src/types.ts:287

Middleware configuration


routes?

optional routes: EventRoute[]

Defined in: packages/events/src/types.ts:283

Event routes to register


signal?

optional signal: AbortSignal

Defined in: packages/events/src/types.ts:295

Abort signal for graceful shutdown.

When provided, per-event signals are composed via AbortSignal.any() so that server shutdown aborts in-flight event processing. Automatically set when used with createServer({ eventBus }).