Unverified Commit e7368098 authored by Sebastian Schüpbach's avatar Sebastian Schüpbach
Browse files

remove effects registry

parent ac3eb855
......@@ -40,7 +40,6 @@ lazy val root = (project in file("."))
log4jCore,
log4jSlf4j,
log4jScala,
memobaseProcessRegistry,
memobaseServiceUtils,
requests,
scalatic,
......
......@@ -32,7 +32,6 @@ object Dependencies {
lazy val log4jCore = "org.apache.logging.log4j" % "log4j-core" % log4jV
lazy val log4jScala = "org.apache.logging.log4j" %% "log4j-api-scala" % "11.0"
lazy val log4jSlf4j = "org.apache.logging.log4j" % "log4j-slf4j-impl" % log4jV
lazy val memobaseProcessRegistry = "ch.memobase" %% "import-process-effects-registry" % "0.2.1"
lazy val memobaseServiceUtils = "org.memobase" % "memobase-service-utilities" % "1.4.1"
lazy val rdfRioApi = "org.eclipse.rdf4j" % "rdf4j-rio-api" % "3.2.3"
lazy val rdfRioNtriples = "org.eclipse.rdf4j" % "rdf4j-rio-ntriples" % "3.2.3"
......
......@@ -36,20 +36,6 @@ class KafkaTopology extends Logging {
def build(): Topology = {
val builder = new StreamsBuilder
EffectsRegistry()
.register(
ShutdownMessage(
SettingsFromFile.getApplicationId.replace("-media-metadata-extractor", ""),
"media-metadata-extractor",
"termination"),
Effect(
"shutdown",
() => {
logger.info("Termination message received. Shutting down")
sys.exit(0)
},
Some("shuts down application"))
).run(builder, "import-process-admin")
val source = builder.stream[String, String](SettingsFromFile.getKafkaInputTopic)
......
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