diff --git a/extensions/openpower-pels/repository.cpp b/extensions/openpower-pels/repository.cpp
index 21b0243..aaa6a87 100644
--- a/extensions/openpower-pels/repository.cpp
+++ b/extensions/openpower-pels/repository.cpp
@@ -128,6 +128,8 @@
     using pelID = LogID::Pel;
     using obmcID = LogID::Obmc;
     _idsToPELs.emplace(LogID(pelID(pel->id()), obmcID(pel->obmcLogID())), path);
+
+    processAddCallbacks(*pel);
 }
 
 void Repository::remove(const LogID& id)
@@ -137,6 +139,8 @@
     {
         fs::remove(pel->second);
         _idsToPELs.erase(pel);
+
+        processDeleteCallbacks(id.pelID.id);
     }
 }
 
@@ -198,5 +202,39 @@
     }
 }
 
+void Repository::processAddCallbacks(const PEL& pel) const
+{
+    for (auto& [name, func] : _addSubscriptions)
+    {
+        try
+        {
+            func(pel);
+        }
+        catch (std::exception& e)
+        {
+            log<level::ERR>("PEL Repository add callback exception",
+                            entry("NAME=%s", name.c_str()),
+                            entry("ERROR=%s", e.what()));
+        }
+    }
+}
+
+void Repository::processDeleteCallbacks(uint32_t id) const
+{
+    for (auto& [name, func] : _deleteSubscriptions)
+    {
+        try
+        {
+            func(id);
+        }
+        catch (std::exception& e)
+        {
+            log<level::ERR>("PEL Repository delete callback exception",
+                            entry("NAME=%s", name.c_str()),
+                            entry("ERROR=%s", e.what()));
+        }
+    }
+}
+
 } // namespace pels
 } // namespace openpower