diff --git a/lib/deimos/active_record_consume/batch_consumption.rb b/lib/deimos/active_record_consume/batch_consumption.rb
index 2016b8b..b2d9341 100644
--- a/lib/deimos/active_record_consume/batch_consumption.rb
+++ b/lib/deimos/active_record_consume/batch_consumption.rb
@@ -179,9 +179,9 @@ def filter_records(record_list)
         record_list.filter!(self.method(:should_consume?).to_proc, consume_filter)
       end
 
-      # @return [NilClass,ActiveRecord::Relation,Hash,Set]
+      # @return [ActiveRecord::Relation,Hash,Set]
       def consume_filter
-        nil
+        { }
       end
 
       # @param messages [Array<Deimos::Message>]
@@ -210,10 +210,10 @@ def build_records(messages)
       end
 
       # Additional processing after records have been successfully upserted
-      # @param _valid_records [Array<ActiveRecord>] Records to be post processed
-      # @param _invalid_records [Array<BatchRecord>] Invalid records to be processed
+      # @param _valid_active_records [Array<ActiveRecord>] Records to be post processed
+      # @param _invalid_batch_records [Array<BatchRecord>] Invalid records to be processed
       # @return [void]
-      def post_process(_valid_records, _invalid_records)
+      def post_process(_valid_active_records, _invalid_batch_records)
         nil
       end