diff options
| author | chrislu <chris.lu@gmail.com> | 2023-09-25 08:20:16 -0700 |
|---|---|---|
| committer | chrislu <chris.lu@gmail.com> | 2023-09-25 08:20:16 -0700 |
| commit | c9177c92e5b6459d15d112738b7a3862655a853f (patch) | |
| tree | 7acec7c8405ebdbb60f5a0ba194bcca3321ba20d /weed | |
| parent | 81e57bd45eaf9cda4682dc765202342ed92d07ab (diff) | |
| parent | 7bb58e23ea03846b06b540f9570c48dc41b5f2c2 (diff) | |
| download | seaweedfs-c9177c92e5b6459d15d112738b7a3862655a853f.tar.xz seaweedfs-c9177c92e5b6459d15d112738b7a3862655a853f.zip | |
Merge branch 'master' of https://github.com/seaweedfs/seaweedfs
Diffstat (limited to 'weed')
| -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, |