Class RabbitMQIO

constructor

• new RabbitMQIO(options?: RabbitMQOptions): RabbitMQIO

  Parameters

  • options: RabbitMQOptions = {}

  Returns RabbitMQIO

capabilities

name

destroy

• destroy(): void

  Clean up resources used by the IO adapter

  Returns void

getExchange

• getExchange(): string

  Get the exchange name used by this adapter

  Returns string

getRoutingKeys

• getRoutingKeys(): { inbound: string; outbound: string }

  Get the routing keys used by this adapter

  Returns { inbound: string; outbound: string }

getSessionId

• getSessionId(): string

  Get the session ID for this adapter

  Returns string

read

• read(): Promise<null | string>

  Returns Promise<null | string>

signalDestroy

• signalDestroy(): Promise<void>

  Signal that the IO adapter should prepare for destruction

  Returns Promise<void>

write

• write(message: string | IoMessage): Promise<void>

  Parameters

  • message: string | IoMessage

  Returns Promise<void>