File tree Expand file tree Collapse file tree
aws-lambda-java-tests/src
main/java/com/amazonaws/services/lambda/runtime/tests
java/com/amazonaws/services/lambda/runtime/tests Expand file tree Collapse file tree Original file line number Diff line number Diff line change 1212 * Load events from json files and serialize them in Events
1313 */
1414public class EventLoader {
15+
16+ public static ActiveMQEvent loadActiveMQEvent (String filename ) {
17+ return loadEvent (filename , ActiveMQEvent .class );
18+ }
19+
1520 public static APIGatewayV2HTTPEvent loadApiGatewayHttpEvent (String filename ) {
1621 return loadEvent (filename , APIGatewayV2HTTPEvent .class );
1722 }
Original file line number Diff line number Diff line change @@ -191,6 +191,16 @@ public void testLoadKinesisEvent() {
191191 assertThat (new String (record .getData ().array ())).isEqualTo ("Hello, this is a test 123." );
192192 }
193193
194+ @ Test
195+ public void testLoadActiveMQEvent () {
196+ ActiveMQEvent event = EventLoader .loadActiveMQEvent ("mq_event.json" );
197+ assertThat (event ).isNotNull ();
198+ assertThat (event .getMessages ()).hasSize (2 );
199+
200+ assertThat (event .getMessages ().get (0 ).getMessageID ()).isEqualTo ("ID:b-9bcfa592-423a-4942-879d-eb284b418fc8-1.mq.us-west-2.amazonaws.com-37557-1234520418293-4:1:1:1:1" );
201+ 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" );
202+ }
203+
194204 @ Test
195205 public void testLoadCodeCommitEvent () {
196206 CodeCommitEvent event = EventLoader .loadCodeCommitEvent ("codecommit_event.json" );
Original file line number Diff line number Diff line change 1+ {
2+ "eventSource" : " aws:amq" ,
3+ "eventSourceArn" : " arn:aws:mq:us-west-2:112556298976:broker:test:b-9bcfa592-423a-4942-879d-eb284b418fc8" ,
4+ "messages" : [
5+ {
6+ "messageID" : " ID:b-9bcfa592-423a-4942-879d-eb284b418fc8-1.mq.us-west-2.amazonaws.com-37557-1234520418293-4:1:1:1:1" ,
7+ "messageType" : " jms/text-message" ,
8+ "data" : " QUJDOkFBQUE=" ,
9+ "connectionId" : " myJMSCoID" ,
10+ "redelivered" : false ,
11+ "destination" : {
12+ "physicalname" : " testQueue"
13+ },
14+ "timestamp" : 1598827811958 ,
15+ "brokerInTime" : 1598827811958 ,
16+ "brokerOutTime" : 1598827811959
17+ },
18+ {
19+ "messageID" : " ID:b-8bcfa572-428a-4642-879d-eb284b418fc8-1.mq.us-west-2.amazonaws.com-37557-1234520418293-4:1:1:1:1" ,
20+ "messageType" : " jms/bytes-message" ,
21+ "data" : " 3DTOOW7crj51prgVLQaGQ82S48k=" ,
22+ "connectionId" : " myJMSCoID1" ,
23+ "persistent" : false ,
24+ "destination" : {
25+ "physicalname" : " testQueue"
26+ },
27+ "timestamp" : 1598827811958 ,
28+ "brokerInTime" : 1598827811958 ,
29+ "brokerOutTime" : 1598827811959
30+ }
31+ ]
32+ }
You can’t perform that action at this time.
0 commit comments