diff --git a/apps/coordinator/src/main/kotlin/no/iktdev/mediaprocessing/coordinator/Coordinator.kt b/apps/coordinator/src/main/kotlin/no/iktdev/mediaprocessing/coordinator/Coordinator.kt
index 2cfc6a12..d7ff9c28 100644
--- a/apps/coordinator/src/main/kotlin/no/iktdev/mediaprocessing/coordinator/Coordinator.kt
+++ b/apps/coordinator/src/main/kotlin/no/iktdev/mediaprocessing/coordinator/Coordinator.kt
@@ -21,7 +21,6 @@ import java.util.UUID
 @EnableScheduling
 @Service
 class Coordinator() : CoordinatorBase<PersistentMessage, PersistentEventBasedMessageListener>() {
-    val io = Coroutines.io()
 
     override fun onCoordinatorReady() {
         super.onCoordinatorReady()
@@ -33,7 +32,7 @@ class Coordinator() : CoordinatorBase<PersistentMessage, PersistentEventBasedMes
         if (!success) {
             log.error { "Failed to store message event\nReferenceId: ${event.value.referenceId}\n\tEventId: ${event.value.eventId}\n\tEvent: ${event.key.event}\n\nData:\n${event.value.data}" }
         } else {
-            io.launch {
+            ioCoroutine.launch {
                 readAllMessagesFor(event.value.referenceId, event.value.eventId, event.key.event)
             }
         }
@@ -97,7 +96,7 @@ class Coordinator() : CoordinatorBase<PersistentMessage, PersistentEventBasedMes
                 log.info { "Found uncompleted: ${it.referenceId}" }
             }
         }
-        io.launch {
+        ioCoroutine.launch {
             messages.forEach {
                 delay(1000)
                 try {
@@ -113,7 +112,7 @@ class Coordinator() : CoordinatorBase<PersistentMessage, PersistentEventBasedMes
         val messages = eventManager.getEventsWith(referenceId)
         if (messages.find { it.eventId == eventId && it.referenceId == referenceId } == null) {
             log.warn { "EventId ($eventId) for ReferenceId ($referenceId) with event $event has not been made available in the database yet." }
-            io.launch {
+            ioCoroutine.launch {
                 val fixedDelay = 1000L
                 delay(fixedDelay)
                 var delayed = 0L