Skip to content

Connectum API Reference / @connectum/events-amqp / testing / FakeAmqpAdapterInstance

Interface: FakeAmqpAdapterInstance ​

Defined in: packages/events-amqp/src/testing.ts:233

The fake adapter: a drop-in EventAdapter plus its FakeAmqpControl.

Extends ​

  • EventAdapter

Properties ​

control ​

readonly control: FakeAmqpControl

Defined in: packages/events-amqp/src/testing.ts:234


name ​

readonly name: string

Defined in: packages/events/dist/index.d.ts:105

Adapter name for identification (e.g., "nats", "kafka", "redis", "memory")

Inherited from ​

EventAdapter.name

Methods ​

connect() ​

connect(context?): Promise<void>

Defined in: packages/events/dist/index.d.ts:113

Connect to the message broker.

Parameters ​

context? ​

AdapterContext

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>

Inherited from ​

EventAdapter.connect


disconnect() ​

disconnect(): Promise<void>

Defined in: packages/events/dist/index.d.ts:115

Disconnect from the message broker

Returns ​

Promise<void>

Inherited from ​

EventAdapter.disconnect


publish() ​

publish(eventType, payload, options?): Promise<void>

Defined in: packages/events/dist/index.d.ts:117

Publish a serialized event to a topic

Parameters ​

eventType ​

string

payload ​

Uint8Array

options? ​

PublishOptions

Returns ​

Promise<void>

Inherited from ​

EventAdapter.publish


subscribe() ​

subscribe(patterns, handler, options?): Promise<EventSubscription>

Defined in: packages/events/dist/index.d.ts:119

Subscribe to event patterns with a raw handler

Parameters ​

patterns ​

string[]

handler ​

RawEventHandler

options? ​

RawSubscribeOptions

Returns ​

Promise<EventSubscription>

Inherited from ​

EventAdapter.subscribe