hashes are enqueued by lib/resque.rb, so test that interface.

expose Queue#encode and Queue#decode so that we can hide the coder
interface.

Author: tenderlove

lib/resque/multi_queue.rb

@@ -48,7 +48,7 @@ def pop(non_block = false)
         synchronize do
           value = @redis.blpop(*(queue_names + [1])) until value
           queue_name, payload = value
-          @queues[queue_name].coder.decode(payload)
+          @queues[queue_name].decode(payload)
         end
       end
     end

lib/resque/queue.rb

@@ -9,7 +9,7 @@ module Resque
   class Queue
     include Mutex_m
 
-    attr_reader :name, :redis_name, :coder
+    attr_reader :name, :redis_name
 
     ###
     # Create a new Queue object with +name+ on +redis+ connection, and using
@@ -88,7 +88,6 @@ def destroy
       @redis.srem(:queues, @name)
     end
 
-    private
     def encode object
       @coder.dump object
     end

test/multi_queue_test.rb

@@ -14,19 +14,19 @@
     queue = Resque::MultiQueue.new([foo, bar], redis)
     t     = Thread.new { queue.pop }
 
-    job = Resque::Job.new(:bar, :class => 'GoodJob')
+    job = { 'class' => 'GoodJob', 'args' => [35, 'tar'] }
     bar << job
-    assert_equal coder.decode(job.to_json), t.join.value
+    assert_equal job, t.join.value
   end
 
   it "nonblocking pop works" do
     foo   = Resque::Queue.new 'foo', redis, coder
     bar   = Resque::Queue.new 'bar', redis, coder
     queue = Resque::MultiQueue.new([foo, bar], redis)
 
-    job = Resque::Job.new(:bar, :class => 'GoodJob')
+    job = { 'class' => 'GoodJob', 'args' => [35, 'tar'] }
     bar << job
-    assert_equal coder.decode(job.to_json), queue.pop(true)
+    assert_equal job, queue.pop(true)
   end
 
   it "blocks forever on pop" do