From 5a406358d850251aad6f7d996b52b71369d5dc99 Mon Sep 17 00:00:00 2001 From: Adam <897017+aSemy@users.noreply.github.com> Date: Sun, 9 Jan 2022 11:05:30 +0100 Subject: [PATCH] renaming events server, to match project and so Gradle task.run works --- modules/events-server/build.gradle.kts | 2 +- .../{FactorioEventsTopology.kt => KafkatorioTopology.kt} | 2 +- .../kotlin/dev/adamko/kafkatorio/processor/eventProcessor.kt | 2 +- 3 files changed, 3 insertions(+), 3 deletions(-) rename modules/events-server/src/main/kotlin/dev/adamko/kafkatorio/processor/{FactorioEventsTopology.kt => KafkatorioTopology.kt} (98%) diff --git a/modules/events-server/build.gradle.kts b/modules/events-server/build.gradle.kts index ed4964e..f1e7b8c 100644 --- a/modules/events-server/build.gradle.kts +++ b/modules/events-server/build.gradle.kts @@ -38,7 +38,7 @@ dependencies { } application { - mainClass.set("dev.adamko.factorioevents.processor.mainKt") + mainClass.set("dev.adamko.kafkatorio.processor.EventProcessorKt") } tasks.withType { diff --git a/modules/events-server/src/main/kotlin/dev/adamko/kafkatorio/processor/FactorioEventsTopology.kt b/modules/events-server/src/main/kotlin/dev/adamko/kafkatorio/processor/KafkatorioTopology.kt similarity index 98% rename from modules/events-server/src/main/kotlin/dev/adamko/kafkatorio/processor/FactorioEventsTopology.kt rename to modules/events-server/src/main/kotlin/dev/adamko/kafkatorio/processor/KafkatorioTopology.kt index 139bf1b..523b291 100644 --- a/modules/events-server/src/main/kotlin/dev/adamko/kafkatorio/processor/FactorioEventsTopology.kt +++ b/modules/events-server/src/main/kotlin/dev/adamko/kafkatorio/processor/KafkatorioTopology.kt @@ -13,7 +13,7 @@ import org.apache.kafka.streams.TopologyDescription import org.apache.kafka.streams.kstream.Consumed import org.apache.kafka.streams.kstream.Produced -class FactorioEventsTopology( +class KafkatorioTopology( private val websocketServer: WebsocketServer, private val builder: StreamsBuilder = StreamsBuilder(), ) { diff --git a/modules/events-server/src/main/kotlin/dev/adamko/kafkatorio/processor/eventProcessor.kt b/modules/events-server/src/main/kotlin/dev/adamko/kafkatorio/processor/eventProcessor.kt index 0011293..499cb63 100644 --- a/modules/events-server/src/main/kotlin/dev/adamko/kafkatorio/processor/eventProcessor.kt +++ b/modules/events-server/src/main/kotlin/dev/adamko/kafkatorio/processor/eventProcessor.kt @@ -12,7 +12,7 @@ fun main() = runBlocking { val wsServer = WebsocketServer() - val topology = FactorioEventsTopology(wsServer) + val topology = KafkatorioTopology(wsServer) topology.build() wsServer.build().asServer(Undertow(9073)).start().block()