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

v3 11

Browse Source
This commit is contained in:
bskjon 2024-07-14 00:16:06 +02:00
parent 94e7aa02b0
commit 0d38a75797
2 changed files with 4 additions and 7 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

5
apps/converter/src/main/kotlin/no/iktdev/mediaprocessing/converter/ConverterApplication.kt
View File

@ -31,9 +31,6 @@ fun getEventsDatabase(): MySqlDataSource {
} }
fun main(args: Array<String>) { fun main(args: Array<String>) {
runApplication<ConvertApplication>(*args)
log.info { "App Version: ${getAppVersion()}" }
ioCoroutine.addListener(listener = object: Observables.ObservableValue.ValueListener<Throwable> { ioCoroutine.addListener(listener = object: Observables.ObservableValue.ValueListener<Throwable> {
override fun onUpdated(value: Throwable) { override fun onUpdated(value: Throwable) {
value.printStackTrace() value.printStackTrace()
@ -54,5 +51,7 @@ fun main(args: Array<String>) {
runnerManager = RunnerManager(dataSource = getEventsDatabase(), name = ConvertApplication::class.java.simpleName) runnerManager = RunnerManager(dataSource = getEventsDatabase(), name = ConvertApplication::class.java.simpleName)
runnerManager.assignRunner() runnerManager.assignRunner()
runApplication<ConvertApplication>(*args)
log.info { "App Version: ${getAppVersion()}" }
} }
//private val logger = KotlinLogging.logger {} //private val logger = KotlinLogging.logger {}

6
apps/processer/src/main/kotlin/no/iktdev/mediaprocessing/processer/ProcesserApplication.kt
View File

@ -39,9 +39,6 @@ private val log = KotlinLogging.logger {}
fun main(args: Array<String>) { fun main(args: Array<String>) {
runApplication<ProcesserApplication>(*args)
log.info { "App Version: ${getAppVersion()}" }
ioCoroutine.addListener(listener = object: Observables.ObservableValue.ValueListener<Throwable> { ioCoroutine.addListener(listener = object: Observables.ObservableValue.ValueListener<Throwable> {
override fun onUpdated(value: Throwable) { override fun onUpdated(value: Throwable) {
value.printStackTrace() value.printStackTrace()
@ -62,7 +59,8 @@ fun main(args: Array<String>) {
runnerManager = RunnerManager(dataSource = getEventsDatabase(), name = ProcesserApplication::class.java.simpleName) runnerManager = RunnerManager(dataSource = getEventsDatabase(), name = ProcesserApplication::class.java.simpleName)
runnerManager.assignRunner() runnerManager.assignRunner()
runApplication<ProcesserApplication>(*args)
log.info { "App Version: ${getAppVersion()}" }
} }