From fe01a04c16aa01fbb4abf6fff65deec57990b443 Mon Sep 17 00:00:00 2001 From: Julie Vogelman Date: Wed, 2 Feb 2022 09:40:20 -0800 Subject: [PATCH] clarify comment Signed-off-by: Julie Vogelman --- eventbus/driver/nats.go | 4 +--- 1 file changed, 1 insertion(+), 3 deletions(-) diff --git a/eventbus/driver/nats.go b/eventbus/driver/nats.go index bd936f2965..664a37bed4 100644 --- a/eventbus/driver/nats.go +++ b/eventbus/driver/nats.go @@ -258,9 +258,7 @@ func (n *natsStreaming) processEventSourceMsg(m *stan.Msg, msgHolder *eventSourc return } - // Clean up old messages before starting a new round - - // ACK all the old messages after conditions are met + // Acknowledge any old messages that occurred either before the last reset if m.Timestamp/1e9 <= msgHolder.getLastResetTime() { log.Debugf("About to reset and ack dependency=%s due to message time occurred before reset, m.Timestamp=%d, msgHolder.getLastResetTime()=%d", depName, m.Timestamp, msgHolder.getLastResetTime())