Packages
mississippi
1.0.0
A framework for handling distributed and ordered processing of data over AMQP queues.
Current section
Files
Jump to
Current section
Files
lib/consumer/data_updater_supervisor.ex
# Copyright 2024 SECO Mind Srl
# SPDX-License-Identifier: Apache-2.0
defmodule Mississippi.Consumer.DataUpdater.Supervisor do
@moduledoc false
use DynamicSupervisor
require Logger
def start_link(init_args) do
DynamicSupervisor.start_link(__MODULE__, init_args, name: __MODULE__)
end
@impl true
def init(init_args) do
_ = Logger.info("Starting DataUpdater supervisor")
DynamicSupervisor.init(strategy: :one_for_one, extra_arguments: init_args)
end
def start_child(child) do
DynamicSupervisor.start_child(__MODULE__, child)
end
def terminate_child(pid) do
_ =
Logger.info("Terminating a DataUpdater")
DynamicSupervisor.terminate_child(__MODULE__, pid)
end
end