refactor(#2938): Replace ExtensionsModelSubmitter in archetypes

apache · Jun 17, 2024 · 6ce0f9d · 6ce0f9d
1 parent e072d6c
commit 6ce0f9d
Show file tree

Hide file tree

Showing 5 changed files with 9 additions and 9 deletions.
diff --git a/...s-archetype-extensions-jvm/src/main/resources/archetype-resources/src/main/java/Init.java b/...s-archetype-extensions-jvm/src/main/resources/archetype-resources/src/main/java/Init.java
@@ -32,15 +32,15 @@
 import org.apache.streampipes.messaging.mqtt.SpMqttProtocolFactory;
 import org.apache.streampipes.messaging.nats.SpNatsProtocolFactory;
 import org.apache.streampipes.messaging.pulsar.SpPulsarProtocolFactory;
-import org.apache.streampipes.service.extensions.ExtensionsModelSubmitter;
+import org.apache.streampipes.service.extensions.StreamPipesExtensionsServiceBase;
 import org.apache.streampipes.wrapper.standalone.runtime.StandaloneStreamPipesRuntimeProvider;
 
 import ${package}.pe.${packageName}.${classNamePrefix}DataProcessor;
 import ${package}.pe.${packageName}.${classNamePrefix}DataSink;
 import ${package}.pe.${packageName}.${classNamePrefix}GenericAdapter;
 import ${package}.pe.${packageName}.${classNamePrefix}SpecificAdapter;
 
-public class Init extends ExtensionsModelSubmitter {
+public class Init extends StreamPipesExtensionsServiceBase {
 
   public static void main(String[] args) {
     new Init().init();

diff --git a/...hetype-pe-processors-flink/src/main/resources/archetype-resources/src/main/java/Init.java b/...hetype-pe-processors-flink/src/main/resources/archetype-resources/src/main/java/Init.java
@@ -36,9 +36,9 @@
 import org.apache.streampipes.messaging.mqtt.SpMqttProtocolFactory;
 import org.apache.streampipes.messaging.pulsar.SpPulsarProtocolFactory;
 import org.apache.streampipes.messaging.nats.SpNatsProtocolFactory;
-import org.apache.streampipes.service.extensions.ExtensionsModelSubmitter;
+import org.apache.streampipes.service.extensions.StreamPipesExtensionsServiceBase;
 
-public class Init extends ExtensionsModelSubmitter {
+public class Init extends StreamPipesExtensionsServiceBase {
 
   public static void main(String[] args) throws Exception {
 	  new Init().init();

diff --git a/...s-archetype-pe-sinks-flink/src/main/resources/archetype-resources/src/main/java/Init.java b/...s-archetype-pe-sinks-flink/src/main/resources/archetype-resources/src/main/java/Init.java
@@ -32,12 +32,12 @@
 import org.apache.streampipes.messaging.mqtt.SpMqttProtocolFactory;
 import org.apache.streampipes.messaging.pulsar.SpPulsarProtocolFactory;
 import org.apache.streampipes.messaging.nats.SpNatsProtocolFactory;
-import org.apache.streampipes.service.extensions.ExtensionsModelSubmitter;
+import org.apache.streampipes.service.extensions.StreamPipesExtensionsServiceBase;
 
 import ${package}.config.ConfigKeys;
 import ${package}.pe.sink.${packageName}.${classNamePrefix}Controller;
 
-public class Init extends ExtensionsModelSubmitter {
+public class Init extends StreamPipesExtensionsServiceBase {
 
   public static void main(String[] args) throws Exception {
     new Init().init();

diff --git a/...tal-flink/src/main/java/org/apache/streampipes/pe/flink/AllFlinkPipelineElementsInit.java b/...tal-flink/src/main/java/org/apache/streampipes/pe/flink/AllFlinkPipelineElementsInit.java
@@ -47,11 +47,11 @@
 import org.apache.streampipes.pe.flink.processor.urldereferencing.UrlDereferencingController;
 import org.apache.streampipes.pe.flink.processor.wordcount.WordCountController;
 import org.apache.streampipes.pe.flink.sink.elasticsearch.ElasticSearchController;
-import org.apache.streampipes.service.extensions.ExtensionsModelSubmitter;
+import org.apache.streampipes.service.extensions.StreamPipesExtensionsServiceBase;
 import org.apache.streampipes.wrapper.flink.FlinkRuntimeProvider;
 
 
-public class AllFlinkPipelineElementsInit extends ExtensionsModelSubmitter {
+public class AllFlinkPipelineElementsInit extends StreamPipesExtensionsServiceBase {
 
   public static void main(String[] args) {
     new AllFlinkPipelineElementsInit().init();

diff --git a/streampipes-maven-plugin/README.md b/streampipes-maven-plugin/README.md
@@ -31,7 +31,7 @@ The streampipes-maven-plugin can either be started from the command line or embe
 
 ### Prerequisites
 
-The plugin must be started from a module which contains an `Init` class which inherits `ExtensionsModelSubmitter`.
+The plugin must be started from a module which contains an `Init` class which inherits `StreamPipesExtensionsServiceBase`.
 By default, the goal runs in the `package` phase.
 
 ### Command line