diff --git a/cms/envs/aws.py b/cms/envs/aws.py
index 1c97d6b765..0ec4edb23d 100644
--- a/cms/envs/aws.py
+++ b/cms/envs/aws.py
@@ -65,6 +65,9 @@ CELERY_RESULT_BACKEND = 'djcelery.backends.cache:CacheBackend'
 BROKER_HEARTBEAT = 10.0
 BROKER_HEARTBEAT_CHECKRATE = 2
 
+# Message expiry time in seconds, Default is 5 seconds
+CELERY_EVENT_QUEUE_TTL = 10
+
 # Each worker should only fetch one message at a time
 CELERYD_PREFETCH_MULTIPLIER = 1
 
diff --git a/cms/envs/yaml_config.py b/cms/envs/yaml_config.py
index e6968d3cbd..0e5dbef0a7 100644
--- a/cms/envs/yaml_config.py
+++ b/cms/envs/yaml_config.py
@@ -110,6 +110,9 @@ CELERY_RESULT_BACKEND = 'djcelery.backends.cache:CacheBackend'
 BROKER_HEARTBEAT = 10.0
 BROKER_HEARTBEAT_CHECKRATE = 2
 
+# Message expiry time in seconds, Default is 5 seconds
+CELERY_EVENT_QUEUE_TTL = 10
+
 # Each worker should only fetch one message at a time
 CELERYD_PREFETCH_MULTIPLIER = 1
 
diff --git a/lms/envs/aws.py b/lms/envs/aws.py
index 4d7e52e541..1a1048044b 100644
--- a/lms/envs/aws.py
+++ b/lms/envs/aws.py
@@ -74,6 +74,9 @@ CELERY_RESULT_BACKEND = 'djcelery.backends.cache:CacheBackend'
 BROKER_HEARTBEAT = 10.0
 BROKER_HEARTBEAT_CHECKRATE = 2
 
+# Message expiry time in seconds, Default is 5 seconds
+CELERY_EVENT_QUEUE_TTL = 10
+
 # Each worker should only fetch one message at a time
 CELERYD_PREFETCH_MULTIPLIER = 1
 
diff --git a/lms/envs/yaml_config.py b/lms/envs/yaml_config.py
index 2d816c2f24..ca099d3a2c 100644
--- a/lms/envs/yaml_config.py
+++ b/lms/envs/yaml_config.py
@@ -133,6 +133,9 @@ CELERY_RESULT_BACKEND = 'djcelery.backends.cache:CacheBackend'
 BROKER_HEARTBEAT = 10.0
 BROKER_HEARTBEAT_CHECKRATE = 2
 
+#  Message expiry time in seconds, Default is 5 seconds
+CELERY_EVENT_QUEUE_TTL = 10
+
 # Each worker should only fetch one message at a time
 CELERYD_PREFETCH_MULTIPLIER = 1