lib/resque_bus/adapter.rb in resque-bus-0.5.10 vs lib/resque_bus/adapter.rb in resque-bus-0.5.11

@@ -26,10 +26,11 @@
       def setup_heartbeat!(queue_name)
         # turn on the heartbeat
         # should be down after loading scheduler yml if you do that
         # otherwise, anytime
         name     = 'resquebus_heartbeat'
-        schedule = { 'class' => '::QueueBus::Heartbeat',
+        schedule = { 'class' => '::QueueBus::Worker',
+                     'args'=>[::QueueBus::Util.encode({'bus_class_proxy' => '::QueueBus::Heartbeat'})],
                      'cron'  => '* * * * *',   # every minute
                      'queue' => queue_name,
                      'description' => 'I publish a heartbeat_minutes event every minute'
                    }
         if ::Resque::Scheduler.dynamic