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/12 21:17:43 UTC
[streampipes] 01/05: add checkstyle to streampipes-connect-api
This is an automated email from the ASF dual-hosted git repository.
bossenti pushed a commit to branch add-checkstyle
in repository https://gitbox.apache.org/repos/asf/streampipes.git
commit 638b1fac420df499582a71303a8cf9a20d267b60
Author: bossenti <bo...@posteo.de>
AuthorDate: Mon Dec 12 21:28:49 2022 +0100
add checkstyle to streampipes-connect-api
---
streampipes-connect-api/pom.xml | 12 ++++++++--
.../streampipes/connect/api/EmitBinaryEvent.java | 2 +-
.../connect/api/IAdapterPipelineElement.java | 2 +-
.../apache/streampipes/connect/api/IFormat.java | 28 +++++++++++-----------
.../connect/api/exception/AdapterException.java | 16 ++++++-------
.../connect/api/exception/ParseException.java | 18 +++++++-------
.../api/exception/WorkerAdapterException.java | 27 +++++++++++----------
7 files changed, 57 insertions(+), 48 deletions(-)
diff --git a/streampipes-connect-api/pom.xml b/streampipes-connect-api/pom.xml
index 82f022051..ea0c1fac6 100644
--- a/streampipes-connect-api/pom.xml
+++ b/streampipes-connect-api/pom.xml
@@ -17,7 +17,8 @@
~
-->
-<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>
<artifactId>streampipes-parent</artifactId>
<groupId>org.apache.streampipes</groupId>
@@ -38,5 +39,12 @@
<maven.compiler.source>8</maven.compiler.source>
<maven.compiler.target>8</maven.compiler.target>
</properties>
-
+ <build>
+ <plugins>
+ <plugin>
+ <groupId>org.apache.maven.plugins</groupId>
+ <artifactId>maven-checkstyle-plugin</artifactId>
+ </plugin>
+ </plugins>
+ </build>
</project>
diff --git a/streampipes-connect-api/src/main/java/org/apache/streampipes/connect/api/EmitBinaryEvent.java b/streampipes-connect-api/src/main/java/org/apache/streampipes/connect/api/EmitBinaryEvent.java
index 0fe98abb7..35ea494d6 100644
--- a/streampipes-connect-api/src/main/java/org/apache/streampipes/connect/api/EmitBinaryEvent.java
+++ b/streampipes-connect-api/src/main/java/org/apache/streampipes/connect/api/EmitBinaryEvent.java
@@ -19,5 +19,5 @@
package org.apache.streampipes.connect.api;
public interface EmitBinaryEvent {
- Boolean emit(byte[] event);
+ Boolean emit(byte[] event);
}
diff --git a/streampipes-connect-api/src/main/java/org/apache/streampipes/connect/api/IAdapterPipelineElement.java b/streampipes-connect-api/src/main/java/org/apache/streampipes/connect/api/IAdapterPipelineElement.java
index 87a6f646a..fd3b08a45 100644
--- a/streampipes-connect-api/src/main/java/org/apache/streampipes/connect/api/IAdapterPipelineElement.java
+++ b/streampipes-connect-api/src/main/java/org/apache/streampipes/connect/api/IAdapterPipelineElement.java
@@ -22,6 +22,6 @@ import java.util.Map;
public interface IAdapterPipelineElement {
- Map<String, Object> process(Map<String, Object> event);
+ Map<String, Object> process(Map<String, Object> event);
}
diff --git a/streampipes-connect-api/src/main/java/org/apache/streampipes/connect/api/IFormat.java b/streampipes-connect-api/src/main/java/org/apache/streampipes/connect/api/IFormat.java
index 6c4e52b3b..18a902cb7 100644
--- a/streampipes-connect-api/src/main/java/org/apache/streampipes/connect/api/IFormat.java
+++ b/streampipes-connect-api/src/main/java/org/apache/streampipes/connect/api/IFormat.java
@@ -26,24 +26,24 @@ import java.util.Map;
public interface IFormat {
- IFormat getInstance(FormatDescription formatDescription);
+ IFormat getInstance(FormatDescription formatDescription);
- FormatDescription declareModel();
+ FormatDescription declareModel();
- String getId();
+ String getId();
- /**
- * This method parses a byte[] and transforms the event object into a serialized version of the internal
- * representation
- */
- Map<String, Object> parse(byte[] object) throws ParseException;
+ /**
+ * This method parses a byte[] and transforms the event object into a serialized version of the internal
+ * representation
+ */
+ Map<String, Object> parse(byte[] object) throws ParseException;
- /**
- * Needed for example for the CSV format in iterative protocols to ensure header is not send again
- * When the reset is not required it can be ignored
- */
- default void reset() {
+ /**
+ * Needed for example for the CSV format in iterative protocols to ensure header is not send again
+ * When the reset is not required it can be ignored
+ */
+ default void reset() {
- }
+ }
}
diff --git a/streampipes-connect-api/src/main/java/org/apache/streampipes/connect/api/exception/AdapterException.java b/streampipes-connect-api/src/main/java/org/apache/streampipes/connect/api/exception/AdapterException.java
index 7f6095103..07fc423ef 100644
--- a/streampipes-connect-api/src/main/java/org/apache/streampipes/connect/api/exception/AdapterException.java
+++ b/streampipes-connect-api/src/main/java/org/apache/streampipes/connect/api/exception/AdapterException.java
@@ -19,14 +19,14 @@
package org.apache.streampipes.connect.api.exception;
public class AdapterException extends Exception {
- public AdapterException() {}
+ public AdapterException() {
+ }
- public AdapterException(String message)
- {
- super(message);
- }
+ public AdapterException(String message) {
+ super(message);
+ }
- public AdapterException(String message, Throwable cause) {
- super(message, cause);
- }
+ public AdapterException(String message, Throwable cause) {
+ super(message, cause);
+ }
}
diff --git a/streampipes-connect-api/src/main/java/org/apache/streampipes/connect/api/exception/ParseException.java b/streampipes-connect-api/src/main/java/org/apache/streampipes/connect/api/exception/ParseException.java
index 37c3ed376..b8f185014 100644
--- a/streampipes-connect-api/src/main/java/org/apache/streampipes/connect/api/exception/ParseException.java
+++ b/streampipes-connect-api/src/main/java/org/apache/streampipes/connect/api/exception/ParseException.java
@@ -20,15 +20,15 @@ package org.apache.streampipes.connect.api.exception;
public class ParseException extends RuntimeException {
- public ParseException() {}
+ public ParseException() {
+ }
- public ParseException(String message)
- {
- super(message);
- }
+ public ParseException(String message) {
+ super(message);
+ }
- public ParseException(String message,
- Throwable throwable) {
- super(message, throwable);
- }
+ public ParseException(String message,
+ Throwable throwable) {
+ super(message, throwable);
+ }
}
diff --git a/streampipes-connect-api/src/main/java/org/apache/streampipes/connect/api/exception/WorkerAdapterException.java b/streampipes-connect-api/src/main/java/org/apache/streampipes/connect/api/exception/WorkerAdapterException.java
index c067586ce..9161f73e8 100644
--- a/streampipes-connect-api/src/main/java/org/apache/streampipes/connect/api/exception/WorkerAdapterException.java
+++ b/streampipes-connect-api/src/main/java/org/apache/streampipes/connect/api/exception/WorkerAdapterException.java
@@ -21,20 +21,21 @@ package org.apache.streampipes.connect.api.exception;
import org.apache.streampipes.model.message.Message;
public class WorkerAdapterException extends Exception {
- private Message content;
- public WorkerAdapterException() {}
+ private Message content;
- public WorkerAdapterException(Message message)
- {
- super(message.getElementName());
- this.content = message;
- }
+ public WorkerAdapterException() {
+ }
- public WorkerAdapterException(String message, Throwable cause) {
- super(message, cause);
- }
+ public WorkerAdapterException(Message message) {
+ super(message.getElementName());
+ this.content = message;
+ }
- public Message getContent() {
- return content;
- }
+ public WorkerAdapterException(String message, Throwable cause) {
+ super(message, cause);
+ }
+
+ public Message getContent() {
+ return content;
+ }
}