diff options
| author | Lars Lehtonen <lars.lehtonen@gmail.com> | 2023-09-25 07:33:18 -0700 |
|---|---|---|
| committer | GitHub <noreply@github.com> | 2023-09-25 07:33:18 -0700 |
| commit | 28a3a31b2704e5dc86d1ac8a6d345fc4cefab354 (patch) | |
| tree | 2eebbd746361e49824cff294f05145d8ecfcc6ae | |
| parent | a40888d343a9b1f4ad0b96885f50ccf70e8f8496 (diff) | |
| download | seaweedfs-28a3a31b2704e5dc86d1ac8a6d345fc4cefab354.tar.xz seaweedfs-28a3a31b2704e5dc86d1ac8a6d345fc4cefab354.zip | |
weed/replication/sub: fix dropped error (#4865)
| -rw-r--r-- | weed/replication/sub/notification_aws_sqs.go | 5 |
1 files changed, 4 insertions, 1 deletions
diff --git a/weed/replication/sub/notification_aws_sqs.go b/weed/replication/sub/notification_aws_sqs.go index 0201d4f9c..7fc5c3f46 100644 --- a/weed/replication/sub/notification_aws_sqs.go +++ b/weed/replication/sub/notification_aws_sqs.go @@ -99,7 +99,10 @@ func (k *AwsSqsInput) ReceiveMessage() (key string, message *filer_pb.EventNotif text := *result.Messages[0].Body message = &filer_pb.EventNotification{} 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 _, err = k.svc.DeleteMessage(&sqs.DeleteMessageInput{ QueueUrl: &k.queueUrl, |