diff --git a/api-gateway/src/notification/rabbitmq.service.ts b/api-gateway/src/notification/rabbitmq.service.ts index d7ccf66..fa28a7c 100644 --- a/api-gateway/src/notification/rabbitmq.service.ts +++ b/api-gateway/src/notification/rabbitmq.service.ts @@ -23,8 +23,18 @@ export class RabbitMQService implements OnModuleInit, OnModuleDestroy { 'x-message-ttl': 86400000, }, }); - await channel.assertQueue('push.queue', { durable: true }); - await channel.assertQueue('failed.queue', { durable: true }); + await channel.assertQueue('push.queue', { + durable: true, + arguments: { + 'x-message-ttl': 86400000, + }, + }); + await channel.assertQueue('failed.queue', { + durable: true, + arguments: { + 'x-message-ttl': 86400000, + }, + }); }, });