diff --git a/apps/converter/src/main/java/no/iktdev/mediaprocessing/Main.java b/apps/converter/src/main/java/no/iktdev/mediaprocessing/Main.java deleted file mode 100644 index a8ec1821..00000000 --- a/apps/converter/src/main/java/no/iktdev/mediaprocessing/Main.java +++ /dev/null @@ -1,7 +0,0 @@ -package no.iktdev.mediaprocessing; - -public class Main { - public static void main(String[] args) { - System.out.println("Hello world!"); - } -} \ No newline at end of file diff --git a/apps/coordinator/src/test/kotlin/FlowITTest.kt b/apps/coordinator/src/test/kotlin/FlowITTest.kt deleted file mode 100644 index 56c4fe80..00000000 --- a/apps/coordinator/src/test/kotlin/FlowITTest.kt +++ /dev/null @@ -1,3 +0,0 @@ -class FlowITTest { - //val h2 = H2DataSource() -} \ No newline at end of file diff --git a/apps/coordinator/src/test/kotlin/TestKafka.kt b/apps/coordinator/src/test/kotlin/TestKafka.kt deleted file mode 100644 index f1829611..00000000 --- a/apps/coordinator/src/test/kotlin/TestKafka.kt +++ /dev/null @@ -1,72 +0,0 @@ -import com.google.gson.Gson -import no.iktdev.mediaprocessing.shared.common.kafka.CoordinatorProducer -import no.iktdev.mediaprocessing.shared.kafka.core.DefaultConsumer -import no.iktdev.mediaprocessing.shared.kafka.core.DefaultMessageListener -import no.iktdev.mediaprocessing.shared.kafka.core.DefaultProducer -import no.iktdev.mediaprocessing.shared.kafka.core.KafkaEnv -import no.iktdev.mediaprocessing.shared.kafka.dto.Message -import no.iktdev.mediaprocessing.shared.kafka.dto.MessageDataWrapper -import org.apache.kafka.clients.consumer.ConsumerConfig -import org.apache.kafka.clients.consumer.ConsumerRecord -import org.apache.kafka.clients.producer.ProducerConfig -import org.apache.kafka.common.serialization.StringDeserializer -import org.apache.kafka.common.serialization.StringSerializer -import org.springframework.kafka.core.DefaultKafkaConsumerFactory -import org.springframework.kafka.core.DefaultKafkaProducerFactory -import org.springframework.kafka.core.KafkaTemplate -import org.springframework.kafka.core.ProducerFactory - -class TestKafka { - companion object { - private var listen: Boolean = false - private val topic = "nan" - private val gson = Gson() - - val consumer = object : DefaultConsumer() { - override fun consumerFactory(): DefaultKafkaConsumerFactory { - val config: MutableMap = HashMap() - config[ConsumerConfig.GROUP_ID_CONFIG] = "${KafkaEnv.consumerId}:$subId" - config[ConsumerConfig.KEY_DESERIALIZER_CLASS_CONFIG] = StringDeserializer::class.java - config[ConsumerConfig.VALUE_DESERIALIZER_CLASS_CONFIG] = StringDeserializer::class.java - config[ConsumerConfig.ENABLE_AUTO_COMMIT_CONFIG] = autoCommit - return DefaultKafkaConsumerFactory(config, StringDeserializer(), StringDeserializer()) - } - } - - val listener = object: DefaultMessageListener(topic, consumer) { - override fun listen() { - listen = true - } - } - - val producer = object: CoordinatorProducer() { - - val messages = mutableListOf>() - - override fun usingKafkaTemplate(): KafkaTemplate { - val producerFactory: ProducerFactory = DefaultKafkaProducerFactory(mapOf( - ProducerConfig.KEY_SERIALIZER_CLASS_CONFIG to StringSerializer::class.java, - ProducerConfig.VALUE_SERIALIZER_CLASS_CONFIG to StringSerializer::class.java - )) - return KafkaTemplate(producerFactory) - } - - - override fun sendMessage(key: String, message: Message) { - val mockRecord = ConsumerRecord( - topic, - 0, - messages.size.toLong(), - key, - gson.toJson(message) - ) - if (listen) { - messages.add(mockRecord) - listener.onMessage(mockRecord) - } - } - } - } - - -} \ No newline at end of file diff --git a/apps/coordinator/src/test/kotlin/TestMessageListener.kt b/apps/coordinator/src/test/kotlin/TestMessageListener.kt deleted file mode 100644 index bdf0a596..00000000 --- a/apps/coordinator/src/test/kotlin/TestMessageListener.kt +++ /dev/null @@ -1,6 +0,0 @@ -import no.iktdev.mediaprocessing.shared.kafka.core.DefaultMessageListener - -class TestMessageListener: DefaultMessageListener("nan") { - override fun listen() { - } -} \ No newline at end of file diff --git a/apps/src/main/java/no/iktdev/mediaprocessing/Main.java b/apps/src/main/java/no/iktdev/mediaprocessing/Main.java deleted file mode 100644 index a8ec1821..00000000 --- a/apps/src/main/java/no/iktdev/mediaprocessing/Main.java +++ /dev/null @@ -1,7 +0,0 @@ -package no.iktdev.mediaprocessing; - -public class Main { - public static void main(String[] args) { - System.out.println("Hello world!"); - } -} \ No newline at end of file diff --git a/src/main/java/no/iktdev/mediaprocessing/Main.java b/src/main/java/no/iktdev/mediaprocessing/Main.java deleted file mode 100644 index a8ec1821..00000000 --- a/src/main/java/no/iktdev/mediaprocessing/Main.java +++ /dev/null @@ -1,7 +0,0 @@ -package no.iktdev.mediaprocessing; - -public class Main { - public static void main(String[] args) { - System.out.println("Hello world!"); - } -} \ No newline at end of file