Packages
exq
0.1.4
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.
Current section
Files
Jump to
Current section
Files
test/redis_queue_test.exs
Code.require_file "test_helper.exs", __DIR__
defmodule Exq.RedisQueueTest do
use ExUnit.Case
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 "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