lib/roqua/scheduling/scheduler.rb in roqua-support-0.3.5 vs lib/roqua/scheduling/scheduler.rb in roqua-support-0.4.0

@@ -27,10 +27,13 @@
   def schedule
     Roqua::Scheduling::Schedule.current_schedule
   end
 
   def advisory_lock_name
-    "#{ActiveRecord::Base.connection_config[:database]}_cron_lock"
+    db_name = ActiveRecord::Base.respond_to?(:connection_db_config) \
+              ? ActiveRecord::Base.connection_db_config.database
+              : ActiveRecord::Base.connection_config[:database]
+    "#{db_name}_cron_lock"
   end
 
   private
 
   def with_advisory_lock