ensure messages are delivered before marked as seen

open-telemetry · Jul 28, 2022 · 66a0332 · 66a0332
1 parent 37f0694
commit 66a0332
Showing 1 changed file with 4 additions and 2 deletions.
diff --git a/instrumentation/racecar/test/opentelemetry/instrumentation/racecar/patches/runner_test.rb b/instrumentation/racecar/test/opentelemetry/instrumentation/racecar/patches/runner_test.rb
@@ -83,11 +83,12 @@ def self.messages_seen
           end
 
           def process(message)
-            TestConsumer.messages_seen << message
-            produce(
+            producea
               'message seen',
               topic: "ack-#{message.topic}"
             )
+            deliver!
+            TestConsumer.messages_seen << message
           end
         end
         TestConsumer.subscribes_to(topic_name)
@@ -229,6 +230,7 @@ def process_batch(messages)
               'message seen',
               topic: "ack-#{message.topic}"
             )
+            deliver!
             TestBatchConsumer.messages_seen << message
           end
         end