Implement create method in Java PipelineApi

apache · Mar 29, 2023 · c38e61f · c38e61f
1 parent c33607d
commit c38e61f
Showing 1 changed file with 5 additions and 3 deletions.
diff --git a/streampipes-client/src/main/java/org/apache/streampipes/client/api/PipelineApi.java b/streampipes-client/src/main/java/org/apache/streampipes/client/api/PipelineApi.java
@@ -17,13 +17,14 @@
  */
 package org.apache.streampipes.client.api;
 
+import java.util.List;
 import org.apache.streampipes.client.model.StreamPipesClientConfig;
 import org.apache.streampipes.client.util.StreamPipesApiPath;
 import org.apache.streampipes.model.message.Message;
+import org.apache.streampipes.model.message.SuccessMessage;
 import org.apache.streampipes.model.pipeline.Pipeline;
 import org.apache.streampipes.model.pipeline.PipelineOperationStatus;
-
-import java.util.List;
+import org.apache.streampipes.model.message.SuccessMessage;
 
 public class PipelineApi extends AbstractTypedClientApi<Pipeline> implements CRUDApi<String, Pipeline> {
 
@@ -46,9 +47,10 @@ public List<Pipeline> all() {
     return getAll(getBaseResourcePath());
   }
 
+
   @Override
   public void create(Pipeline element) {
-
+    post(getBaseResourcePath(), element, SuccessMessage.class);
   }
 
   /**