updating lifecycle expired field

Minehut · Sep 12, 2024 · 572ae16 · 572ae16
1 parent 61c0e08
commit 572ae16
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/archie/removeObject.go b/archie/removeObject.go
@@ -11,7 +11,7 @@ import (
 func (a *Archiver) removeObject(ctx context.Context, mLog zerolog.Logger, eventObjKey string, msg *nats.Msg, record event.Record) (error, string, AckType) {
 	metadata, _ := msg.Metadata()
 
-	if a.SkipLifecycleExpired && record.Source.Host == "Internal: [ILM-EXPIRY]" {
+	if a.SkipLifecycleExpired && (record.Source.Host == "Internal: [ILM-EXPIRY]" || record.Source.UserAgent == "Internal: [ILM-EXPIRY]") {
 		mLog.Info().
 			Uint64("numDelivered", metadata.NumDelivered).
 			Str("queueDuration", time.Now().Sub(metadata.Timestamp).String()).