iktdev/MediaProcessing
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

Mini change

Browse Source
This commit is contained in:
bskjon 2025-04-11 23:39:02 +02:00
parent 66589ffaf6
commit d1e96f5d2a
1 changed files with 16 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

18
apps/coordinator/src/main/kotlin/no/iktdev/mediaprocessing/coordinator/CoordinatorApplication.kt
View File

@ -36,8 +36,22 @@ class CoordinatorApplication {
private lateinit var storeDatabase: MySqlDataSource
val ioCoroutine = CoroutinesIO()
val defaultCoroutine = CoroutinesDefault()
val ioCoroutine = CoroutinesIO().
also {
it.addListener(object : Observables.ObservableValue.ValueListener<Throwable> {
override fun onUpdated(value: Throwable) {
log.error { "IO Coroutine" + value.printStackTrace() }
}
})
}
val defaultCoroutine = CoroutinesDefault().
also {
it.addListener(object : Observables.ObservableValue.ValueListener<Throwable> {
override fun onUpdated(value: Throwable) {
log.error { "Default Coroutine" + value.printStackTrace() }
}
})
}
fun getStoreDatabase(): MySqlDataSource {