fix checkStyle

apache · Nov 1, 2021 · 691bcb3 · 691bcb3
1 parent 670c2f2
commit 691bcb3
Show file tree

Hide file tree

Showing 5 changed files with 17 additions and 11 deletions.
diff --git a/...-plugin/eventmesh-connector-api/src/main/java/org/apache/eventmesh/api/EventListener.java b/...-plugin/eventmesh-connector-api/src/main/java/org/apache/eventmesh/api/EventListener.java
@@ -25,8 +25,8 @@
  *
  * <p>
  * <strong>
- * Thread safe requirements: this interface will be invoked by multi threads, so users should keep thread safe during
- * the consume process.
+ * Thread safe requirements: this interface will be invoked by multi threads,
+ * so users should keep thread safe during the consume process.
  * </strong>
  * </p>
  */

diff --git a/...r-plugin/eventmesh-connector-api/src/main/java/org/apache/eventmesh/api/SendCallback.java b/...r-plugin/eventmesh-connector-api/src/main/java/org/apache/eventmesh/api/SendCallback.java
@@ -18,8 +18,13 @@
 package org.apache.eventmesh.api;
 
 
+import io.cloudevents.CloudEvent;
 import org.apache.eventmesh.api.exception.OnExceptionContext;
+import org.apache.eventmesh.api.producer.Producer;
 
+/**
+ * Call back interface used in {@link Producer#sendAsync(CloudEvent, SendCallback)}.
+ */
 public interface SendCallback {
 
     void onSuccess(final SendResult sendResult);

diff --git a/...he/eventmesh/api/consumer/EMConsumer.java → ...ache/eventmesh/api/consumer/Consumer.java b/...he/eventmesh/api/consumer/EMConsumer.java → ...ache/eventmesh/api/consumer/Consumer.java
@@ -18,6 +18,7 @@
 package org.apache.eventmesh.api.consumer;
 
 import io.cloudevents.CloudEvent;
+
 import org.apache.eventmesh.api.AbstractContext;
 import org.apache.eventmesh.api.EventListener;
 import org.apache.eventmesh.spi.EventMeshExtensionType;
@@ -27,10 +28,10 @@
 import java.util.Properties;
 
 /**
- * Consumer Interface
+ * Consumer Interface.
  */
 @EventMeshSPI(isSingleton = false, eventMeshExtensionType = EventMeshExtensionType.CONNECTOR)
-public interface EMConsumer {
+public interface Consumer {
 
     void init(Properties keyValue) throws Exception;
 

diff --git a/...ector-api/src/main/java/org/apache/eventmesh/api/exception/ConnectorRuntimeException.java b/...ector-api/src/main/java/org/apache/eventmesh/api/exception/ConnectorRuntimeException.java
@@ -17,21 +17,21 @@
 
 package org.apache.eventmesh.api.exception;
 
-public class ConnectorRuntimeException extends RuntimeException{
+public class ConnectorRuntimeException extends RuntimeException {
 
-    public ConnectorRuntimeException(){
+    public ConnectorRuntimeException() {
 
     }
 
-    public ConnectorRuntimeException(String message){
+    public ConnectorRuntimeException(String message) {
         super(message);
     }
 
-    public ConnectorRuntimeException(Throwable throwable){
+    public ConnectorRuntimeException(Throwable throwable) {
         super(throwable);
     }
 
-    public ConnectorRuntimeException(String message, Throwable throwable){
+    public ConnectorRuntimeException(String message, Throwable throwable) {
         super(message, throwable);
     }
 

diff --git a/...he/eventmesh/api/producer/EMProducer.java → ...ache/eventmesh/api/producer/Producer.java b/...he/eventmesh/api/producer/EMProducer.java → ...ache/eventmesh/api/producer/Producer.java
@@ -28,10 +28,10 @@
 import java.util.Properties;
 
 /**
- * Producer Interface
+ * Producer Interface.
  */
 @EventMeshSPI(isSingleton = false, eventMeshExtensionType = EventMeshExtensionType.CONNECTOR)
-public interface EMProducer {
+public interface Producer {
 
     void init(Properties properties) throws Exception;