Michael McGuinness
f11f4def43
Clean Set Up * fail * starteddb * constraint * cleantest * fixqueries * fixtests * storemimetype * buffer * tests * setup * passingtests * pdfHElloWorld * rm * test * notodos * tests * clean * testpdf
29 lines
610 B
Go
29 lines
610 B
Go
package queue
|
|
|
|
import (
|
|
"context"
|
|
"log/slog"
|
|
|
|
"github.com/aws/aws-sdk-go-v2/aws"
|
|
"github.com/aws/aws-sdk-go-v2/service/sqs"
|
|
)
|
|
|
|
type DeleteParams struct {
|
|
QueueURL string
|
|
ReceiptHandle *string
|
|
}
|
|
|
|
func (c *QueueConfig) DeleteFromQueue(ctx context.Context, params *DeleteParams) error {
|
|
slog.Debug("deleting message from queue", "url", params.QueueURL, "receipt_handle", *params.ReceiptHandle)
|
|
|
|
_, err := c.QueueClient.DeleteMessage(ctx, &sqs.DeleteMessageInput{
|
|
QueueUrl: aws.String(params.QueueURL),
|
|
ReceiptHandle: params.ReceiptHandle,
|
|
})
|
|
if err != nil {
|
|
return err
|
|
}
|
|
|
|
return nil
|
|
}
|