Commit 2698f299 authored by Jonas Waeber's avatar Jonas Waeber
Browse files

Update service utility dependency.

parent 8d787ebe
Pipeline #15883 passed with stages
in 8 minutes and 37 seconds
......@@ -41,7 +41,7 @@ dependencies {
//implementation "org.apache.kafka:kafka-streams:${kafkaV}"
compile group: 'org.apache.kafka', name: 'kafka-clients', version: kafkaV
implementation 'org.memobase:memobase-service-utilities:1.11.0'
implementation 'org.memobase:memobase-service-utilities:0.15.0'
// SFTP Client
// is needed because of a bug.
implementation 'com.hierynomus:sshj:0.27.0'
......
......@@ -84,9 +84,9 @@ class Service(fileName: String = "app.yml") {
log.info("Begin Validation: $file.")
val format = validator.validateExtension(file)
try {
val remoteFile = sftp.open(file)
remoteFile.use {
val validationResult = validator.validate(it.RemoteFileInputStream(), format, file)
val remoteInputStream = sftp.open(file)
remoteInputStream.use {
val validationResult = validator.validate(it, format, file)
log.info("Validation ${validationResult.second.status}.")
producer.sendMessage(validationResult.second.id, validationResult.first)
producer.sendReport(validationResult.second)
......
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