You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@streampipes.apache.org by ze...@apache.org on 2021/10/05 10:24:18 UTC

[incubator-streampipes-extensions] 01/01: [STEAMPIPES-438] Remove adapter Id form backend

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

zehnder pushed a commit to branch STREAMPIPES-438
in repository https://gitbox.apache.org/repos/asf/incubator-streampipes-extensions.git

commit 8d7ddc581fd98db2fedb7bf839826e9613522b40
Author: Philipp Zehnder <ze...@fzi.de>
AuthorDate: Tue Oct 5 12:23:59 2021 +0200

    [STEAMPIPES-438] Remove adapter Id form backend
---
 streampipes-connect-adapters/pom.xml                                 | 5 +++++
 .../main/java/org/apache/streampipes/connect/ConnectAdapterInit.java | 4 ++--
 2 files changed, 7 insertions(+), 2 deletions(-)

diff --git a/streampipes-connect-adapters/pom.xml b/streampipes-connect-adapters/pom.xml
index 3b8f8ba..054e1fa 100644
--- a/streampipes-connect-adapters/pom.xml
+++ b/streampipes-connect-adapters/pom.xml
@@ -35,6 +35,11 @@
                 <artifactId>streampipes-connect-container-worker</artifactId>
                 <version>${streampipes.version}</version>
             </dependency>
+            <dependency>
+                <groupId>org.apache.streampipes</groupId>
+                <artifactId>streampipes-container-extensions</artifactId>
+                <version>${streampipes.version}</version>
+            </dependency>
 
             <!-- External dependencies -->
             <dependency>
diff --git a/streampipes-connect-adapters/src/main/java/org/apache/streampipes/connect/ConnectAdapterInit.java b/streampipes-connect-adapters/src/main/java/org/apache/streampipes/connect/ConnectAdapterInit.java
index 6795797..0e3db62 100644
--- a/streampipes-connect-adapters/src/main/java/org/apache/streampipes/connect/ConnectAdapterInit.java
+++ b/streampipes-connect-adapters/src/main/java/org/apache/streampipes/connect/ConnectAdapterInit.java
@@ -35,15 +35,15 @@ import org.apache.streampipes.connect.adapters.simulator.random.RandomDataStream
 import org.apache.streampipes.connect.adapters.slack.SlackAdapter;
 import org.apache.streampipes.connect.adapters.wikipedia.WikipediaEditedArticlesAdapter;
 import org.apache.streampipes.connect.adapters.wikipedia.WikipediaNewArticlesAdapter;
-import org.apache.streampipes.connect.container.worker.init.AdapterWorkerContainer;
 import org.apache.streampipes.connect.protocol.set.FileProtocol;
 import org.apache.streampipes.connect.protocol.set.HttpProtocol;
 import org.apache.streampipes.connect.protocol.stream.*;
 import org.apache.streampipes.connect.protocol.stream.pulsar.PulsarProtocol;
+import org.apache.streampipes.container.extensions.ExtensionsModelSubmitter;
 import org.apache.streampipes.container.model.SpServiceDefinition;
 import org.apache.streampipes.container.model.SpServiceDefinitionBuilder;
 
-public class ConnectAdapterInit extends AdapterWorkerContainer {
+public class ConnectAdapterInit extends ExtensionsModelSubmitter {
 
   public static void main(String[] args) {
     new ConnectAdapterInit().init();