lazzexus/Kafkatorio
1
0
Fork 0
Code Issues Pull requests Projects Releases Packages Wiki Activity Actions

re-enable kafka processor

Browse source
This commit is contained in:
Adam 2022-07-02 08:54:38 +02:00
parent 8c9d8e40c2
commit db4350a927
1 changed files with 4 additions and 4 deletions
Download patch file Download diff file Expand all files Collapse all files

8
modules/events-server/src/main/kotlin/dev/adamko/kafkatorio/server/eventsServer.kt
View file

@ -1,10 +1,10 @@
package dev.adamko.kafkatorio.server
import dev.adamko.kafkatorio.server.config.ApplicationProperties
import dev.adamko.kafkatorio.server.processor.eventsProcessor
import dev.adamko.kafkatorio.server.socket.SyslogSocketServer
import dev.adamko.kafkatorio.server.web.startWebServer
import dev.adamko.kafkatorio.server.web.websocket.WebmapWebsocketServer
import kotlinx.coroutines.Dispatchers
import kotlinx.coroutines.coroutineScope
import kotlinx.coroutines.launch
@ -26,7 +26,7 @@ suspend fun main(): Unit = coroutineScope {
}
// launch(Dispatchers.Default.limitedParallelism(2)) {
// eventsProcessor(appProps, syslogSocketServer, websocketServer)
// }
launch {
eventsProcessor(appProps, syslogSocketServer, websocketServer)
}
}