Merge pull request #41 from skisulli/add-unique-key-to-message

Add the unique hash to the message for use by the workers.
mhenrixon · Jun 8, 2014 · 15c2142 · 15c2142
2 parents b347577 + 22c358f
commit 15c2142
Show file tree

Hide file tree

Showing 2 changed files with 9 additions and 0 deletions.
diff --git a/lib/sidekiq-unique-jobs/middleware/client/unique_jobs.rb b/lib/sidekiq-unique-jobs/middleware/client/unique_jobs.rb
@@ -12,6 +12,7 @@ def call(worker_class, item, queue, redis_pool = nil)
           @item = item
 
           if unique_enabled?
+            @item['unique_hash'] = payload_hash
             yield if unique?
           else
             yield

diff --git a/spec/lib/sidekiq_testing_enabled_spec.rb b/spec/lib/sidekiq_testing_enabled_spec.rb
@@ -17,6 +17,14 @@
         UniqueWorker.perform_async(param)
         expect(UniqueWorker.jobs.size).to eq(1)
       end
+
+      it "adds the unique_hash to the message" do
+        param = 'hash'
+        hash = SidekiqUniqueJobs::PayloadHelper.get_payload(UniqueWorker, :working, [param])
+        UniqueWorker.perform_async(param)
+        expect(UniqueWorker.jobs.size).to eq(1)
+        expect(UniqueWorker.jobs.first['unique_hash']).to eq(hash)
+      end
     end
 
     context "with non-unique worker" do