Packages
exq
0.1.3
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
assert Exq.RedisQueue.dequeue(:testredis, "test", "default") == :none
end
test "enqueue/dequeue multi queue" do
Exq.RedisQueue.enqueue(:testredis, "test", "default", "MyWorker", [])
Exq.RedisQueue.enqueue(:testredis, "test", "myqueue", "MyWorker", [])
assert Exq.RedisQueue.dequeue(:testredis, "test", ["default", "myqueue"]) != :none
assert Exq.RedisQueue.dequeue(:testredis, "test", ["default", "myqueue"]) != :none
assert Exq.RedisQueue.dequeue(:testredis, "test", ["default", "myqueue"]) == :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