defmodule ElixirDrip.Storage.Workers.QueueWorker do
use GenServer
require Logger
def start_link(name) do
GenServer.start_link(__MODULE__, [], name: queue_name(name))
end
def queue_name(name) do
name = name
|> Atom.to_string()
|> String.capitalize()
Module.concat(__MODULE__, name)
end
def init(queue) do
Logger.debug("#{inspect(self())}: QueueWorker started.")
{:ok, queue}
This file has been truncated. show original
