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

renaming events server, to match project and so Gradle task.run works

Browse source
This commit is contained in:
Adam 2022-01-09 11:05:30 +01:00
parent 101e48c593
commit 5a406358d8
3 changed files with 3 additions and 3 deletions
Download patch file Download diff file Expand all files Collapse all files

2
modules/events-server/build.gradle.kts
View file

@ -38,7 +38,7 @@ dependencies {
} }
application { application {
mainClass.set("dev.adamko.factorioevents.processor.mainKt") mainClass.set("dev.adamko.kafkatorio.processor.EventProcessorKt")
} }
tasks.withType<KotlinCompile> { tasks.withType<KotlinCompile> {

2
modules/events-server/src/main/kotlin/dev/adamko/kafkatorio/processor/FactorioEventsTopology.kt → modules/events-server/src/main/kotlin/dev/adamko/kafkatorio/processor/KafkatorioTopology.kt
View file

@ -13,7 +13,7 @@ import org.apache.kafka.streams.TopologyDescription
import org.apache.kafka.streams.kstream.Consumed import org.apache.kafka.streams.kstream.Consumed
import org.apache.kafka.streams.kstream.Produced import org.apache.kafka.streams.kstream.Produced
class FactorioEventsTopology( class KafkatorioTopology(
private val websocketServer: WebsocketServer, private val websocketServer: WebsocketServer,
private val builder: StreamsBuilder = StreamsBuilder(), private val builder: StreamsBuilder = StreamsBuilder(),
) { ) {

2
modules/events-server/src/main/kotlin/dev/adamko/kafkatorio/processor/eventProcessor.kt
View file

@ -12,7 +12,7 @@ fun main() = runBlocking {
val wsServer = WebsocketServer() val wsServer = WebsocketServer()
val topology = FactorioEventsTopology(wsServer) val topology = KafkatorioTopology(wsServer)
topology.build() topology.build()
wsServer.build().asServer(Undertow(9073)).start().block() wsServer.build().asServer(Undertow(9073)).start().block()