APIGOV-31178 - do not stop request queue within request queue (#974)

jcollins-axway · web-flow · commit 28cbc8d18e6a · 2025-09-23T09:26:33.000-07:00
diff --git a/pkg/agent/events/requestqueue.go b/pkg/agent/events/requestqueue.go
@@ -52,10 +52,8 @@ func (q *requestQueue) Stop() {
 	}
 
 	defer q.isActive.Store(false)
-	if q.cancel != nil {
-		q.cancel()
-		close(q.receiveCh)
-	}
+	q.cancel()
+	close(q.receiveCh)
 }
 
 func (q *requestQueue) IsActive() bool {
@@ -79,7 +77,6 @@ func (q *requestQueue) Start() {
 
 		for {
 			if q.process() {
-				q.Stop()
 				break
 			}
 		}

Original file line number	Diff line number	Diff line change
`@@ -52,10 +52,8 @@ func (q *requestQueue) Stop() {`
`52`	`52`	`}`
`53`	`53`
`54`	`54`	`defer q.isActive.Store(false)`
`55`		`- if q.cancel != nil {`
`56`		`- q.cancel()`
`57`		`- close(q.receiveCh)`
`58`		`- }`
	`55`	`+ q.cancel()`
	`56`	`+ close(q.receiveCh)`
`59`	`57`	`}`
`60`	`58`
`61`	`59`	`func (q *requestQueue) IsActive() bool {`
`@@ -79,7 +77,6 @@ func (q *requestQueue) Start() {`
`79`	`77`
`80`	`78`	`for {`
`81`	`79`	`if q.process() {`
`82`		`- q.Stop()`
`83`	`80`	`break`
`84`	`81`	`}`
`85`	`82`	`}`