feat: make RabbitMQ exchange/queue setup optional and add 5min TTL to queues

Add ensureExchangesAndQueues option (default false) to control whether
exchanges and queues are declared on startup. Add x-message-ttl of 5
minutes to the main queue and DLQ.

Co-Authored-By: Claude Opus 4.6 <noreply@anthropic.com>

Author: saby1101

src/event-bus/interfaces.ts

@@ -11,6 +11,7 @@ export interface EventBusOptions {
   }[];
   validateMsg: (event: string, payload: any, req?: FastifyRequest) => void;
   processError(err: any, ctx: ActionContext): { err: any; status: number };
+  ensureExchangesAndQueues?: boolean;
   disableEventPublishRoute?: boolean;
   actionConcurrency?: number;
   registry?: Registry;

src/event-bus/rabbitmq-utils.ts

@@ -28,6 +28,7 @@ export async function ensureRabbitMqExchangesAndQueues(
   await connection.queueDeclare({
     queue: `${prefix}.queue.${service}`,
     arguments: {
+      "x-message-ttl": 300000, // 5 minutes
       "x-dead-letter-exchange": `${prefix}.retry-exchange.${service}`,
       "x-dead-letter-routing-key": "retry", // Fixed routing key for DLX
       "x-queue-type": "classic",
@@ -72,6 +73,7 @@ export async function ensureRabbitMqExchangesAndQueues(
   await connection.queueDeclare({
     queue: `${prefix}.dlq.${service}`,
     arguments: {
+      "x-message-ttl": 300000, // 5 minutes
       "x-queue-type": "classic",
     },
     autoDelete: false,

src/event-bus/rabbitmq.ts

@@ -48,7 +48,9 @@ const plugin: FastifyPluginAsync<EventBusOptions> = async function (
   }
   const connection = new Connection(process.env.RABBITMQ_URL);
   const service = process.env.K_SERVICE;
-  await ensureRabbitMqExchangesAndQueues(connection, service);
+  if (options.ensureExchangesAndQueues) {
+    await ensureRabbitMqExchangesAndQueues(connection, service);
+  }
 
   const publisher = connection.createPublisher({ maxAttempts: 3 });