plugins/jobs/broker/sqs/job_test.go


1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19

package sqs

import (
	"github.com/aws/aws-sdk-go/aws"
	"github.com/aws/aws-sdk-go/service/sqs"
	"github.com/stretchr/testify/assert"
	"testing"
)

func Test_Unpack(t *testing.T) {
	msg := &sqs.Message{
		Body:              aws.String("body"),
		Attributes:        map[string]*string{},
		MessageAttributes: map[string]*sqs.MessageAttributeValue{},
	}

	_, _, _, err := unpack(msg)
	assert.Error(t, err)
}