You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@streampipes.apache.org by ob...@apache.org on 2023/03/29 14:27:10 UTC

[streampipes] branch obermeier-patch-1 created (now 7ccaf50d1)

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

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


      at 7ccaf50d1 Implement create method in Java PipelineApi

This branch includes the following new commits:

     new 7ccaf50d1 Implement create method in Java PipelineApi

The 1 revisions listed above as "new" are entirely new to this
repository and will be described in separate emails.  The revisions
listed as "add" were already present in the repository and have only
been added to this reference.



[streampipes] 01/01: Implement create method in Java PipelineApi

Posted by ob...@apache.org.
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 <ob...@apache.org>
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);
   }
 
   /**