Implement create method in Java PipelineApi

apache · Mar 29, 2023 · 6b48d3f · 6b48d3f
1 parent c33607d
commit 6b48d3f
Showing 1 changed file with 4 additions and 1 deletion.
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,9 +17,11 @@
  */
 package org.apache.streampipes.client.api;
 
+
 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;
 
@@ -46,9 +48,10 @@ public List<Pipeline> all() {
     return getAll(getBaseResourcePath());
   }
 
+
   @Override
   public void create(Pipeline element) {
-
+    post(getBaseResourcePath(), element, SuccessMessage.class);
   }
 
   /**