Skip to content

Commit ed2c8b0

Browse files
committed
Add testing for queue_latency API
1 parent a5e8f18 commit ed2c8b0

1 file changed

Lines changed: 15 additions & 0 deletions

File tree

test/client_test.rb

Lines changed: 15 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -51,4 +51,19 @@ def test_queue_pause_and_resume
5151
assert client.pause_queues ["foo", "bar"]
5252
assert client.resume_queues "*"
5353
end
54+
55+
def test_queue_latency
56+
client = Faktory::Client.new
57+
assert_equal({"foo" => 0, "default" => 0}, client.queue_latency("default", "foo"))
58+
client.push(jobtype: "mike", jid: "123456789", args: [])
59+
hsh = client.queue_latency("default")
60+
assert_in_delta 0.1, hsh["default"], 0.1
61+
62+
assert_raises ArgumentError do
63+
client.queue_latency
64+
end
65+
assert_raises Faktory::CommandError do
66+
client.queue_latency "*"
67+
end
68+
end
5469
end

0 commit comments

Comments
 (0)