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

fix example code in README

parent 61599fc9
Pipeline #13391 passed with stages
in 6 minutes and 7 seconds
......@@ -20,8 +20,8 @@ val inputTopic = ...
// `inputTopic` is the name of the topic where the maintenance message are
stored; props is a variable containing properties for the Kafka consumer
val registry = EffectsRegistry()
val shutdownEffect = Effect("shutdown", () => sys.exit(0), "shuts down
val shutdownEffect = Effect("shutdown", () => sys.exit(0), Some("shuts down
// the `register` method takes a message matcher as well as an instance of the
`Effect` case class
registry.register(ShutdownMessage, shutdownEffect)
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