Packages

exq

0.2.1
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
6 Dependencies
Dependants
Files
Activity
exq test redis_queue_test.exs
Raw

test/redis_queue_test.exs 

Code.require_file "test_helper.exs", __DIR__



defmodule Exq.RedisQueueTest do

  use ExUnit.Case

  use Timex



  setup_all do

    TestRedis.setup

    on_exit fn ->

      TestRedis.teardown

    end

  end





  test "enqueue/dequeue single queue" do

    Exq.RedisQueue.enqueue(:testredis, "test", "default", "MyWorker", [])

    {deq, _} = Exq.RedisQueue.dequeue(:testredis, "test", "default")

    assert deq != :none

    {deq, _} = Exq.RedisQueue.dequeue(:testredis, "test", "default")

    assert deq == :none

  end



  test "enqueue/dequeue multi queue" do

    Exq.RedisQueue.enqueue(:testredis, "test", "default", "MyWorker", [])

    Exq.RedisQueue.enqueue(:testredis, "test", "myqueue", "MyWorker", [])

    assert elem(Exq.RedisQueue.dequeue(:testredis, "test", ["default", "myqueue"]), 0) != :none

    assert elem(Exq.RedisQueue.dequeue(:testredis, "test", ["default", "myqueue"]), 0) != :none

    assert elem(Exq.RedisQueue.dequeue(:testredis, "test", ["default", "myqueue"]), 0) == :none

  end



  test "scheduler_dequeue single queue" do

    Exq.RedisQueue.enqueue_in(:testredis, "test", "default", 0, "MyWorker", [])

    Exq.RedisQueue.enqueue_in(:testredis, "test", "default", 0, "MyWorker", [])

    assert Exq.RedisQueue.scheduler_dequeue(:testredis, "test", ["default"]) == 2

    assert elem(Exq.RedisQueue.dequeue(:testredis, "test", "default"), 0) != :none

    assert elem(Exq.RedisQueue.dequeue(:testredis, "test", "default"), 0) != :none

    assert elem(Exq.RedisQueue.dequeue(:testredis, "test", "default"), 0) == :none

  end



  test "scheduler_dequeue multi queue" do

    Exq.RedisQueue.enqueue_in(:testredis, "test", "default", -1, "MyWorker", [])

    Exq.RedisQueue.enqueue_in(:testredis, "test", "myqueue", -1, "MyWorker", [])

    assert Exq.RedisQueue.scheduler_dequeue(:testredis, "test", ["default", "myqueue"]) == 2

    assert elem(Exq.RedisQueue.dequeue(:testredis, "test", ["default", "myqueue"]), 0) != :none

    assert elem(Exq.RedisQueue.dequeue(:testredis, "test", ["default", "myqueue"]), 0) != :none

    assert elem(Exq.RedisQueue.dequeue(:testredis, "test", ["default", "myqueue"]), 0) == :none

  end



  test "scheduler_dequeue enqueue_at" do

    Exq.RedisQueue.enqueue_at(:testredis, "test", "default", Time.now, "MyWorker", [])

    assert Exq.RedisQueue.scheduler_dequeue(:testredis, "test", ["default"]) == 1

    assert elem(Exq.RedisQueue.dequeue(:testredis, "test", "default"), 0) != :none

    assert elem(Exq.RedisQueue.dequeue(:testredis, "test", "default"), 0) == :none

  end



  test "scheduler_dequeue max_score" do

    Exq.RedisQueue.enqueue_in(:testredis, "test", "default", 300, "MyWorker", [])

    now = Time.now

    time1 = Time.add(now, Time.from(140, :secs))

    Exq.RedisQueue.enqueue_at(:testredis, "test", "default", time1, "MyWorker", [])

    time2 = Time.add(now, Time.from(150, :secs))

    Exq.RedisQueue.enqueue_at(:testredis, "test", "default", time2, "MyWorker", [])

    time2a = Time.add(now, Time.from(151, :secs))

    time2b = Time.add(now, Time.from(159, :secs))

    time3 = Time.add(now, Time.from(160, :secs))

    Exq.RedisQueue.enqueue_at(:testredis, "test", "default", time3, "MyWorker", [])

    time4 = Time.add(now, Time.from(160000001, :usecs))

    Exq.RedisQueue.enqueue_at(:testredis, "test", "default", time4, "MyWorker", [])

    time5 = Time.add(now, Time.from(300, :secs))



    assert Exq.Enqueuer.queue_size(:testredis, "test", "default") == "0"

    assert Exq.Enqueuer.queue_size(:testredis, "test", :scheduled) == "5"



    assert Exq.RedisQueue.scheduler_dequeue(:testredis, "test", ["default"], Exq.RedisQueue.time_to_score(time2a)) == 2

    assert Exq.RedisQueue.scheduler_dequeue(:testredis, "test", ["default"], Exq.RedisQueue.time_to_score(time2b)) == 0

    assert Exq.RedisQueue.scheduler_dequeue(:testredis, "test", ["default"], Exq.RedisQueue.time_to_score(time3)) == 1

    assert Exq.RedisQueue.scheduler_dequeue(:testredis, "test", ["default"], Exq.RedisQueue.time_to_score(time3)) == 0

    assert Exq.RedisQueue.scheduler_dequeue(:testredis, "test", ["default"], Exq.RedisQueue.time_to_score(time4)) == 1

    assert Exq.RedisQueue.scheduler_dequeue(:testredis, "test", ["default"], Exq.RedisQueue.time_to_score(time5)) == 1



    assert Exq.Enqueuer.queue_size(:testredis, "test", "default") == "5"

    assert Exq.Enqueuer.queue_size(:testredis, "test", :scheduled) == "0"



    assert elem(Exq.RedisQueue.dequeue(:testredis, "test", "default"), 0) != :none

    assert elem(Exq.RedisQueue.dequeue(:testredis, "test", "default"), 0) != :none

    assert elem(Exq.RedisQueue.dequeue(:testredis, "test", "default"), 0) != :none

    assert elem(Exq.RedisQueue.dequeue(:testredis, "test", "default"), 0) != :none

    assert elem(Exq.RedisQueue.dequeue(:testredis, "test", "default"), 0) != :none

    assert elem(Exq.RedisQueue.dequeue(:testredis, "test", "default"), 0) == :none

  end



  test "full_key" do

    assert Exq.RedisQueue.full_key("exq","k1") == "exq:k1"

    assert Exq.RedisQueue.full_key("","k1") == "k1"

    assert Exq.RedisQueue.full_key(nil,"k1") == "k1"

  end



  test "creates and returns a jid" do

    jid = Exq.RedisQueue.enqueue(:testredis, "test", "default", "MyWorker", [])

    assert jid != nil



    {job_str, _} = Exq.RedisQueue.dequeue(:testredis, "test", "default")

    job = Poison.decode!(job_str, as: Exq.Job)

    assert job.jid == jid

  end



end