Removed SubmissionClientException

Author: pc9795

src/main/java/com/exceptionless/exceptionlessclient/exceptions/SubmissionClientException.java

@@ -1,12 +1,11 @@
 package com.exceptionless.exceptionlessclient.queue;
 
 import com.exceptionless.exceptionlessclient.configuration.Configuration;
-import com.exceptionless.exceptionlessclient.exceptions.SubmissionClientException;
 import com.exceptionless.exceptionlessclient.models.Event;
 import com.exceptionless.exceptionlessclient.models.storage.StorageItem;
-import com.exceptionless.exceptionlessclient.submission.SubmissionResponse;
 import com.exceptionless.exceptionlessclient.storage.StorageProviderIF;
 import com.exceptionless.exceptionlessclient.submission.SubmissionClientIF;
+import com.exceptionless.exceptionlessclient.submission.SubmissionResponse;
 import com.exceptionless.exceptionlessclient.utils.VisibleForTesting;
 import lombok.Builder;
 import lombok.extern.slf4j.Slf4j;
@@ -137,11 +136,13 @@ public void process() {
       log.info(
           String.format("Sending %s events to %s", events.size(), configuration.getServerUrl()));
       SubmissionResponse response = submissionClient.postEvents(events);
+      if (response.hasException()) {
+        log.error("Error submitting events from queue", response.getException());
+        suspendProcessing();
+        return;
+      }
       processSubmissionResponse(response, storedEvents);
       eventPosted(response, events);
-    } catch (SubmissionClientException e) {
-      log.error("Error submitting events from queue", e);
-      suspendProcessing();
     } finally {
       synchronized (this) {
         processingQueue = false;

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

@@ -1,7 +1,6 @@
 package com.exceptionless.exceptionlessclient.submission;
 
 import com.exceptionless.exceptionlessclient.configuration.Configuration;
-import com.exceptionless.exceptionlessclient.exceptions.SubmissionClientException;
 import com.exceptionless.exceptionlessclient.models.Event;
 import com.exceptionless.exceptionlessclient.models.UserDescription;
 import com.exceptionless.exceptionlessclient.settings.SettingsManager;
@@ -84,7 +83,7 @@ private SubmissionResponse postSubmission(String url, Object data) {
           .body(body == null ? "" : body.string())
           .build();
     } catch (Exception e) {
-      throw new SubmissionClientException(e);
+      return SubmissionResponse.builder().exception(e).build();
     }
   }
 
@@ -122,7 +121,7 @@ public void sendHeartBeat(String sessionIdOrUserId, boolean closeSession) {
                 sessionIdOrUserId));
       }
     } catch (Exception e) {
-      throw new SubmissionClientException(e);
+      log.error("Error while submitting heartbeat", e);
     }
   }
 }

src/main/java/com/exceptionless/exceptionlessclient/submission/DefaultSubmissionClient.java

