Interface: RabbitMQOptions

Defined in: packages/microservices/src/interfaces/microservice.interface.ts:29

Connection options for the RabbitMQ (amqplib) transport.

Properties

Property	Type	Description	Defined in
exchange?	string	Exchange name to publish to / consume from.	packages/microservices/src/interfaces/microservice.interface.ts:48
exchangeType?	"direct" | "topic" | "fanout" | "headers"	Exchange type. Defaults to "topic".	packages/microservices/src/interfaces/microservice.interface.ts:50
noAck?	boolean	When true, messages are auto-acknowledged (no manual ack/nack).	packages/microservices/src/interfaces/microservice.interface.ts:44
persistent?	boolean	When true, published messages are marked as persistent.	packages/microservices/src/interfaces/microservice.interface.ts:46
prefetchCount?	number	Number of messages to prefetch per consumer.	packages/microservices/src/interfaces/microservice.interface.ts:42
queue	string	Name of the queue to consume from.	packages/microservices/src/interfaces/microservice.interface.ts:33
queueOptions?	{ arguments?: Record<string, unknown>; autoDelete?: boolean; durable?: boolean; exclusive?: boolean; }	Optional queue-declaration parameters.	packages/microservices/src/interfaces/microservice.interface.ts:35
queueOptions.arguments?	Record<string, unknown>	-	packages/microservices/src/interfaces/microservice.interface.ts:39
queueOptions.autoDelete?	boolean	-	packages/microservices/src/interfaces/microservice.interface.ts:38
queueOptions.durable?	boolean	-	packages/microservices/src/interfaces/microservice.interface.ts:36
queueOptions.exclusive?	boolean	-	packages/microservices/src/interfaces/microservice.interface.ts:37
routingKey?	string	Routing key used when binding queue to exchange or publishing messages.	packages/microservices/src/interfaces/microservice.interface.ts:52
urls	string[]	AMQP URLs to try in order (e.g. ["amqp://localhost"]).	packages/microservices/src/interfaces/microservice.interface.ts:31