Packages

express

1.1.3
1.3.3 1.3.2 1.3.1 1.3.0 1.2.13 1.2.12 1.2.11 1.2.10 1.2.9 1.2.7 1.2.6 1.2.5 1.2.4 1.2.3 1.2.2 1.2.1 1.2.0 1.1.3 1.1.2 1.1.1 1.1.0 1.0.0

Library for sending push notifications. Supports Apple APNS (with either ssl certificate or JWT) and Google FCM services.

HexDocs

Current section

Files

Jump to
Readme
22 Versions
8 Dependencies
Dependants
Files
Activity
express lib express push_requests consumers_supervisor.ex
Raw

lib/express/push_requests/consumers_supervisor.ex 

defmodule Express.PushRequests.ConsumersSupervisor do

  @moduledoc """

  Dynamically spawns and supervises consumers for the push requests buffer.

  """



  use Supervisor



  def start_link do

    Supervisor.start_link(__MODULE__, :ok, name: __MODULE__)

  end



  def init(:ok), do: supervise(children(), opts())



  defp children do

    [

      worker(

        Express.PushRequests.Consumer,

        [],

        restart: :permanent

      )

    ]

  end



  defp opts do

    [strategy: :simple_one_for_one, name: __MODULE__]

  end



  @doc "Spawns the buffer consumer."

  @spec start_consumer() :: Supervisor.on_start_child

  def start_consumer do

    Supervisor.start_child(__MODULE__, [])

  end

end