lsm/seaweedfs
1
0
Fork 0
mirror of https://github.com/seaweedfs/seaweedfs.git synced 2025-09-23 00:43:32 +08:00
Code Issues Actions Packages Projects Releases Wiki Activity

weed/replication/sub: fix dropped error (#4865)

Browse Source
This commit is contained in:
Lars Lehtonen
2023-09-25 07:33:18 -07:00
committed by GitHub
parent a40888d343
commit 28a3a31b27
1 changed files with 4 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files

5
weed/replication/sub/notification_aws_sqs.go
View File

@@ -99,7 +99,10 @@ func (k *AwsSqsInput) ReceiveMessage() (key string, message *filer_pb.EventNotif
text := *result.Messages[0].Body text := *result.Messages[0].Body
message = &filer_pb.EventNotification{} message = &filer_pb.EventNotification{}
err = proto.Unmarshal([]byte(text), message) err = proto.Unmarshal([]byte(text), message)
if err != nil {
err = fmt.Errorf("unmarshal message from sqs %s: %w", k.queueUrl, err)
return
}
// delete the message // delete the message
_, err = k.svc.DeleteMessage(&sqs.DeleteMessageInput{ _, err = k.svc.DeleteMessage(&sqs.DeleteMessageInput{
QueueUrl: &k.queueUrl, QueueUrl: &k.queueUrl,