Updated timer names

Author: pc9795

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

@@ -17,6 +17,7 @@
 import java.util.TimerTask;
 
 public class ExceptionlessClient {
+  private static final String UPDATE_SETTINGS_TIMER_NAME = "update-settings-timer";
   private static final int UPDATE_SETTINGS_TIMER_INITIAL_DELAY = 5000;
 
   private ConfigurationManager configurationManager;
@@ -28,7 +29,7 @@ public ExceptionlessClient(ConfigurationManager configurationManager) {
     this.configurationManager = configurationManager;
     this.eventPluginRunner =
         EventPluginRunner.builder().configurationManager(this.configurationManager).build();
-    this.updateSettingsTimer = new Timer();
+    this.updateSettingsTimer = new Timer(UPDATE_SETTINGS_TIMER_NAME);
     init();
   }
 
@@ -144,7 +145,7 @@ private Event.EventBuilder createEvent() {
   }
 
   // todo this should be async
-  private void submitEvent(EventPluginContext eventPluginContext) {
+  public void submitEvent(EventPluginContext eventPluginContext) {
     eventPluginRunner.run(eventPluginContext);
   }
 

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

@@ -14,6 +14,8 @@
 import java.util.*;
 
 public class DuplicateErrorCheckerPlugin implements EventPluginIF {
+  private static final String MERGED_EVENTS_RESUBMISSION_TIMER_NAME = "merged-events-resubmission-timer";
+
   private LogIF log;
   private int maxHashesCount;
   private Queue<MergedEvent> mergedEvents;
@@ -27,7 +29,7 @@ public DuplicateErrorCheckerPlugin(
     this.log = log;
     this.maxHashesCount = maxHashesCount == null ? 50 : maxHashesCount;
     this.mergedEvents = new ArrayDeque<>();
-    this.mergedEventsResubmissionTimer = new Timer();
+    this.mergedEventsResubmissionTimer = new Timer(MERGED_EVENTS_RESUBMISSION_TIMER_NAME);
     this.hashes = new ArrayList<>();
     this.mergedEventsResubmissionInSecs =
         mergedEventsResubmissionInSecs == null ? 30 : mergedEventsResubmissionInSecs;

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

@@ -11,14 +11,16 @@
 import java.util.TimerTask;
 
 public class HeartbeatPlugin implements EventPluginIF {
+  private static final String HEART_BEAT_TIMER_NAME = "heart-beat-timer";
+
   private int heartbeatInterval;
   private Timer heartbeatTimer;
   private String prevIdentity;
 
   @Builder
   public HeartbeatPlugin(int heartbeatInterval) {
     this.heartbeatInterval = heartbeatInterval;
-    this.heartbeatTimer = new Timer();
+    this.heartbeatTimer = new Timer(HEART_BEAT_TIMER_NAME);
   }
 
   @Override
@@ -28,7 +30,7 @@ public int getPriority() {
 
   @Override
   public void run(
-          EventPluginContext eventPluginContext, ConfigurationManager configurationManager) {
+      EventPluginContext eventPluginContext, ConfigurationManager configurationManager) {
     Optional<UserInfo> maybeUserInfo = eventPluginContext.getEvent().getUserInfo();
     if (!maybeUserInfo.isPresent()) {
       return;
@@ -50,8 +52,8 @@ public void run() {
         heartbeatInterval);
   }
 
-  private void resetHeartbeatTimer(){
+  private void resetHeartbeatTimer() {
     heartbeatTimer.cancel();
-    heartbeatTimer = new Timer();
+    heartbeatTimer = new Timer(HEART_BEAT_TIMER_NAME);
   }
 }

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

@@ -20,6 +20,8 @@
 import java.util.stream.Collectors;
 
 public class DefaultEventQueue implements EventQueueIF {
+  private static final String QUEUE_TIMER_NAME = "queue-timer";
+
   private LogIF log;
   private StorageProviderIF storageProvider;
   private Configuration configuration;
@@ -42,7 +44,7 @@ public DefaultEventQueue(
     this.storageProvider = storageProvider;
     this.configuration = configuration;
     this.submissionClient = submissionClient;
-    this.queueTimer = new Timer();
+    this.queueTimer = new Timer(QUEUE_TIMER_NAME);
     this.handlers = new ArrayList<>();
     this.currentSubmissionBatchSize = configuration.getSubmissionBatchSize();
     init(processingIntervalInSecs == null ? 10 : processingIntervalInSecs);