Added unit test to ensure that we can provide our own jid.

seomoz · May 15, 2012 · 9ced46d · 9ced46d
1 parent 31d4a35
commit 9ced46d
Show file tree

Hide file tree

Showing 2 changed files with 9 additions and 2 deletions.
diff --git a/lib/qless/queue.rb b/lib/qless/queue.rb
@@ -64,7 +64,7 @@ def heartbeat=(value)
     # => delay (int)
     def put(klass, data, opts={})
       @client._put.call([@name], [
-        Qless.generate_jid,
+        (opts[:jid] or Qless.generate_jid),
         klass.to_s,
         JSON.generate(data),
         Time.now.to_f,
@@ -86,7 +86,7 @@ def recur(klass, data, interval, opts={})
       @client._recur.call([], [
         'on',
         @name,
-        Qless.generate_jid,
+        (opts[:jid] or Qless.generate_jid),
         klass.to_s,
         JSON.generate(data),
         Time.now.to_f,

diff --git a/spec/unit/queue_spec.rb b/spec/unit/queue_spec.rb
@@ -19,6 +19,13 @@ module Qless
         string.should include("queue-name")
       end
     end
+
+    it "can specify a jid in put and recur" do
+      client.queues['foo'].put(  Qless::Job, {'foo' => 'bar'},    :jid => 'howdy').should eq('howdy')
+      client.queues['foo'].recur(Qless::Job, {'foo' => 'bar'}, 5, :jid => 'hello').should eq('hello')
+      client.jobs['howdy'].should be
+      client.jobs['hello'].should be
+    end
   end
 end