Connectum API Reference / @connectum/events / types / EventAdapter
Interface: EventAdapter
Defined in: packages/events/src/types.ts:112
Minimal adapter interface for message brokers.
Inspired by Watermill (Go): minimal surface, broker-specific config in constructor, not in interface methods.
Properties
name
readonlyname:string
Defined in: packages/events/src/types.ts:114
Adapter name for identification (e.g., "nats", "kafka", "redis", "memory")
Methods
connect()
connect(
context?):Promise<void>
Defined in: packages/events/src/types.ts:123
Connect to the message broker.
Parameters
context?
Optional adapter context with service-level information derived from proto service descriptors. Adapters may use context.serviceName for broker-level client identification.
Returns
Promise<void>
disconnect()
disconnect():
Promise<void>
Defined in: packages/events/src/types.ts:126
Disconnect from the message broker
Returns
Promise<void>
publish()
publish(
eventType,payload,options?):Promise<void>
Defined in: packages/events/src/types.ts:129
Publish a serialized event to a topic
Parameters
eventType
string
payload
Uint8Array
options?
Returns
Promise<void>
subscribe()
subscribe(
patterns,handler,options?):Promise<EventSubscription>
Defined in: packages/events/src/types.ts:132
Subscribe to event patterns with a raw handler
Parameters
patterns
string[]
handler
options?
Returns
Promise<EventSubscription>