Packages

exq

0.18.0
0.23.0 0.22.0 0.21.0 0.20.0 0.19.0 0.18.0 0.17.0 0.16.2 0.16.1 0.16.0 0.15.0 0.14.0 0.13.5 0.13.4 0.13.3 0.13.2 0.13.1 0.13.0 0.12.2 0.12.1 0.12.0 0.11.0 0.10.1 0.10.0 0.9.1 0.9.0 0.8.7 0.8.6 0.8.5 0.8.4 0.8.3 0.8.2 0.8.1 0.8.0 0.7.3 0.7.2 0.7.1 0.7.0 0.6.5 0.6.4 0.6.3 0.6.2 0.6.1 0.6.0 0.5.0 0.4.4 0.4.3 0.4.2 0.4.1 0.4.0 0.3.0 0.2.3 0.2.2 0.2.1 0.2.0 0.1.4 0.1.3 0.1.2 0.1.1 0.1.0 0.0.2

Exq is a job processing library compatible with Resque / Sidekiq for the Elixir language.

HexDocs

Current section

Files

Jump to
Readme
61 Versions
4 Dependencies
Dependants
Files
Activity
exq lib exq adapters queue redis.ex
Raw

lib/exq/adapters/queue/redis.ex 

defmodule Exq.Adapters.Queue.Redis do

  @moduledoc """

  Redis based Asynchronous queue.



  Enqueue the job by using the GenServer API. Default queue. Designed to be used in production.

  """

  alias Exq.Support.Config

  alias Exq.Redis.JobQueue



  @behaviour Exq.Adapters.Queue



  def enqueue(pid, queue, worker, args, options) do

    {redis, namespace} = GenServer.call(pid, :redis, Config.get(:genserver_timeout))

    JobQueue.enqueue(redis, namespace, queue, worker, args, options)

  end



  def enqueue_at(pid, queue, time, worker, args, options) do

    {redis, namespace} = GenServer.call(pid, :redis, Config.get(:genserver_timeout))

    JobQueue.enqueue_at(redis, namespace, queue, time, worker, args, options)

  end



  def enqueue_in(pid, queue, offset, worker, args, options) do

    {redis, namespace} = GenServer.call(pid, :redis, Config.get(:genserver_timeout))

    JobQueue.enqueue_in(redis, namespace, queue, offset, worker, args, options)

  end



  def enqueue_all(pid, jobs) do

    {redis, namespace} = GenServer.call(pid, :redis, Config.get(:genserver_timeout))

    JobQueue.enqueue_all(redis, namespace, jobs)

  end

end