added tyrewt / SQS IN / KINESIS IN / Test for invoke Lambda

rtchandler_fix
Bernd Brandl 2022-06-14 11:40:04 +02:00
parent 5417ff280a
commit 83c32035ce
3 changed files with 64 additions and 5 deletions

View File

@ -1,9 +1,32 @@
config: config:
- customService1: template-1-1.json - customService1: template-1-1.json
- customService2: template-1-1.json
- customService3: template-2-1.json
customService1: customService1:
- name: myJOYNRService - name: "ts-tyrewt: ifs-001 (Kinesis) TyreWtIncoming - IN"
- className: com.bmw.cc.conn.this.is.just.an.exampleClasss - className: com.bmw.cc.tstyrewt.api.vehicleshadow.v1.boundary.VehicleShadowRecordProcessorBF
- methodName: exampleJoynrMethod - methodName: processRecords
- methodArgs: software.amazon.kinesis.lifecycle.events.ProcessRecordsInput
- returnType: void - returnType: void
- skipDeployment: "true" - skipDeployment: "false"
customService2:
- name: "ifs-003 (SQS) TyrewtLambdaIn - IN"
- className: com.bmw.cc.tstyrewt.api.lambda.v1.boundary.LambdaQueueListenerMDB
- methodName: listen
- methodArgs: java.lang.String,java.util.Map,org.springframework.cloud.aws.messaging.listener.Acknowledgment
- returnType: void
- skipDeployment: "false"
customService3:
- name: "ifs-002 (SQS) TyrewtMessageBuffer - IN/OUT"
- className1: com.bmw.cc.tstyrewt.api.buffer.v1.boundary.MessageBufferQueueListenerMDB
- methodName1: listen
- methodArgs1: java.lang.String,java.util.Map,org.springframework.cloud.aws.messaging.listener.Acknowledgment
- returnType1: void
- className2: com.bmw.cc.tstyrewt.integration.buffer.boundary.MessageBufferQueueESI
- methodName2: sendMessageToBufferQueue
- methodArgs2: java.lang.String,com.bmw.cc.tstyrewt.integration.buffer.entity.MessageType
- returnType2: void
- skipDeployment: "false"

View File

@ -13,7 +13,7 @@
"matcher": "EQUALS", "matcher": "EQUALS",
"methodRules": [ "methodRules": [
{ {
"argumentTypes": [], "argumentTypes": ["{{.methodArgs}}"],
"methodName": "{{.methodName}}", "methodName": "{{.methodName}}",
"returnType": "{{.returnType}}" "returnType": "{{.returnType}}"
} }

View File

@ -0,0 +1,36 @@
{
"enabled": true,
"name": "{{.name}}",
"processGroups": [],
"queueEntryPoint": false,
"queueEntryPointType": null,
"rules": [
{
"annotations": [],
"className": "{{.className1}}",
"enabled": true,
"fileName": "",
"matcher": "EQUALS",
"methodRules": [
{
"argumentTypes": ["{{.methodArgs1}}"],
"methodName": "{{.methodName1}}",
"returnType": "{{.returnType1}}"
}]
},
{
"annotations": [],
"className": "{{.className2}}",
"enabled": true,
"fileName": "",
"matcher": "EQUALS",
"methodRules": [
{
"argumentTypes": ["{{.methodArgs2}}"],
"methodName": "{{.methodName2}}",
"returnType": "{{.returnType2}}"
}
]
}
]
}