mirror of
https://github.com/Luzifer/cloudkeys-go.git
synced 2024-11-15 01:12:44 +00:00
35 lines
780 B
Go
35 lines
780 B
Go
|
// +build integration
|
||
|
|
|
||
|
|
package sqs_test
|
||
|
|
|
||
|
|
import (
|
||
|
|
"testing"
|
||
|
|
|
||
|
|
"github.com/aws/aws-sdk-go/aws"
|
||
|
|
"github.com/aws/aws-sdk-go/awstesting/unit"
|
||
|
|
"github.com/aws/aws-sdk-go/service/sqs"
|
||
|
|
)
|
||
|
|
|
||
|
|
func TestFlattenedTraits(t *testing.T) {
|
||
|
|
s := sqs.New(unit.Session)
|
||
|
|
_, err := s.DeleteMessageBatch(&sqs.DeleteMessageBatchInput{
|
||
|
|
QueueURL: aws.String("QUEUE"),
|
||
|
|
Entries: []*sqs.DeleteMessageBatchRequestEntry{
|
||
|
|
{
|
||
|
|
ID: aws.String("TEST"),
|
||
|
|
ReceiptHandle: aws.String("RECEIPT"),
|
||
|
|
},
|
||
|
|
},
|
||
|
|
})
|
||
|
|
|
||
|
|
if err == nil {
|
||
|
|
t.Fatalf("expect error, got nil")
|
||
|
|
}
|
||
|
|
if e, a := "InvalidAddress", err.Code(); e != a {
|
||
|
|
t.Errorf("expect %v, got %v", e, a)
|
||
|
|
}
|
||
|
|
if e, a := "The address QUEUE is not valid for this endpoint.", err.Message(); e != a {
|
||
|
|
t.Errorf("expect %v, got %v", e, a)
|
||
|
|
}
|
||
|
|
}
|