Class: RabbitMQClient

Defined in: packages/microservices/src/client/rabbitmq.client.ts:75

Client proxy that communicates over RabbitMQ (AMQP via amqplib).

• send: publishes a message with replyTo and correlationId set, then waits for a reply on an exclusive per-client queue.
• emit: publishes without replyTo.

Requires the optional peer dependency amqplib.

Extends

• ClientProxy

Constructors

Constructor

new RabbitMQClient(options): RabbitMQClient;

Defined in: packages/microservices/src/client/rabbitmq.client.ts:91

Parameters

Parameter	Type
options	RabbitMQOptions

Returns

RabbitMQClient

Overrides

ClientProxy.constructor

Methods

close()

close(): void;

Defined in: packages/microservices/src/client/rabbitmq.client.ts:252

Cancels the consumer, closes channel and connection.

Returns

void

Overrides

ClientProxy.close

---

connect()

connect(): Promise<void>;

Defined in: packages/microservices/src/client/rabbitmq.client.ts:102

Connects to RabbitMQ and sets up the exclusive reply queue.

Returns

Promise<void>

Overrides

ClientProxy.connect

---

emit()

emit<T>(pattern, data): void;

Defined in: packages/microservices/src/client/rabbitmq.client.ts:234

Publishes a fire-and-forget event to pattern.

Type Parameters

Type Parameter	Default type
T	unknown

Parameters

Parameter	Type
pattern	string
data	T

Returns

void

Overrides

ClientProxy.emit

---

send()

send<T, R>(pattern, data): Observable<R>;

Defined in: packages/microservices/src/client/rabbitmq.client.ts:186

Sends a request to pattern and returns an Observable that emits the server's response then completes. Times out after 5 seconds.

Type Parameters

Type Parameter	Default type
T	unknown
R	unknown

Parameters

Parameter	Type
pattern	string
data	T

Returns

Observable<R>

Overrides

ClientProxy.send