@@ -8,6 +8,7 @@
 public class SubmissionResponse {
   int code;
   String body;
+  Exception exception;
 
   public boolean isSuccess() {
     return code >= 200 && code <= 299;
@@ -36,4 +37,8 @@ public boolean isNotFound() {
   public boolean isRequestEntityTooLarge() {
     return code == 413;
   }
+
+  public boolean hasException() {
+    return exception != null;
+  }
 }

src/main/java/com/exceptionless/exceptionlessclient/submission/SubmissionResponse.java

@@ -2,12 +2,11 @@
 
 import com.exceptionless.exceptionlessclient.TestFixtures;
 import com.exceptionless.exceptionlessclient.configuration.Configuration;
-import com.exceptionless.exceptionlessclient.exceptions.SubmissionClientException;
 import com.exceptionless.exceptionlessclient.models.Event;
-import com.exceptionless.exceptionlessclient.submission.SubmissionResponse;
 import com.exceptionless.exceptionlessclient.storage.InMemoryStorage;
 import com.exceptionless.exceptionlessclient.storage.InMemoryStorageProvider;
 import com.exceptionless.exceptionlessclient.submission.DefaultSubmissionClient;
+import com.exceptionless.exceptionlessclient.submission.SubmissionResponse;
 import org.junit.jupiter.api.BeforeEach;
 import org.junit.jupiter.api.Test;
 import org.junit.jupiter.api.extension.ExtendWith;
@@ -111,7 +110,9 @@ public void itShouldNotPostEmptyEvents() {
   public void itShouldSuspendProcessingOnClientException() {
     storage.save(event);
 
-    doThrow(new SubmissionClientException("test")).when(submissionClient).postEvents(List.of(event));
+    doReturn(SubmissionResponse.builder().exception(new RuntimeException("test")).build())
+        .when(submissionClient)
+        .postEvents(List.of(event));
 
     queue.onEventsPosted(testHandler);
     queue.process();
@@ -250,11 +251,9 @@ public void itShouldReduceSubmissionBatchSizeIfRequestEntitiesAreTooLarge() {
     queue.process();
 
     // One invocation with full batch
-    verify(submissionClient, times(1))
-        .postEvents(argThat(argument -> argument.size() == 3));
+    verify(submissionClient, times(1)).postEvents(argThat(argument -> argument.size() == 3));
     // One invocation with reduced batch
-    verify(submissionClient, times(1))
-        .postEvents(argThat(argument -> argument.size() == 2));
+    verify(submissionClient, times(1)).postEvents(argThat(argument -> argument.size() == 2));
   }
 
   @Test
@@ -303,11 +302,9 @@ public void itShouldResetSubmissionBatchSizeOnNextSuccessfulResponse() {
 
     // Two invocations with full batch; First with the default size and next after a successful
     // response
-    verify(submissionClient, times(2))
-        .postEvents(argThat(argument -> argument.size() == 3));
+    verify(submissionClient, times(2)).postEvents(argThat(argument -> argument.size() == 3));
     // One invocation with reduced batch
-    verify(submissionClient, times(1))
-        .postEvents(argThat(argument -> argument.size() == 2));
+    verify(submissionClient, times(1)).postEvents(argThat(argument -> argument.size() == 2));
   }
 
   @Test

src/test/java/com/exceptionless/exceptionlessclient/queue/DefaultEventQueueTest.java

@@ -2,7 +2,6 @@
 
 import com.exceptionless.exceptionlessclient.TestFixtures;
 import com.exceptionless.exceptionlessclient.configuration.Configuration;
-import com.exceptionless.exceptionlessclient.exceptions.SubmissionClientException;
 import com.exceptionless.exceptionlessclient.models.Event;
 import com.exceptionless.exceptionlessclient.models.UserDescription;
 import com.exceptionless.exceptionlessclient.settings.SettingsManager;
@@ -18,7 +17,6 @@
 import java.util.Map;
 
 import static org.assertj.core.api.Assertions.assertThat;
-import static org.assertj.core.api.Assertions.assertThatThrownBy;
 import static org.mockito.ArgumentMatchers.any;
 import static org.mockito.ArgumentMatchers.argThat;
 import static org.mockito.Mockito.*;
@@ -90,12 +88,14 @@ public void itCanPostEventsSuccessfullyWhenNoSettingHeaderIsReturned() throws IO
   }
 
   @Test
-  public void itCanThrowAllExceptionsAsSubmissionExceptionWhilePostingEvents() {
-    doThrow(new RuntimeException("test")).when(httpClient).newCall(any());
+  public void itCanHandleAllExceptionsWhilePostingEvents() {
+    Exception exception = new RuntimeException("test");
+    doThrow(exception).when(httpClient).newCall(any());
+
+    SubmissionResponse response = submissionClient.postEvents(List.of(Event.builder().build()));
 
-    assertThatThrownBy(() -> submissionClient.postEvents(List.of(Event.builder().build())))
-        .isInstanceOf(SubmissionClientException.class)
-        .hasMessage("java.lang.RuntimeException: test");
+    assertThat(response.hasException()).isTrue();
+    assertThat(response.getException()).isSameAs(exception);
   }
 
   @Test
@@ -140,15 +140,14 @@ public void itCanPostUserDescriptionSuccessfullyWhenNoSettingHeaderIsReturned()
   }
 
   @Test
-  public void itCanThrowAllExceptionsAsSubmissionExceptionWhilePostingUserDescription() {
-    doThrow(new RuntimeException("test")).when(httpClient).newCall(any());
+  public void itCanHandleAllExceptionsWhilePostingUserDescription() {
+    Exception exception = new RuntimeException("test");
+    doThrow(exception).when(httpClient).newCall(any());
 
-    assertThatThrownBy(
-            () ->
-                submissionClient.postUserDescription(
-                    "test-reference-id", UserDescription.builder().build()))
-        .isInstanceOf(SubmissionClientException.class)
-        .hasMessage("java.lang.RuntimeException: test");
+    SubmissionResponse response = submissionClient.postUserDescription("test-reference-id", UserDescription.builder().build());
+
+    assertThat(response.hasException()).isTrue();
+    assertThat(response.getException()).isSameAs(exception);
   }
 
   @Test
@@ -172,11 +171,9 @@ public void itCanSendHeartbeatSuccessfully() throws IOException {
   }
 
   @Test
-  public void itCanThrowAllExceptionsAsSubmissionExceptionWhileSendingHeartbeat() {
+  public void itCanHandleAllExceptionsWhileSendingHeartbeat() {
     doThrow(new RuntimeException("test")).when(httpClient).newCall(any());
 
-    assertThatThrownBy(() -> submissionClient.sendHeartBeat("test-user-id", true))
-        .isInstanceOf(SubmissionClientException.class)
-        .hasMessage("java.lang.RuntimeException: test");
+    submissionClient.sendHeartBeat("test-user-id", true);
   }
 }