You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@streampipes.apache.org by bo...@apache.org on 2022/12/25 20:00:34 UTC
[streampipes] 02/06: add checkstyle to streampipes-container-standalone
This is an automated email from the ASF dual-hosted git repository.
bossenti pushed a commit to branch chore/add-checkstyle
in repository https://gitbox.apache.org/repos/asf/streampipes.git
commit 3e47592704f9c7ad1edc449f0256e5efe467ce8a
Author: bossenti <bo...@posteo.de>
AuthorDate: Sun Dec 25 20:53:07 2022 +0100
add checkstyle to streampipes-container-standalone
---
streampipes-container-standalone/pom.xml | 14 ++++-
.../PipelineElementContainerResourceConfig.java | 7 +--
.../PipelineElementServiceShutdownHandler.java | 1 +
.../standalone/init/StandaloneModelSubmitter.java | 59 +++++++++++-----------
4 files changed, 47 insertions(+), 34 deletions(-)
diff --git a/streampipes-container-standalone/pom.xml b/streampipes-container-standalone/pom.xml
index 1649fb035..3b1a44b3b 100644
--- a/streampipes-container-standalone/pom.xml
+++ b/streampipes-container-standalone/pom.xml
@@ -17,10 +17,11 @@
~
-->
-<project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
+<project xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xmlns="http://maven.apache.org/POM/4.0.0"
+ xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
<parent>
<groupId>org.apache.streampipes</groupId>
- <artifactId>streampipes-parent</artifactId>
+ <artifactId>streampipes-parent</artifactId>
<version>0.91.0-SNAPSHOT</version>
</parent>
<modelVersion>4.0.0</modelVersion>
@@ -48,4 +49,13 @@
<!-- Test dependencies -->
</dependencies>
+ <build>
+ <finalName>streampipes-connect-container-master</finalName>
+ <plugins>
+ <plugin>
+ <groupId>org.apache.maven.plugins</groupId>
+ <artifactId>maven-checkstyle-plugin</artifactId>
+ </plugin>
+ </plugins>
+ </build>
</project>
diff --git a/streampipes-container-standalone/src/main/java/org/apache/streampipes/container/standalone/init/PipelineElementContainerResourceConfig.java b/streampipes-container-standalone/src/main/java/org/apache/streampipes/container/standalone/init/PipelineElementContainerResourceConfig.java
index 291337520..b639766e1 100644
--- a/streampipes-container-standalone/src/main/java/org/apache/streampipes/container/standalone/init/PipelineElementContainerResourceConfig.java
+++ b/streampipes-container-standalone/src/main/java/org/apache/streampipes/container/standalone/init/PipelineElementContainerResourceConfig.java
@@ -17,9 +17,10 @@
*/
package org.apache.streampipes.container.standalone.init;
-import org.apache.streampipes.service.base.rest.BaseResourceConfig;
import org.apache.streampipes.container.init.BaseExtensionsServiceResourceProvider;
import org.apache.streampipes.container.init.PipelineElementServiceResourceProvider;
+import org.apache.streampipes.service.base.rest.BaseResourceConfig;
+
import org.springframework.stereotype.Component;
import java.util.Arrays;
@@ -31,8 +32,8 @@ public class PipelineElementContainerResourceConfig extends BaseResourceConfig {
@Override
public List<List<Class<?>>> getClassesToRegister() {
return Arrays.asList(
- new BaseExtensionsServiceResourceProvider().getResourceClasses(),
- new PipelineElementServiceResourceProvider().getResourceClasses()
+ new BaseExtensionsServiceResourceProvider().getResourceClasses(),
+ new PipelineElementServiceResourceProvider().getResourceClasses()
);
}
}
diff --git a/streampipes-container-standalone/src/main/java/org/apache/streampipes/container/standalone/init/PipelineElementServiceShutdownHandler.java b/streampipes-container-standalone/src/main/java/org/apache/streampipes/container/standalone/init/PipelineElementServiceShutdownHandler.java
index 6b3522d5e..1b9cf5512 100644
--- a/streampipes-container-standalone/src/main/java/org/apache/streampipes/container/standalone/init/PipelineElementServiceShutdownHandler.java
+++ b/streampipes-container-standalone/src/main/java/org/apache/streampipes/container/standalone/init/PipelineElementServiceShutdownHandler.java
@@ -18,6 +18,7 @@
package org.apache.streampipes.container.standalone.init;
import org.apache.streampipes.container.init.RunningInstances;
+
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
diff --git a/streampipes-container-standalone/src/main/java/org/apache/streampipes/container/standalone/init/StandaloneModelSubmitter.java b/streampipes-container-standalone/src/main/java/org/apache/streampipes/container/standalone/init/StandaloneModelSubmitter.java
index 037a6fbd5..bf9dc8024 100644
--- a/streampipes-container-standalone/src/main/java/org/apache/streampipes/container/standalone/init/StandaloneModelSubmitter.java
+++ b/streampipes-container-standalone/src/main/java/org/apache/streampipes/container/standalone/init/StandaloneModelSubmitter.java
@@ -19,13 +19,14 @@
package org.apache.streampipes.container.standalone.init;
-import org.apache.streampipes.service.base.BaseNetworkingConfig;
import org.apache.streampipes.container.init.DeclarersSingleton;
import org.apache.streampipes.container.model.PeConfig;
import org.apache.streampipes.container.model.SpServiceDefinition;
+import org.apache.streampipes.service.base.BaseNetworkingConfig;
import org.apache.streampipes.service.extensions.base.StreamPipesExtensionsServiceBase;
import org.apache.streampipes.service.extensions.base.WebSecurityConfig;
import org.apache.streampipes.svcdiscovery.api.model.SpServiceTag;
+
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.boot.autoconfigure.EnableAutoConfiguration;
@@ -38,43 +39,43 @@ import java.util.List;
@Deprecated
@Configuration
@EnableAutoConfiguration
-@Import({ PipelineElementContainerResourceConfig.class, WebSecurityConfig.class})
+@Import({PipelineElementContainerResourceConfig.class, WebSecurityConfig.class})
public abstract class StandaloneModelSubmitter extends StreamPipesExtensionsServiceBase {
- private static final Logger LOG =
- LoggerFactory.getLogger(StandaloneModelSubmitter.class.getCanonicalName());
+ private static final Logger LOG =
+ LoggerFactory.getLogger(StandaloneModelSubmitter.class.getCanonicalName());
- @Deprecated
- public void init(PeConfig peConfig) {
- DeclarersSingleton.getInstance()
- .setHostName(peConfig.getHost());
- DeclarersSingleton.getInstance()
- .setPort(peConfig.getPort());
+ @Deprecated
+ public void init(PeConfig peConfig) {
+ DeclarersSingleton.getInstance()
+ .setHostName(peConfig.getHost());
+ DeclarersSingleton.getInstance()
+ .setPort(peConfig.getPort());
- BaseNetworkingConfig networkingConfig = new BaseNetworkingConfig(peConfig.getHost(), peConfig.getPort());
- SpServiceDefinition serviceDef = DeclarersSingleton.getInstance().toServiceDefinition(peConfig.getId());
+ BaseNetworkingConfig networkingConfig = new BaseNetworkingConfig(peConfig.getHost(), peConfig.getPort());
+ SpServiceDefinition serviceDef = DeclarersSingleton.getInstance().toServiceDefinition(peConfig.getId());
- try {
- startExtensionsService(this.getClass(), serviceDef, networkingConfig);
- } catch (UnknownHostException e) {
- e.printStackTrace();
- }
+ try {
+ startExtensionsService(this.getClass(), serviceDef, networkingConfig);
+ } catch (UnknownHostException e) {
+ e.printStackTrace();
}
+ }
- @Override
- public void onExit() {
- new PipelineElementServiceShutdownHandler().onShutdown();
- deregisterService(DeclarersSingleton.getInstance().getServiceId());
- }
+ @Override
+ public void onExit() {
+ new PipelineElementServiceShutdownHandler().onShutdown();
+ deregisterService(DeclarersSingleton.getInstance().getServiceId());
+ }
- @Override
- protected List<SpServiceTag> getExtensionsServiceTags() {
- return new PipelineElementServiceTagProvider().extractServiceTags();
- }
+ @Override
+ protected List<SpServiceTag> getExtensionsServiceTags() {
+ return new PipelineElementServiceTagProvider().extractServiceTags();
+ }
- @Override
- public void afterServiceRegistered(SpServiceDefinition serviceDef) {
+ @Override
+ public void afterServiceRegistered(SpServiceDefinition serviceDef) {
- }
+ }
}