You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@streampipes.apache.org by ri...@apache.org on 2023/03/30 11:42:08 UTC

[streampipes] branch dev updated: Implement create method in Java PipelineApi (#1467)

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

riemer pushed a commit to branch dev
in repository https://gitbox.apache.org/repos/asf/streampipes.git


The following commit(s) were added to refs/heads/dev by this push:
     new 8503549cf Implement create method in Java PipelineApi (#1467)
8503549cf is described below

commit 8503549cf6c0c29d340db06ac35ad0e31fe002a3
Author: Stefan Obermeier <ob...@apache.org>
AuthorDate: Thu Mar 30 13:41:59 2023 +0200

    Implement create method in Java PipelineApi (#1467)
    
    Co-authored-by: Dominik Riemer <do...@gmail.com>
---
 .../src/main/java/org/apache/streampipes/client/api/PipelineApi.java | 5 ++++-
 1 file changed, 4 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..888c15df7 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
@@ -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 class PipelineApi extends AbstractTypedClientApi<Pipeline> implements CRU
     return getAll(getBaseResourcePath());
   }
 
+
   @Override
   public void create(Pipeline element) {
-
+    post(getBaseResourcePath(), element, SuccessMessage.class);
   }
 
   /**