Recreate subscription if failing to read events

open-telemetry · Sep 13, 2024 · f809b1a · f809b1a
1 parent da20290
commit f809b1a
Showing 1 changed file with 6 additions and 2 deletions.
diff --git a/pkg/stanza/operator/input/windows/input.go b/pkg/stanza/operator/input/windows/input.go
@@ -216,9 +216,13 @@ func (i *Input) read(ctx context.Context) int {
 	events, err := i.subscription.Read(i.maxReads)
 	if err != nil {
 		i.Logger().Error("Failed to read events from subscription", zap.Error(err))
-		i.subscription.Close()
+		closeErr := i.subscription.Close()
+		if closeErr != nil {
+			i.Logger().Error("Failed to close subscription", zap.Error(closeErr))
+			return 0
+		}
+		i.Logger().Info("Recreating subscription")
 		i.subscription = NewRemoteSubscription(i.remote.Server)
-		i.Logger().Info("Reopening subscription")
 		return 0
 	}