Add request processor

config-layers/test/in/erail/route/OpenAPI3RouteBuilder.properties

@@ -2,5 +2,7 @@
 securityEnable=false
 services+=\
     /in/erail/service/BroadcastService,\
-    /in/erail/service/BinaryBodyService
+    /in/erail/service/BinaryBodyService,\
+    /in/erail/service/ProcessorCheckService
+
 

config-layers/test/in/erail/route/openapi3.json

@@ -11,14 +11,26 @@
         "summary": "Send message to all subscriber of topicName",
         "description": "Send message to all subscriber of topicName",
         "operationId": "API_V1_BROADCAST_SERVICE",
-        "parameters": [{
-          "name": "topicName",
-          "in": "path",
-          "required": true,
-          "schema": {
-            "type": "string"
+        "parameters": [
+          {
+            "name": "topicName",
+            "in": "path",
+            "required": true,
+            "schema": {
+              "type": "string"
+            }
           }
-        }],
+        ],
+        "requestBody": {
+          "content": {
+            "application/json": {
+              "schema": {
+                "$ref": "#/components/schemas/broadcastMessage"
+              }
+            }
+          },
+          "required": true
+        },
         "responses": {
           "200": {
             "description": "Success Response",
@@ -30,41 +42,45 @@
               }
             }
           }
-        },
-        "requestBody": {
-          "content": {
-            "application/json": {
-              "schema": {
-                "$ref": "#/components/schemas/broadcastMessage"
-              }
-            }
-          },
-          "required": true
         }
       },
-      "parameters": [{
-        "name": "topicName",
-        "in": "path",
-        "description": "Name of topic on which to broadcast message",
-        "required": true,
-        "schema": {
-          "type": "string"
+      "parameters": [
+        {
+          "name": "topicName",
+          "in": "path",
+          "description": "Name of topic on which to broadcast message",
+          "required": true,
+          "schema": {
+            "type": "string"
+          }
         }
-      }]
+      ]
     },
     "/broadcastv2/{topicName}": {
       "post": {
         "summary": "Send message to all subscriber of topicName",
         "description": "Send message to all subscriber of topicName",
         "operationId": "API_V1_BROADCAST_V2_SERVICE",
-        "parameters": [{
-          "name": "topicName",
-          "in": "path",
-          "required": true,
-          "schema": {
-            "type": "string"
+        "parameters": [
+          {
+            "name": "topicName",
+            "in": "path",
+            "required": true,
+            "schema": {
+              "type": "string"
+            }
           }
-        }],
+        ],
+        "requestBody": {
+          "content": {
+            "application/json": {
+              "schema": {
+                "$ref": "#/components/schemas/broadcastMessage"
+              }
+            }
+          },
+          "required": true
+        },
         "responses": {
           "200": {
             "description": "Success Response",
@@ -76,27 +92,30 @@
               }
             }
           }
-        },
-        "requestBody": {
-          "content": {
-            "application/json": {
-              "schema": {
-                "$ref": "#/components/schemas/broadcastMessage"
-              }
-            }
-          },
-          "required": true
         }
       },
