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);
}
/**