diff --git a/archie/removeObject.go b/archie/removeObject.go
index ad47f00..d162932 100644
--- 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()).