lib/woodhouse/extensions/progress.rb in woodhouse-0.1.5 vs lib/woodhouse/extensions/progress.rb in woodhouse-1.0.0

@@ -62,11 +62,11 @@
       
       bunny.start
       begin
         channel = bunny.create_channel
         exchange = channel.direct("woodhouse.progress")
-        queue = channel.queue(job_id, :durable => true)
+        queue = channel.queue(job_id, :arguments => {"x-expires" => 5*60*1000})
         queue.bind(exchange, :routing_key => job_id)
         payload = nil
         queue.message_count.times do
           _, _, next_payload = queue.pop
           payload = next_payload if next_payload
@@ -141,10 +141,10 @@
     end
 
     def update_progress(data)
       job = self
       sink = progress_sink
-      Celluloid::InternalPool.get { sink.update_job(job, data) }
+      Celluloid.internal_pool.get { sink.update_job(job, data) }
       nil
     end
 
     def progress_sink
       @progress_sink ||= Woodhouse