comet.sh
1defmodule BasicConsumer do
2 @behaviour Drinkup.Consumer
3
4 def handle_event(%Drinkup.Event.Commit{} = event) do
5 IO.inspect(event, label: "Got commit event")
6 end
7
8 def handle_event(_), do: :noop
9end
10
11defmodule ExampleSupervisor do
12 use Supervisor
13
14 def start_link(arg \\ []) do
15 Supervisor.start_link(__MODULE__, arg, name: __MODULE__)
16 end
17
18 @impl true
19 def init(_) do
20 children = [
21 {Drinkup, %{consumer: BasicConsumer}}
22 ]
23
24 Supervisor.init(children, strategy: :one_for_one)
25 end
26end