diff --git a/apps/converter/src/main/kotlin/no/iktdev/mediaprocessing/converter/ConverterCoordinator.kt b/apps/converter/src/main/kotlin/no/iktdev/mediaprocessing/converter/ConverterCoordinator.kt
index 618a91c8..9d50a9dc 100644
--- a/apps/converter/src/main/kotlin/no/iktdev/mediaprocessing/converter/ConverterCoordinator.kt
+++ b/apps/converter/src/main/kotlin/no/iktdev/mediaprocessing/converter/ConverterCoordinator.kt
@@ -34,6 +34,7 @@ class ConverterCoordinator() : CoordinatorBase<PersistentProcessDataMessage, Per
     }
 
     override fun onCoordinatorReady() {
+        super.onCoordinatorReady()
         log.info { "Converter Coordinator is ready" }
         readAllInQueue()
     }
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 a6610f77..afa812a8 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
@@ -22,6 +22,7 @@ class Coordinator() : CoordinatorBase<PersistentMessage, PersistentEventBasedMes
     val io = Coroutines.io()
 
     override fun onCoordinatorReady() {
+        super.onCoordinatorReady()
         readAllUncompletedMessagesInQueue()
     }
 
diff --git a/apps/processer/src/main/kotlin/no/iktdev/mediaprocessing/processer/Coordinator.kt b/apps/processer/src/main/kotlin/no/iktdev/mediaprocessing/processer/Coordinator.kt
index a4b5e1c3..c34d63cb 100644
--- a/apps/processer/src/main/kotlin/no/iktdev/mediaprocessing/processer/Coordinator.kt
+++ b/apps/processer/src/main/kotlin/no/iktdev/mediaprocessing/processer/Coordinator.kt
@@ -46,6 +46,7 @@ class Coordinator(): CoordinatorBase<PersistentProcessDataMessage, PersistentEve
     }
 
     override fun onCoordinatorReady() {
+        super.onCoordinatorReady()
         generateMissingEvents()
         readAllAvailableInQueue()
     }
diff --git a/apps/ui/src/main/kotlin/no/iktdev/mediaprocessing/ui/Coordinator.kt b/apps/ui/src/main/kotlin/no/iktdev/mediaprocessing/ui/Coordinator.kt
index 8e176538..00118bbe 100644
--- a/apps/ui/src/main/kotlin/no/iktdev/mediaprocessing/ui/Coordinator.kt
+++ b/apps/ui/src/main/kotlin/no/iktdev/mediaprocessing/ui/Coordinator.kt
@@ -28,7 +28,7 @@ class Coordinator(@Autowired private val eventbasedTopic: EventbasedTopic) : Coo
     override val listeners = PersistentEventBasedMessageListener()
 
     override fun onCoordinatorReady() {
-
+        super.onCoordinatorReady()
     }
 
     override fun onMessageReceived(event: DeserializedConsumerRecord<KafkaEvents, Message<out MessageDataWrapper>>) {
diff --git a/shared/common/src/main/kotlin/no/iktdev/mediaprocessing/shared/common/CoordinatorBase.kt b/shared/common/src/main/kotlin/no/iktdev/mediaprocessing/shared/common/CoordinatorBase.kt
index 048fcbe0..93a054b8 100644
--- a/shared/common/src/main/kotlin/no/iktdev/mediaprocessing/shared/common/CoordinatorBase.kt
+++ b/shared/common/src/main/kotlin/no/iktdev/mediaprocessing/shared/common/CoordinatorBase.kt
@@ -1,9 +1,6 @@
 package no.iktdev.mediaprocessing.shared.common
 
-import kotlinx.coroutines.Dispatchers
-import kotlinx.coroutines.delay
-import kotlinx.coroutines.launch
-import kotlinx.coroutines.withContext
+import kotlinx.coroutines.*
 import mu.KotlinLogging
 import no.iktdev.exfl.coroutines.Coroutines
 import no.iktdev.mediaprocessing.shared.common.persistance.PersistentProcessDataMessage
@@ -37,6 +34,7 @@ abstract class CoordinatorBase<V, L: EventBasedMessageListener<V>> {
     abstract fun createTasksBasedOnEventsAndPersistence(referenceId: String, eventId: String, messages: List<V>)
 
     open fun onCoordinatorReady() {
+        log.info { "Attaching listeners to Coordinator" }
         listener.onMessageReceived = { event -> onMessageReceived(event)}
         listener.listen(KafkaEnv.kafkaTopic)
     }
@@ -46,20 +44,24 @@ abstract class CoordinatorBase<V, L: EventBasedMessageListener<V>> {
         val services = context.getBeansWithAnnotation(Service::class.java).values.map { it.javaClass }.filter { TaskCreatorImpl.isInstanceOfTaskCreatorImpl(it) }
         val loadedServices = listeners.listeners.map { it.taskHandler.javaClass as Class<Any> }
         val notPresent = services.filter { it !in loadedServices }
+
+        notPresent.forEach {
+            log.warn { "Waiting for ${it.simpleName} to attach.." }
+        }
+
         return notPresent.isEmpty()
     }
 
     @PostConstruct
     fun onInitializationCompleted() {
-        Coroutines.io().launch {
+        Coroutines.default().launch {
             while (!isAllServicesRegistered()) {
                 log.info { "Waiting for mandatory services to start" }
                 delay(1000)
             }
-            withContext(Dispatchers.Default) {
-                log.info { "Coordinator is Ready!" }
-                onCoordinatorReady()
-            }
+        }.invokeOnCompletion {
+            onCoordinatorReady()
+            log.info { "Coordinator is Ready!" }
         }
     }
 }
\ No newline at end of file