Make the lag monitor send along the class for which the lag is being …

…reported to statistics methods

lib/multi_db/lag_monitor.rb

@@ -24,7 +24,7 @@ def self.replication_lag_too_high?(connection)
 
     def self.slave_lag(klass)
       cache_fetch("slave_lag:#{klass.name}") {
-        actual_slave_lag(klass.retrieve_connection)
+        actual_slave_lag(klass)
       }
     end
 
@@ -42,12 +42,13 @@ def self.report_lag_statistic(lag)
       # hook method
     end
 
-    def self.actual_slave_lag(connection)
+    def self.actual_slave_lag(connection_class)
+      connection = connection_class.retrieve_connection
       result = connection.execute("SHOW SLAVE STATUS")
       index = result.fields.index("Seconds_Behind_Master")
       lag = result.first.try(:[], index).to_i
 
-      report_lag_statistic(lag)
+      report_lag_statistic(connection_class.name, lag)
 
       lag
     end