Skip to content

Commit 6ad3f70

Browse files
authored
Integrates custom properties into ActiveMQ event (#408)
1 parent cd30dc5 commit 6ad3f70

File tree

3 files changed

+19
-2
lines changed

3 files changed

+19
-2
lines changed

aws-lambda-java-events/src/main/java/com/amazonaws/services/lambda/runtime/events/ActiveMQEvent.java

+2
Original file line numberDiff line numberDiff line change
@@ -18,6 +18,7 @@
1818
import lombok.EqualsAndHashCode;
1919
import lombok.NoArgsConstructor;
2020
import java.util.List;
21+
import java.util.Map;
2122

2223
/**
2324
* Represents an Active MQ event sent to Lambda
@@ -52,6 +53,7 @@ public static class ActiveMQMessage {
5253
private String data;
5354
private long brokerInTime;
5455
private long brokerOutTime;
56+
private Map<String, String> properties;
5557
}
5658

5759
@Data

aws-lambda-java-tests/src/test/java/com/amazonaws/services/lambda/runtime/tests/EventLoaderTest.java

+9
Original file line numberDiff line numberDiff line change
@@ -205,6 +205,15 @@ public void testLoadActiveMQEvent() {
205205
assertThat(event.getMessages().get(1).getMessageID()).isEqualTo("ID:b-8bcfa572-428a-4642-879d-eb284b418fc8-1.mq.us-west-2.amazonaws.com-37557-1234520418293-4:1:1:1:1");
206206
}
207207

208+
@Test
209+
public void testLoadActiveMQEventWithProperties() {
210+
ActiveMQEvent event = EventLoader.loadActiveMQEvent("mq_event.json");
211+
assertThat(event).isNotNull();
212+
assertThat(event.getMessages()).hasSize(2);
213+
assertThat(event.getMessages().get(0).getProperties().get("testKey")).isEqualTo("testValue");
214+
assertThat(event.getMessages().get(1).getProperties().get("testKey")).isEqualTo("testValue");
215+
}
216+
208217
@Test
209218
public void testLoadCodeCommitEvent() {
210219
CodeCommitEvent event = EventLoader.loadCodeCommitEvent("codecommit_event.json");

aws-lambda-java-tests/src/test/resources/mq_event.json

+8-2
Original file line numberDiff line numberDiff line change
@@ -13,7 +13,10 @@
1313
},
1414
"timestamp": 1598827811958,
1515
"brokerInTime": 1598827811958,
16-
"brokerOutTime": 1598827811959
16+
"brokerOutTime": 1598827811959,
17+
"properties": {
18+
"testKey": "testValue"
19+
}
1720
},
1821
{
1922
"messageID": "ID:b-8bcfa572-428a-4642-879d-eb284b418fc8-1.mq.us-west-2.amazonaws.com-37557-1234520418293-4:1:1:1:1",
@@ -26,7 +29,10 @@
2629
},
2730
"timestamp": 1598827811958,
2831
"brokerInTime": 1598827811958,
29-
"brokerOutTime": 1598827811959
32+
"brokerOutTime": 1598827811959,
33+
"properties": {
34+
"testKey": "testValue"
35+
}
3036
}
3137
]
3238
}

0 commit comments

Comments
 (0)