Commit d55ac68c authored by Thomas Bernhart's avatar Thomas Bernhart
Browse files

Fix gradle compile errors

parent 5d0b6d56
......@@ -17,6 +17,10 @@
*/
package org.memobase
import java.io.Closeable
import java.io.File
import java.io.StringWriter
import java.net.URI
import org.apache.kafka.clients.consumer.ConsumerRecord
import org.apache.kafka.clients.consumer.ConsumerRecords
import org.apache.logging.log4j.LogManager
......@@ -24,10 +28,6 @@ import org.fcrepo.client.FcrepoOperationFailedException
import org.memobase.fedora.FedoraClient
import org.memobase.fedora.RdfContentTypes
import org.memobase.sftp.SftpClient
import java.io.Closeable
import java.io.File
import java.io.StringWriter
import java.net.URI
class Ingester(
private val producer: Producer,
......
......@@ -17,10 +17,10 @@
*/
package org.memobase
import org.apache.kafka.clients.producer.KafkaProducer
import org.apache.kafka.clients.producer.ProducerRecord
import java.io.Closeable
import java.util.Properties
import org.apache.kafka.clients.producer.KafkaProducer
import org.apache.kafka.clients.producer.ProducerRecord
class Producer(props: Properties, topic: String) : Closeable {
private val instance = KafkaProducer<String, String>(props)
......
package org.memobase
import java.io.ByteArrayInputStream
import org.apache.jena.rdf.model.Model
import org.apache.jena.rdf.model.ModelFactory
import org.apache.jena.rdf.model.Statement
......@@ -9,7 +10,6 @@ import org.apache.log4j.LogManager
import org.memobase.rdf.EBUCORE
import org.memobase.rdf.RDF
import org.memobase.rdf.RICO
import java.io.ByteArrayInputStream
class RdfHandler(data: String) {
private val log = LogManager.getLogger("RdfHandler")
......@@ -100,4 +100,4 @@ class RdfHandler(data: String) {
Pair(it.uri, it.getProperty(EBUCORE.hasMimeType).`object`.asLiteral().string)
}.toList()
}
}
\ No newline at end of file
}
......@@ -19,13 +19,13 @@
package org.memobase
// import org.bouncycastle.cms.RecipientId.password
import java.util.Properties
import org.apache.logging.log4j.LogManager
import org.apache.logging.log4j.Logger
import org.memobase.fedora.FedoraClient
import org.memobase.fedora.FedoraClientImpl
import org.memobase.settings.SettingsLoader
import org.memobase.sftp.SftpClient
import java.util.Properties
class Service(fileName: String = "app.yml") {
......
......@@ -17,28 +17,28 @@
*/
package org.memobase
// import java.io.File
// import java.time.Duration
import java.util.Properties
import java.util.stream.Stream
import org.apache.kafka.clients.admin.AdminClient
import org.apache.kafka.clients.admin.AdminClientConfig
import org.apache.kafka.clients.consumer.ConsumerConfig
import org.apache.kafka.clients.consumer.ConsumerRecord
// import org.apache.kafka.clients.consumer.ConsumerRecord
import org.apache.kafka.clients.consumer.KafkaConsumer
import org.apache.kafka.clients.producer.KafkaProducer
import org.apache.kafka.clients.producer.ProducerConfig
import org.apache.kafka.clients.producer.ProducerRecord
// import org.apache.kafka.clients.producer.ProducerRecord
import org.apache.kafka.common.serialization.StringDeserializer
import org.apache.kafka.common.serialization.StringSerializer
import org.apache.logging.log4j.LogManager
import org.assertj.core.api.Assertions.assertThat
// import org.assertj.core.api.Assertions.assertThat
import org.junit.jupiter.api.TestInstance
import org.junit.jupiter.api.extension.ExtendWith
import org.junit.jupiter.params.ParameterizedTest
import org.junit.jupiter.params.provider.MethodSource
import org.memobase.testing.EmbeddedKafkaExtension
import org.memobase.testing.EmbeddedSftpServer
import java.io.File
import java.time.Duration
import java.util.Properties
import java.util.stream.Stream
@ExtendWith(EmbeddedKafkaExtension::class)
@TestInstance(TestInstance.Lifecycle.PER_CLASS)
......
package org.memobase
import java.io.File
import java.io.StringWriter
import java.nio.charset.Charset
import org.apache.jena.riot.Lang
import org.apache.jena.riot.RDFDataMgr
import org.assertj.core.api.Assertions.assertThat
import org.junit.jupiter.api.Test
import org.junit.jupiter.api.TestInstance
import java.io.File
import java.io.StringWriter
import java.nio.charset.Charset
@TestInstance(TestInstance.Lifecycle.PER_CLASS)
class TestRdfHandler {
......@@ -18,7 +17,6 @@ class TestRdfHandler {
return File("$resourcePath/$fileName").readText(Charset.defaultCharset())
}
private val regex = Regex("(_:B[A-Za-z0-9]+)")
private fun sort(input: List<String>): String {
......@@ -112,10 +110,8 @@ class TestRdfHandler {
assertThat(rdfHandler.getMimeType().first().second).isEqualTo("video/mpeg")
}
private val uris2 = listOf(
"https://memobase.ch/instantiation/digital/AFZ-IB_Becker_Audiovisuals_63-1",
"https://memobase.ch/instantiation/digital/AFZ-IB_Becker_Audiovisuals_63-2"
)
}
\ No newline at end of file
}
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