Merge pull request #40 from pipefy/ms-main/feature/flush-log

🔊 Force flushing logs after processing a message
pipefy · Aug 23, 2022 · d7a7d3a · d7a7d3a
2 parents be54b8e + 4520479
commit d7a7d3a
Showing 1 changed file with 1 addition and 0 deletions.
diff --git a/lib/pipefy_message/consumer.rb b/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