lib/quebert/backend/beanstalk.rb in quebert-0.0.4 vs lib/quebert/backend/beanstalk.rb in quebert-0.0.6

@@ -3,27 +3,27 @@
 module Quebert
   module Backend
     
     # Manage jobs on a Beanstalk queue out of process
     class Beanstalk < Beanstalk::Pool
-      def put(job, *args)
-        super Job.to_json(job, *args)
+      def put(job)
+        super job.to_json
       end
       
-      def reserve_with_consumer
-        Consumer::Beanstalk.new(reserve_without_consumer, self)
+      def reserve_with_controller
+        Controller::Beanstalk.new(reserve_without_controller, self)
       end
-      alias :reserve_without_consumer :reserve
-      alias :reserve :reserve_with_consumer
+      alias :reserve_without_controller :reserve
+      alias :reserve :reserve_with_controller
       
       # For testing purposes... I think there's a better way to do this though.
       def drain!
         while peek_ready do
-          reserve_without_consumer.delete
+          reserve_without_controller.delete
         end
         while job = peek_buried do
           last_conn.kick 1 # what? Why the 1? it kicks them all?
-          reserve_without_consumer.delete
+          reserve_without_controller.delete
         end
       end
       
       def self.configure(opts={})
         opts[:host] ||= '127.0.0.1:11300'
\ No newline at end of file