aboutsummaryrefslogtreecommitdiff
diff options
context:
space:
mode:
authorMichael Pu <michael.pu@uwaterloo.ca>2024-01-31 12:09:05 -0500
committerCecylia Bocovich <cohosh@torproject.org>2024-01-31 12:50:50 -0500
commitb8df42a377ca61390494155e99672434fc72083c (patch)
treec223c985412d65b8576c0edf374298cbb7dc6e76
parent9b90b77d696a241bf4a363deee633b59a1680f85 (diff)
downloadsnowflake-b8df42a377ca61390494155e99672434fc72083c.tar.gz
snowflake-b8df42a377ca61390494155e99672434fc72083c.zip
Fix nil ptr deference when listing client queues
Signed-off-by: Cecylia Bocovich <cohosh@torproject.org>
-rw-r--r--broker/sqs.go2
1 files changed, 2 insertions, 0 deletions
diff --git a/broker/sqs.go b/broker/sqs.go
index 057a923..47b97c2 100644
--- a/broker/sqs.go
+++ b/broker/sqs.go
@@ -71,6 +71,8 @@ func (r *sqsHandler) cleanupClientQueues(ctx context.Context) {
})
if err != nil {
log.Printf("SQSHandler: encountered error while retrieving client queues to clean up: %v\n", err)
+ // client queues will be cleaned up the next time the cleanup operation is triggered automatically
+ break
}
queueURLsList = append(queueURLsList, res.QueueUrls...)
if res.NextToken == nil {