diff --git a/symmetric-util/src/main/java/org/jumpmind/util/LogSummaryAppender.java b/symmetric-util/src/main/java/org/jumpmind/util/LogSummaryAppender.java
index 1a59927a91..a6c6493839 100644
--- a/symmetric-util/src/main/java/org/jumpmind/util/LogSummaryAppender.java
+++ b/symmetric-util/src/main/java/org/jumpmind/util/LogSummaryAppender.java
@@ -119,14 +119,17 @@ public void purgeOlderThan(long time) {
         purgeOlderThan(time, warningByEngineByMessage);
     }
     
-    protected void purgeOlderThan(long time, Map<String, Map<String, LogSummary>> logSummaryByEngineByMessage) {
+    protected void purgeOlderThan(long time,
+            Map<String, Map<String, LogSummary>> logSummaryByEngineByMessage) {
         Collection<Map<String, LogSummary>> all = logSummaryByEngineByMessage.values();
         for (Map<String, LogSummary> map : all) {
             Set<String> keys = map.keySet();
             for (String key : keys) {
                 LogSummary summary = map.get(key);
-                if (summary.getMostRecentTime() < time) {
-                    map.remove(key);
+                if (summary != null) {
+                    if (summary.getMostRecentTime() < time) {
+                        map.remove(key);
+                    }
                 }
             }
         }