This is an automated email from the ASF dual-hosted git repository.

obermeier pushed a commit to branch obermeier-patch-1
in repository https://gitbox.apache.org/repos/asf/streampipes.git

commit 7ccaf50d12ec159445ec060f143ecae3d0095c42
Author: Stefan Obermeier <[email protected]>
AuthorDate: Wed Mar 29 16:27:03 2023 +0200

    Implement create method in Java PipelineApi
---
 .../src/main/java/org/apache/streampipes/client/api/PipelineApi.java   | 3 ++-
 1 file changed, 2 insertions(+), 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
index c599fee2d..eaa1fb4e4 100644
--- 
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
@@ -22,6 +22,7 @@ import org.apache.streampipes.client.util.StreamPipesApiPath;
 import org.apache.streampipes.model.message.Message;
 import org.apache.streampipes.model.pipeline.Pipeline;
 import org.apache.streampipes.model.pipeline.PipelineOperationStatus;
+import org.apache.streampipes.model.message.SuccessMessage;
 
 import java.util.List;
 
@@ -48,7 +49,7 @@ public class PipelineApi extends 
AbstractTypedClientApi<Pipeline> implements CRU
 
   @Override
   public void create(Pipeline element) {
-
+    return post(getBaseResourcePath(), element, SuccessMessage.class);
   }
 
   /**

Reply via email to