-      "parameters": [{
-        "name": "topicName",
-        "in": "path",
-        "description": "Name of topic on which to broadcast message",
-        "required": true,
-        "schema": {
-          "type": "string"
+      "parameters": [
+        {
+          "name": "topicName",
+          "in": "path",
+          "description": "Name of topic on which to broadcast message",
+          "required": true,
+          "schema": {
+            "type": "string"
+          }
+        }
+      ]
+    },
+    "/processcheck": {
+      "get": {
+        "summary": "Check Processor",
+        "operationId": "API_V1_PROCESSOR_CHECK",
+        "responses": {
+          "200": {
+            "description": "Success"
+          }
         }
-      }]
+      }
     }
   },
   "components": {

config-layers/test/in/erail/service/BaseService.properties

@@ -0,0 +1,7 @@
+#/in/erail/service/BaseService
+
+vertx=/io/vertx/core/Vertx
+enable=true
+log=true
+preProcessProcessors=/in/erail/service/processor/LoadSubjectProcessor1
+postProcessProcessors=/in/erail/service/processor/AddHeaderProcessor1

config-layers/test/in/erail/service/BinaryBodyService.properties

@@ -1,8 +1,6 @@
 #/in/erail/service/BinaryBodyService
 $class=in.erail.service.BinaryBodyService
+$basedOn=/in/erail/service/BaseService
 
 operationId=API_V1_BROADCAST_V2_SERVICE
 serviceUniqueId=API_V1_BROADCAST_V2_SERVICE
-vertx=/io/vertx/core/Vertx
-enable=true
-log=true

config-layers/test/in/erail/service/BroadcastService.properties

@@ -1,8 +1,6 @@
 #/in/erail/service/BroadcastService
 $class=in.erail.service.BroadcastService
+$basedOn=/in/erail/service/BaseService
 
 operationId=API_V1_BROADCAST_SERVICE
 serviceUniqueId=API_V1_BROADCAST_SERVICE
-vertx=/io/vertx/core/Vertx
-enable=true
-log=true

config-layers/test/in/erail/service/ProcessorCheckService.properties

@@ -0,0 +1,8 @@
+#/in/erail/service/ProcessorCheckService
+$class=in.erail.service.ProcessorCheckService
+$basedOn=/in/erail/service/BaseService
+
+operationId=API_V1_PROCESSOR_CHECK
+serviceUniqueId=API_V1_PROCESSOR_CHECK
+preProcessProcessors+=/in/erail/service/processor/LoadSubjectProcessor2
+postProcessProcessors+=/in/erail/service/processor/AddHeaderProcessor2

config-layers/test/in/erail/service/processor/AddHeaderProcessor1.properties

@@ -0,0 +1,3 @@
+#/in/erail/service/processor/AddHeaderProcessor1
+$class=in.erail.service.processor.AddHeaderProcessor
+message=Header1

config-layers/test/in/erail/service/processor/AddHeaderProcessor2.properties

@@ -0,0 +1,3 @@
+#/in/erail/service/processor/AddHeaderProcessor2
+$class=in.erail.service.processor.AddHeaderProcessor
+message=Header2

config-layers/test/in/erail/service/processor/LoadSubjectProcessor1.properties

@@ -0,0 +1,3 @@
+#/in/erail/service/processor/LoadSubjectProcessor1
+$class=in.erail.service.processor.LoadSubjectProcessor
+message=Subject1

config-layers/test/in/erail/service/processor/LoadSubjectProcessor2.properties

@@ -0,0 +1,3 @@
+#/in/erail/service/processor/LoadSubjectProcessor2
+$class=in.erail.service.processor.LoadSubjectProcessor
+message=Subject2

pom.xml

@@ -4,7 +4,7 @@
     <modelVersion>4.0.0</modelVersion>
     <groupId>in.erail</groupId>
     <artifactId>api-framework</artifactId>
-    <version>2.4.3</version>
+    <version>2.4.4</version>
     <packaging>jar</packaging>
     <developers>
         <developer>

src/main/java/in/erail/model/RequestEvent.java

@@ -28,77 +28,87 @@ public class RequestEvent {
   private byte[] mBody = new byte[0];
   private boolean mIsBase64Encoded = false;
   private Map<String, Object> mPrincipal;
+  private Object mSubject;
 
   public String getResource() {
     return mResource;
   }
 
-  public void setResource(String pResource) {
+  public RequestEvent setResource(String pResource) {
     this.mResource = pResource;
+    return this;
   }
 
   public String getPath() {
     return mPath;
   }
 
-  public void setPath(String pPath) {
+  public RequestEvent setPath(String pPath) {
     this.mPath = pPath;
+    return this;
   }
 
   public HttpMethod getHttpMethod() {
     return mHttpMethod;
   }
 
-  public void setHttpMethod(HttpMethod pHttpMethod) {
+  public RequestEvent setHttpMethod(HttpMethod pHttpMethod) {
     this.mHttpMethod = pHttpMethod;
+    return this;
   }
 
   public Map<String, String> getHeaders() {
     return mHeaders;
   }
 
-  public void setHeaders(Map<String, String> pHeaders) {
+  public RequestEvent setHeaders(Map<String, String> pHeaders) {
     this.mHeaders = pHeaders;
+    return this;
   }
 
   public Map<String, String[]> getMultiValueHeaders() {
     return mMultiValueHeaders;
   }
 
-  public void setMultiValueHeaders(Map<String, String[]> pMultiValueHeaders) {
+  public RequestEvent setMultiValueHeaders(Map<String, String[]> pMultiValueHeaders) {
     this.mMultiValueHeaders = pMultiValueHeaders;
+    return this;
   }
 
   public Map<String, String> getQueryStringParameters() {
     return mQueryStringParameters;
   }
 
-  public void setQueryStringParameters(Map<String, String> pQueryStringParameters) {
+  public RequestEvent setQueryStringParameters(Map<String, String> pQueryStringParameters) {
     this.mQueryStringParameters = pQueryStringParameters;
+    return this;
   }
 
   public Map<String, String[]> getMultiValueQueryStringParameters() {
     return mMultiValueQueryStringParameters;
   }
 
-  public void setMultiValueQueryStringParameters(Map<String, String[]> pMultiValueQueryStringParameters) {
+  public RequestEvent setMultiValueQueryStringParameters(Map<String, String[]> pMultiValueQueryStringParameters) {
     this.mMultiValueQueryStringParameters = pMultiValueQueryStringParameters;
+    return this;
   }
 
   public Map<String, String> getPathParameters() {
     return mPathParameters;
   }
 
-  public void setPathParameters(Map<String, String> pPathParameters) {
+  public RequestEvent setPathParameters(Map<String, String> pPathParameters) {
     this.mPathParameters = pPathParameters;
+    return this;
   }
 
   public Map<String, String> getStageVariables() {
     return mStageVariables;
   }
 
-  public void setStageVariables(Map<String, String> pStageVariables) {
+  public RequestEvent setStageVariables(Map<String, String> pStageVariables) {
     this.mStageVariables = pStageVariables;
+    return this;
   }
 
   @SuppressWarnings("rawtypes")
@@ -107,24 +117,27 @@ public Map getRequestContext() {
   }
 
   @SuppressWarnings("rawtypes")
-  public void setRequestContext(Map pRequestContext) {
+  public RequestEvent setRequestContext(Map pRequestContext) {
     this.mRequestContext = pRequestContext;
+    return this;
   }
 
   public boolean isIsBase64Encoded() {
     return mIsBase64Encoded;
   }
 
-  public void setIsBase64Encoded(boolean pIsBase64Encoded) {
+  public RequestEvent setIsBase64Encoded(boolean pIsBase64Encoded) {
     this.mIsBase64Encoded = pIsBase64Encoded;
+    return this;
   }
 
   public byte[] getBody() {
     return mBody;
   }
 
-  public void setBody(byte[] pBody) {
+  public RequestEvent setBody(byte[] pBody) {
     this.mBody = pBody;
+    return this;
   }
 
   public String bodyAsString() {
@@ -138,13 +151,23 @@ public Map<String, Object> getPrincipal() {
     return mPrincipal;
   }
 
-  public void setPrincipal(Map<String, Object> pPrincipal) {
+  public RequestEvent setPrincipal(Map<String, Object> pPrincipal) {
     this.mPrincipal = pPrincipal;
+    return this;
   }
 
   @Override
   public String toString() {
     return JsonObject.mapFrom(this).toString();
   }
 
+  public Object getSubject() {
+    return mSubject;
+  }
+
+  public RequestEvent setSubject(Object pSubject) {
+    this.mSubject = pSubject;
+    return this;
+  }
+
 }