diff --git a/lib/deimos/active_record_consume/batch_consumption.rb b/lib/deimos/active_record_consume/batch_consumption.rb
index e4365a7c..ffea9c81 100644
--- a/lib/deimos/active_record_consume/batch_consumption.rb
+++ b/lib/deimos/active_record_consume/batch_consumption.rb
@@ -123,7 +123,7 @@ def uncompacted_update(messages)
         invalid_records = []
         BatchSlicer.
           slice(messages).each do |slice|
-          valid, invalid = self.update_database(slice)
+          valid, invalid = update_database(slice)
           valid_records.push(*valid) if valid.any?
           invalid_records.push(*invalid) if invalid.any?
           end