Ensure that exceptions gets thrown

Author: blootsvoets

src/main/java/org/radarbase/output/Application.kt

@@ -18,8 +18,7 @@ package org.radarbase.output
 
 import com.beust.jcommander.JCommander
 import com.beust.jcommander.ParameterException
-import kotlinx.coroutines.launch
-import kotlinx.coroutines.runBlocking
+import kotlinx.coroutines.*
 import kotlinx.coroutines.sync.Mutex
 import kotlinx.coroutines.sync.Semaphore
 import org.radarbase.output.accounting.*
@@ -200,9 +199,17 @@ class Application(
             } catch (e: IllegalStateException) {
                 logger.error("Invalid configuration: {}", e.message)
                 exitProcess(1)
+            } catch (ex: Throwable) {
+                logger.error("Failed to initialize application: {}", ex.message)
+                exitProcess(1)
             }
 
-            application.start()
+            try {
+                application.start()
+            } catch (ex: Throwable) {
+                logger.error("Application failed: {}", ex.message)
+                exitProcess(1)
+            }
         }
     }
 }

src/test/java/org/radarbase/output/source/S3SourceStorageTest.kt

@@ -0,0 +1,27 @@
+package org.radarbase.output.source
+
+import kotlinx.coroutines.launch
+import kotlinx.coroutines.runBlocking
+import org.junit.jupiter.api.Test
+import org.junit.jupiter.api.assertThrows
+import org.radarbase.output.source.S3SourceStorage.Companion.faultTolerant
+import java.io.IOException
+
+class S3SourceStorageTest {
+    @Test
+    fun testSuspend() {
+        assertThrows<IOException> {
+            runBlocking {
+                launch { throw IOException("ex") }
+            }
+        }
+    }
+    @Test
+    fun testFaultTolerant() {
+        assertThrows<IOException> {
+            runBlocking {
+                faultTolerant { throw IOException("test") }
+            }
+        }
+    }
+}