Current section
Files
Jump to
Current section
Files
lib/cafex/topic/supervisor.ex
# Deprecated
defmodule Cafex.Topic.Supervisor do
@moduledoc false
use Supervisor
def start_link do
Supervisor.start_link __MODULE__, [], name: __MODULE__
end
def start_topic(name, brokers, opts \\ []) when is_binary(name) do
Supervisor.start_child __MODULE__, [name, brokers, opts]
end
def init([]) do
children = [
worker(Cafex.Topic.Server, [], restart: :temporary,
shutdown: 2000)
]
supervise children, strategy: :simple_one_for_one,
max_restarts: 10,
max_seconds: 60
end
end