Commit b1da8ebe authored by Jonas Waeber's avatar Jonas Waeber
Browse files

Fix service properties loader

parent 4443288e
Pipeline #11697 failed with stages
in 1 minute and 44 seconds
......@@ -37,8 +37,7 @@ class Service(fileName: String = "app.yml") {
fun createFedoraClient(appSettings: Properties): FedoraClient {
return FedoraClientImpl.builder()
// FIXME: update to new version supporting method properties()
//.properties(appSettings, FEDORA_PROPERTIES_PREFIX)
.properties(appSettings, FEDORA_PROPERTIES_PREFIX)
.build()
}
}
......@@ -58,11 +57,11 @@ class Service(fileName: String = "app.yml") {
private val log: Logger = LogManager.getLogger("FedoraIngestService")
private val consumer = Consumer(settings.kafkaConsumerSettings, settings.inputTopic)
val consumer = Consumer(settings.kafkaConsumerSettings, settings.inputTopic)
private val producer = Producer(settings.kafkaProducerSettings, settings.outputTopic)
private val sftp = SftpClient(settings.sftpSettings)
private val fedora = createFedoraClient(settings.appSettings)
private val ingester = Ingester(producer, sftp, fedora)
val ingester = Ingester(producer, sftp, fedora)
fun run() {
consumer.use { consumer ->
......
Supports Markdown
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