Renaming enum cases

Author: LikeTheSalad

disk-buffering/src/main/java/io/opentelemetry/contrib/disk/buffering/internal/storage/Storage.java

@@ -104,7 +104,7 @@ private ReadableResult readAndProcess(Function<byte[], ProcessResult> processing
     ReadableResult result = readableFile.readAndProcess(processing);
     switch (result) {
       case SUCCEEDED:
-      case PROCESSING_FAILED:
+      case TRY_LATER:
         return result;
       default:
         // Retry with new file

disk-buffering/src/main/java/io/opentelemetry/contrib/disk/buffering/internal/storage/files/ReadableFile.java

@@ -111,10 +111,10 @@ public synchronized ReadableResult readAndProcess(Function<byte[], ProcessResult
         return ReadableResult.SUCCEEDED;
       case TRY_LATER:
         unconsumedResult = read;
-        return ReadableResult.PROCESSING_FAILED;
+        return ReadableResult.TRY_LATER;
       case CONTENT_INVALID:
         cleanUp();
-        return ReadableResult.PROCESSING_FAILED;
+        return ReadableResult.FAILED;
     }
     return ReadableResult.FAILED;
   }

disk-buffering/src/main/java/io/opentelemetry/contrib/disk/buffering/internal/storage/responses/ReadableResult.java

@@ -8,5 +8,5 @@
 public enum ReadableResult {
   SUCCEEDED,
   FAILED,
-  PROCESSING_FAILED
+  TRY_LATER
 }

disk-buffering/src/test/java/io/opentelemetry/contrib/disk/buffering/internal/storage/StorageTest.java

@@ -5,7 +5,7 @@
 
 package io.opentelemetry.contrib.disk.buffering.internal.storage;
 
-import static io.opentelemetry.contrib.disk.buffering.internal.storage.responses.ReadableResult.PROCESSING_FAILED;
+import static io.opentelemetry.contrib.disk.buffering.internal.storage.responses.ReadableResult.TRY_LATER;
 import static org.junit.jupiter.api.Assertions.assertEquals;
 import static org.junit.jupiter.api.Assertions.assertFalse;
 import static org.mockito.ArgumentMatchers.any;
@@ -53,11 +53,11 @@ void whenReadingAndProcessingSuccessfully_returnSuccess() throws IOException {
   }
 
   @Test
-  void whenReadableFileProcessingFails_returnFailed() throws IOException {
+  void whenReadableFileProcessingFails_returnTryLater() throws IOException {
     when(folderManager.getReadableFile()).thenReturn(readableFile);
-    when(readableFile.readAndProcess(processing)).thenReturn(PROCESSING_FAILED);
+    when(readableFile.readAndProcess(processing)).thenReturn(TRY_LATER);
 
-    assertEquals(PROCESSING_FAILED, storage.readAndProcess(processing));
+    assertEquals(TRY_LATER, storage.readAndProcess(processing));
 
     verify(readableFile).readAndProcess(processing);
   }

disk-buffering/src/test/java/io/opentelemetry/contrib/disk/buffering/internal/storage/files/ReadableFileTest.java

@@ -138,9 +138,9 @@ void whenProcessingSucceeds_returnSuccessStatus() throws IOException {
   }
 
   @Test
-  void whenProcessingFails_returnProcessFailedStatus() throws IOException {
+  void whenProcessingFails_returnTryLaterStatus() throws IOException {
     assertEquals(
-        ReadableResult.PROCESSING_FAILED,
+        ReadableResult.TRY_LATER,
         readableFile.readAndProcess(bytes -> ProcessResult.TRY_LATER));
   }
 
@@ -180,6 +180,15 @@ void whenReadingLastLine_deleteOriginalFile_and_close() throws IOException {
     assertTrue(readableFile.isClosed());
   }
 
+  @Test
+  void whenTheFileContentIsInvalid_deleteOriginalFile_and_close() throws IOException {
+    assertEquals(
+        ReadableResult.FAILED, readableFile.readAndProcess(bytes -> ProcessResult.CONTENT_INVALID));
+
+    assertFalse(source.exists());
+    assertTrue(readableFile.isClosed());
+  }
+
   @Test
   void whenNoMoreLinesAvailableToRead_deleteOriginalFile_close_and_returnNoContentStatus()
       throws IOException {