fix: fix for missing republishing step after manual close

telekom · Dec 19, 2024 · 770e620 · 770e620
1 parent fa3e3c6
commit 770e620
Showing 1 changed file with 2 additions and 1 deletion.
diff --git a/internal/republish/republish.go b/internal/republish/republish.go
@@ -128,11 +128,12 @@ func RepublishPendingEvents(subscription *resource.SubscriptionResource, republi
 	throttler = createThrottler(subscription.Spec.Subscription.RedeliveriesPerSecond, string(subscription.Spec.Subscription.DeliveryType))
 	defer throttler.Release(context.Background())
 
+	cache.SetCancelStatus(subscriptionId, false)
+
 	var lastCursor any
 	for {
 		if cache.GetCancelStatus(subscriptionId) {
 			log.Info().Msgf("Republishing for subscription %s has been cancelled", subscriptionId)
-			cache.SetCancelStatus(subscriptionId, false)
 
 			return nil
 		}