diff options
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, |