Added exception handling for timers

Author: pc9795

src/main/java/com/exceptionless/exceptionlessclient/ExceptionlessClient.java

@@ -39,7 +39,11 @@ private void init() {
         new TimerTask() {
           @Override
           public void run() {
-            configurationManager.getSettingsManager().updateSettingsThreadSafe();
+            try {
+              configurationManager.getSettingsManager().updateSettingsThreadSafe();
+            } catch (Exception e) {
+              configurationManager.getLog().error("Error in updating settings", e);
+            }
           }
         },
         UPDATE_SETTINGS_TIMER_INITIAL_DELAY,

src/main/java/com/exceptionless/exceptionlessclient/plugins/preconfigured/DuplicateErrorCheckerPlugin.java

@@ -14,7 +14,8 @@
 import java.util.*;
 
 public class DuplicateErrorCheckerPlugin implements EventPluginIF {
-  private static final String MERGED_EVENTS_RESUBMISSION_TIMER_NAME = "merged-events-resubmission-timer";
+  private static final String MERGED_EVENTS_RESUBMISSION_TIMER_NAME =
+      "merged-events-resubmission-timer";
 
   private final LogIF log;
   private final int maxHashesCount;
@@ -41,9 +42,13 @@ private void init() {
         new TimerTask() {
           @Override
           public void run() {
-            MergedEvent event = mergedEvents.poll();
-            if (event != null) {
-              event.resubmit();
+            try {
+              MergedEvent event = mergedEvents.poll();
+              if (event != null) {
+                event.resubmit();
+              }
+            } catch (Exception e) {
+              log.error("Error in resubmitting merged events", e);
             }
           }
         },
@@ -57,7 +62,7 @@ public int getPriority() {
 
   @Override
   public void run(
-          EventPluginContext eventPluginContext, ConfigurationManager configurationManager) {
+      EventPluginContext eventPluginContext, ConfigurationManager configurationManager) {
     Event event = eventPluginContext.getEvent();
     Optional<Error> maybeError = event.getError();
     if (maybeError.isEmpty()) {

src/main/java/com/exceptionless/exceptionlessclient/plugins/preconfigured/HeartbeatPlugin.java

@@ -32,7 +32,7 @@ public int getPriority() {
   public void run(
       EventPluginContext eventPluginContext, ConfigurationManager configurationManager) {
     Optional<UserInfo> maybeUserInfo = eventPluginContext.getEvent().getUserInfo();
-    if (!maybeUserInfo.isPresent()) {
+    if (maybeUserInfo.isEmpty()) {
       return;
     }
     if (maybeUserInfo.get().getIdentity().equals(prevIdentity)) {
@@ -46,7 +46,15 @@ public void run(
         new TimerTask() {
           @Override
           public void run() {
-            configurationManager.submitSessionHeartbeat(prevIdentity);
+            try {
+              configurationManager.submitSessionHeartbeat(prevIdentity);
+            } catch (Exception e) {
+              configurationManager
+                  .getLog()
+                  .error(
+                      String.format("Error in submitting hearbeat for identity: %s", prevIdentity),
+                      e);
+            }
           }
         },
         heartbeatInterval);

src/main/java/com/exceptionless/exceptionlessclient/queue/DefaultEventQueue.java

@@ -55,7 +55,11 @@ private void init(Integer processingIntervalInSecs) {
         new TimerTask() {
           @Override
           public void run() {
-            onProcessQueue();
+            try {
+              onProcessQueue();
+            } catch (Exception e) {
+              log.error("Error in processing queue", e);
+            }
           }
         },
         processingIntervalInSecs * 1000);