Configurable Proto buff example added

Author: elans3

rest-db-kafka/pom.xml

@@ -53,6 +53,14 @@
 
 	<build>
 		<sourceDirectory>src/main/java</sourceDirectory>
+		<extensions>
+			<extension>
+				<groupId>kr.motd.maven</groupId>
+				<artifactId>os-maven-plugin</artifactId>
+				<version>1.5.0.Final</version>
+			</extension>
+		</extensions>
+
 		<plugins>
 			<plugin>
 				<groupId>org.apache.maven.plugins</groupId>
@@ -99,6 +107,24 @@
 					<testFailureIgnore>true</testFailureIgnore>
 				</configuration>
 			</plugin>
+			<plugin>
+				<groupId>org.xolstice.maven.plugins</groupId>
+				<artifactId>protobuf-maven-plugin</artifactId>
+				<version>0.5.1</version>
+				<configuration>
+					<protocArtifact>com.google.protobuf:protoc:3.5.1-1:exe:${os.detected.classifier}</protocArtifact>
+					<pluginId>grpc-java</pluginId>
+					<pluginArtifact>io.grpc:protoc-gen-grpc-java:1.13.1:exe:${os.detected.classifier}</pluginArtifact>
+				</configuration>
+				<executions>
+					<execution>
+						<goals>
+							<goal>compile</goal>
+							<goal>compile-custom</goal>
+						</goals>
+					</execution>
+				</executions>
+			</plugin>
 		</plugins>
 	</build>
 	<dependencies>

rest-db-kafka/src/main/proto/cucumblan.proto

@@ -0,0 +1,14 @@
+syntax = "proto3";
+
+option java_multiple_files = true;
+option java_package = "io.virtualan.proto.cucumblan";
+option java_outer_classname = "CucumblanProto";
+
+package cucumblan;
+
+message NewUser {
+    uint64 id = 1;
+    string firstName = 2;
+    string lastName = 3;
+}
+

rest-db-kafka/src/test/java/io/virtualan/cucumblan/message/typeimpl/JSONMessageType.java

@@ -15,4 +15,15 @@ public void execute_orderEvent_workflow() {
             e.printStackTrace();
         }
     }
+
+//    @org.testng.annotations.Test
+//    public void execute_orderEvent_protobuff_workflow() {
+//        try {
+//            boolean isSuccess = VirtualanTestPlanExecutor.invoke("work-flow-proto.yaml");
+//            org.junit.Assert.assertTrue(isSuccess);
+//
+//        } catch (Exception e) {
+//            e.printStackTrace();
+//        }
+//    }
 }

rest-db-kafka/src/test/java/io/virtualan/test/KafkaTestPlanExecutor.java

@@ -0,0 +1 @@
+OrderCreated=io.virtualan.proto.cucumblan.NewUser

rest-db-kafka/src/test/resources/createOrder_API_with_OrderCreated_Event-Protobuff.xlsx

@@ -0,0 +1,10 @@
+parallelExecution: 4
+timeout:  30000
+apiExecutor:
+  - reportTitle: "API with Kafka Event Testing"
+    env: dev
+    outputJsonDir: target/idaithalam
+    outputDir: target/message-proto
+    inputExcel: createOrder_API_with_OrderCreated_Event-Protobuff.xlsx
+    cucumblanProperties:
+      service.api.orderservice-proto: http://localhost:8800

rest-db-kafka/src/test/resources/createOrder_API_with_OrderCreated_Event.xlsx

@@ -4,7 +4,7 @@ apiExecutor:
   - reportTitle: "API with Kafka Event Testing"
     env: dev
     outputJsonDir: target/idaithalam
-    outputDir: target/dev/1
+    outputDir: target/message
     inputExcel: createOrder_API_with_OrderCreated_Event.xlsx
     cucumblanProperties:
       service.api.orderservice: http://microservices.virtualandemo.com:9001