toniq

# Used for manual testing of toniq
# Usage: Toniq.enqueue(Toniq.TestWorker)
defmodule Toniq.TestWorker do
  use Toniq.Worker, max_concurrency: 2

  # Usage: Toniq.enqueue(Toniq.TestWorker, :fail)
  #
  # To make this fail right away:
  # Application.put_env(:toniq, :retry_strategy, Toniq.RetryWithoutDelayStrategy)
  def perform(:fail) do
    IO.inspect "Running fail-every-time job"
    raise "failing every time"
  end

  def perform(:fail_once) do
    unless Application.get_env(:toniq, :fail_once) do
      Application.put_env(:toniq, :fail_once, true)
      raise "failing once"
    end

    IO.inspect "fail once job succeeded"
  end

  def perform([]) do
    IO.puts "Job started in #{Toniq.Keepalive.identifier}"
    :timer.sleep 3000
    IO.puts "Job finished in #{Toniq.Keepalive.identifier}"
  end
end