Skip to content

Commit 617ec8a

Browse files
committed
Use event serialization helpers
1 parent 418152c commit 617ec8a

File tree

3 files changed

+11
-5
lines changed

3 files changed

+11
-5
lines changed

powertools-sqs/pom.xml

Lines changed: 4 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -45,6 +45,10 @@
4545
<groupId>software.amazon.lambda</groupId>
4646
<artifactId>powertools-core</artifactId>
4747
</dependency>
48+
<dependency>
49+
<groupId>com.amazonaws</groupId>
50+
<artifactId>aws-lambda-java-tests</artifactId>
51+
</dependency>
4852
<dependency>
4953
<groupId>com.amazonaws</groupId>
5054
<artifactId>aws-lambda-java-core</artifactId>

powertools-sqs/src/test/java/software/amazon/lambda/powertools/sqs/SqsUtilsFifoBatchProcessorTest.java

Lines changed: 3 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -1,6 +1,7 @@
11
package software.amazon.lambda.powertools.sqs;
22

33
import com.amazonaws.services.lambda.runtime.events.SQSEvent;
4+
import com.amazonaws.services.lambda.runtime.tests.EventLoader;
45
import com.fasterxml.jackson.databind.ObjectMapper;
56
import org.junit.jupiter.api.AfterEach;
67
import org.junit.jupiter.api.BeforeEach;
@@ -37,7 +38,8 @@ public class SqsUtilsFifoBatchProcessorTest {
3738
private ArgumentCaptor<DeleteMessageBatchRequest> deleteMessageBatchCaptor;
3839

3940
public SqsUtilsFifoBatchProcessorTest() throws IOException {
40-
sqsBatchEvent = MAPPER.readValue(SqsUtilsFifoBatchProcessorTest.class.getResource("/SqsFifoBatchEvent.json"), SQSEvent.class);
41+
//sqsBatchEvent = MAPPER.readValue(SqsUtilsFifoBatchProcessorTest.class.getResource("/SqsFifoBatchEvent.json"), SQSEvent.class);
42+
sqsBatchEvent = EventLoader.loadSQSEvent("SqsFifoBatchEvent.json");
4143
}
4244

4345
@BeforeEach

powertools-sqs/src/test/resources/SqsFifoBatchEvent.json

Lines changed: 4 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -1,5 +1,5 @@
11
{
2-
"records": [
2+
"Records": [
33
{
44
"messageId": "059f36b4-87a3-44ab-83d2-661975830a7d",
55
"receiptHandle": "AQEBwJnKyrHigUMZj6rYigCgxlaS3SLy0a...",
@@ -14,7 +14,7 @@
1414
"messageAttributes": {},
1515
"md5OfBody": "e4e68fb7bd0e697a0ae8f1bb342846b3",
1616
"eventSource": "aws:sqs",
17-
"eventSourceArn": "arn:aws:sqs:us-east-1:906126917321:sqs-lambda-MySqsQueue-4DYWWJIE97N5",
17+
"eventSourceARN": "arn:aws:sqs:us-east-1:906126917321:sqs-lambda-MySqsQueue-4DYWWJIE97N5",
1818
"awsRegion": "us-east-2"
1919
},
2020
{
@@ -44,7 +44,7 @@
4444
},
4545
"md5OfBody": "e4e68fb7bd0e697a0ae8f1bb342846b3",
4646
"eventSource": "aws:sqs",
47-
"eventSourceArn": "arn:aws:sqs:us-east-1:906126917321:sqs-lambda-MySqsQueue-4DYWWJIE97N5",
47+
"eventSourceARN": "arn:aws:sqs:us-east-1:906126917321:sqs-lambda-MySqsQueue-4DYWWJIE97N5",
4848
"awsRegion": "us-east-2"
4949
},
5050
{
@@ -66,7 +66,7 @@
6666
},
6767
"md5OfBody": "e4e68fb7bd0e697a0ae8f1bb342846b3",
6868
"eventSource": "aws:sqs",
69-
"eventSourceArn": "arn:aws:sqs:us-east-1:906126917321:sqs-lambda-MySqsQueue-4DYWWJIE97N5",
69+
"eventSourceARN": "arn:aws:sqs:us-east-1:906126917321:sqs-lambda-MySqsQueue-4DYWWJIE97N5",
7070
"awsRegion": "us-east-2"
7171
}
7272
]

0 commit comments

Comments
 (0)