9388: Reset sent_ids for consistency

diff --git a/services/api/lib/eventbus.rb b/services/api/lib/eventbus.rb
index eb7750ff2105019bff502031d933a2e699f042b9..b35da1b0a0e6fb84066e44d1a3d8ca5bde750fa8 100644 (file)
--- a/services/api/lib/eventbus.rb
+++ b/services/api/lib/eventbus.rb
@@ -188,6 +188,9 @@ class EventBus
           # Set or reset the last_log_id.  The event bus only reports events
           # for rows that come after last_log_id.
           ws.last_log_id = p[:last_log_id].to_i
+          # Reset sent_ids for consistency
+          # (always re-deliver all matching messages following last_log_id)
+          ws.sent_ids = Set.new
         end
 
         if ws.filters.length < MAX_FILTERS