Commit 7c57956b authored by Jonas Waeber's avatar Jonas Waeber
Browse files

Update class names

parent 7fad82ae
......@@ -23,7 +23,7 @@ import org.apache.logging.log4j.LogManager
class App {
companion object {
private val log = LogManager.getLogger("TableDataTransformApp")
private val log = LogManager.getLogger("XmlDataApp")
@JvmStatic fun main(args: Array<String>) {
try {
Service().run()
......
......@@ -40,7 +40,7 @@ import java.io.StringReader
class KafkaTopology(private val settings: SettingsLoader) {
private val log = LogManager.getLogger("XMLDataImport")
private val log = LogManager.getLogger("XmlDataTopology")
private val sftpClient: SftpClient = SftpClient(settings.sftpSettings)
private val xmlTransformer = XMLTransformer()
private val configJoiner = ConfigJoiner<Message, ByteArray>(
......
......@@ -21,10 +21,9 @@ package org.memobase
import org.apache.kafka.streams.KafkaStreams
import org.apache.logging.log4j.LogManager
import org.memobase.settings.SettingsLoader
import kotlin.system.exitProcess
class Service(file: String = "app.yml") {
private val log = LogManager.getLogger("TableDataService")
private val log = LogManager.getLogger("XmlDataService")
val settings = SettingsLoader(
listOf(),
......
Markdown is supported
0% or .
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment