From 7d2ab47a7f393e91ee7e750e2a2aa4276496821c Mon Sep 17 00:00:00 2001
From: Dimitra Chatzichrysou <dimitra.chatzichrysou@cern.ch>
Date: Fri, 11 Jun 2021 11:30:06 +0200
Subject: [PATCH] [#52] Set expiration of message to 48h
---
notifications_consumer/config.py | 1 +
notifications_consumer/processors/email_gateway/processor.py | 1 +
2 files changed, 2 insertions(+)
diff --git a/notifications_consumer/config.py b/notifications_consumer/config.py
index b315b82..767c8d6 100644
--- a/notifications_consumer/config.py
+++ b/notifications_consumer/config.py
@@ -42,6 +42,7 @@ class Config:
# ActiveMQ
CONSUMER_NAME = os.getenv("CONSUMER_NAME")
PUBLISHER_NAME = os.getenv("PUBLISHER_NAME")
+ TTL = int(os.getenv("TTL", 172800))
# Email
EMAIL_HOST = os.getenv("EMAIL_HOST", "localhost")
diff --git a/notifications_consumer/processors/email_gateway/processor.py b/notifications_consumer/processors/email_gateway/processor.py
index 5ecf4b7..726eecf 100644
--- a/notifications_consumer/processors/email_gateway/processor.py
+++ b/notifications_consumer/processors/email_gateway/processor.py
@@ -110,6 +110,7 @@ class MailGatewayProcessor(Processor):
self.publisher.send(
message,
extension=Config.EMAIL_GATEWAY_DLQ,
+ ttl=Config.TTL,
headers={"persistent": "true"},
)
--
GitLab