From a275514696c4a47aec88a9cd6eed2f0bff9bee12 Mon Sep 17 00:00:00 2001 From: bskjon Date: Fri, 19 Apr 2024 21:05:44 +0200 Subject: [PATCH] Update --- .../iktdev/mediaprocessing/processer/Implementations.kt | 8 ++++++-- .../mediaprocessing/processer/ProcesserApplication.kt | 3 --- 2 files changed, 6 insertions(+), 5 deletions(-) diff --git a/apps/processer/src/main/kotlin/no/iktdev/mediaprocessing/processer/Implementations.kt b/apps/processer/src/main/kotlin/no/iktdev/mediaprocessing/processer/Implementations.kt index 0789c8f9..c3e0281c 100644 --- a/apps/processer/src/main/kotlin/no/iktdev/mediaprocessing/processer/Implementations.kt +++ b/apps/processer/src/main/kotlin/no/iktdev/mediaprocessing/processer/Implementations.kt @@ -1,6 +1,7 @@ package no.iktdev.mediaprocessing.processer import no.iktdev.mediaprocessing.shared.common.Defaults +import no.iktdev.mediaprocessing.shared.common.socket.SocketImplementation import no.iktdev.mediaprocessing.shared.kafka.core.CoordinatorProducer import no.iktdev.mediaprocessing.shared.kafka.core.DefaultMessageListener import no.iktdev.mediaprocessing.shared.kafka.core.KafkaImplementation @@ -9,8 +10,7 @@ import org.springframework.context.annotation.Configuration import org.springframework.context.annotation.Import import org.springframework.web.client.RestTemplate -//@Configuration -//class SocketLocalInit: SocketImplementation() + @Configuration @Import(CoordinatorProducer::class, DefaultMessageListener::class) @@ -20,3 +20,7 @@ class KafkaLocalInit: KafkaImplementation() { @Configuration public class DefaultProcesserConfiguration: Defaults() { } + +@Configuration +class SocketImplemented: SocketImplementation() { +} \ No newline at end of file diff --git a/apps/processer/src/main/kotlin/no/iktdev/mediaprocessing/processer/ProcesserApplication.kt b/apps/processer/src/main/kotlin/no/iktdev/mediaprocessing/processer/ProcesserApplication.kt index 47870230..f6ec9fd8 100644 --- a/apps/processer/src/main/kotlin/no/iktdev/mediaprocessing/processer/ProcesserApplication.kt +++ b/apps/processer/src/main/kotlin/no/iktdev/mediaprocessing/processer/ProcesserApplication.kt @@ -41,9 +41,6 @@ fun main(args: Array) { val context = runApplication(*args) } -class SocketImplemented: SocketImplementation() { - -} @EnableScheduling class DatabaseReconnect() { var lostConnectionCount = 0