Connectum API Reference / @connectum/events / types / EventAdapter
Interface: EventAdapter ​
Defined in: packages/events/src/types.ts:97
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:99
Adapter name for identification (e.g., "nats", "kafka", "redis", "memory")
Methods ​
connect() ​
connect(
context?):Promise<void>
Defined in: packages/events/src/types.ts:108
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:111
Disconnect from the message broker
Returns ​
Promise<void>
publish() ​
publish(
eventType,payload,options?):Promise<void>
Defined in: packages/events/src/types.ts:114
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:117
Subscribe to event patterns with a raw handler
Parameters ​
patterns ​
string[]
handler ​
options? ​
Returns ​
Promise<EventSubscription>