lib/phobos/actions/process_batch.rb in phobos-1.8.2 vs lib/phobos/actions/process_batch.rb in phobos-1.8.3.pre.beta1

@@ -24,9 +24,10 @@
             Phobos::Actions::ProcessMessage.new(
               listener: @listener,
               message: message,
               listener_metadata: @listener_metadata
             ).execute
+            @listener.consumer.trigger_heartbeat
           end
         end
       end
     end
   end