🔊 Force flushing logs after processing a message

lib/pipefy_message/consumer.rb

@@ -104,6 +104,7 @@ def process_message
                                     log_text: "Message received by consumer poller, processed " \
                                               "in #{elapsed_time_ms} milliseconds"
                                   }, context, correlation_id, event_id))
+          $stdout.flush # Ensure everything is flushed to log after processing a message
         end
       rescue StandardError => e
         context = "NO_CONTEXT_RETRIEVED" unless defined? context