diff --git a/app.py b/app.py
index bb06459..197154f 100644
--- a/app.py
+++ b/app.py
@@ -256,6 +256,10 @@ def handler(event, context):
         title = "ElastiCache fail over stareted"
         body = "for node {}".format(msg["ElastiCache:CacheNodeReplaceStarted"])
 
+    elif "ElastiCache:CacheNodeReplaceComplete" in msg:
+        title = "ElastiCache fail over completed"
+        body = "for node {}".format(msg["ElastiCache:CacheNodeReplaceComplete"])
+
     # ElasticCache replacement notifications
     elif "ElastiCache:FailoverComplete" in msg:
         title = "ElastiCache fail over complete"