Remove unused tasks and replace used with prebuilt tasks

integration-tests/src/test/java/com/redhat/parodos/flows/SimpleWorkFlowTest.java

@@ -1,7 +1,6 @@
 package com.redhat.parodos.flows;
 
 import java.util.Arrays;
-import java.util.Collections;
 import java.util.List;
 import java.util.function.Consumer;
 
@@ -48,8 +47,9 @@ public void runSimpleWorkFlow() throws ApiException, InterruptedException {
 		// Define WorkRequests
 		WorkRequestDTO work1 = new WorkRequestDTO();
 		work1.setWorkName("restCallTask");
-		work1.setArguments(Collections
-				.singletonList(new ArgumentRequestDTO().key("url").value("http://localhost:8080/actuator/health")));
+		work1.setArguments(
+				Arrays.asList(new ArgumentRequestDTO().key("url").value("http://localhost:8080/actuator/health"),
+						new ArgumentRequestDTO().key("method").value("get")));
 
 		WorkRequestDTO work2 = new WorkRequestDTO();
 		work2.setWorkName("loggingTask");

workflow-examples/run_examples.sh

@@ -202,6 +202,10 @@ run_simple_flow() {
                   {
                     "key": "url",
                     "value": "http://localhost:8080/actuator/health"
+                  },
+                  {
+                    "key": "method",
+                    "value": "get"
                   }
               ]
           },

workflow-examples/src/main/java/com/redhat/parodos/examples/simple/SimpleWorkFlowConfiguration.java

@@ -18,7 +18,7 @@
 import java.util.concurrent.Executors;
 
 import com.redhat.parodos.examples.simple.task.LoggingWorkFlowTask;
-import com.redhat.parodos.examples.simple.task.RestAPIWorkFlowTask;
+import com.redhat.parodos.tasks.rest.RestWorkFlowTask;
 import com.redhat.parodos.workflow.annotation.Infrastructure;
 import com.redhat.parodos.workflow.annotation.WorkFlowProperties;
 import com.redhat.parodos.workflow.consts.WorkFlowConstants;
@@ -45,8 +45,8 @@ public class SimpleWorkFlowConfiguration {
 
 	// START Sequential Example (WorkflowTasks and Workflow Definitions)
 	@Bean
-	RestAPIWorkFlowTask restCallTask() {
-		return new RestAPIWorkFlowTask();
+	RestWorkFlowTask restCallTask() {
+		return new RestWorkFlowTask();
 	}
 
 	@Bean
@@ -57,7 +57,7 @@ LoggingWorkFlowTask loggingTask() {
 	@Bean(name = "simpleSequentialWorkFlow" + WorkFlowConstants.INFRASTRUCTURE_WORKFLOW)
 	@Infrastructure
 	@WorkFlowProperties(version = "${git.commit.id}")
-	WorkFlow simpleSequentialWorkFlowTask(@Qualifier("restCallTask") RestAPIWorkFlowTask restCallTask,
+	WorkFlow simpleSequentialWorkFlowTask(@Qualifier("restCallTask") RestWorkFlowTask restCallTask,
 			@Qualifier("loggingTask") LoggingWorkFlowTask loggingTask) {
 		// @formatter:off
 		return SequentialFlow