profiling_worker.rb in sneakers-1.1.0

- old
+ new

@@ -31,11 +31,12 @@
              :ack => true,
              :threads => 50,
              :prefetch => 50,
              :timeout_job_after => 1,
              :exchange => 'sneakers',
-             :heartbeat => 5
+             :heartbeat => 5,
+             :amqp_heartbeat => 10
   def work(msg)
     ack!
   end
 end
 
@@ -64,6 +65,5 @@
     exit(0)
   end
 end
 
 r.run
-