Add purge command

kneu-messenger-pigeon · Oct 1, 2024 · 8727647 · 8727647
1 parent 35b5386
commit 8727647
Showing 1 changed file with 10 additions and 0 deletions.
diff --git a/RealtimeQueue.go b/RealtimeQueue.go
@@ -40,6 +40,16 @@ func CreateRealtimeQueue(t *testing.T) *RealtimeQueue {
 
 	client := sqs.NewFromConfig(awsCfg)
 
+	_, err = client.PurgeQueue(context.Background(), &sqs.PurgeQueueInput{
+		QueueUrl: &config.sqsQueueUrl,
+	})
+
+	if err != nil {
+		fmt.Printf("PurgeQueue failed: %s\n", err)
+	} else {
+		fmt.Printf("Purged success:\n")
+	}
+
 	return &RealtimeQueue{
 		client:      client,
 		sqsQueueUrl: &config.sqsQueueUrl,