This is an automated email from the ASF dual-hosted git repository.
mikexue pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/incubator-eventmesh.git
The following commit(s) were added to refs/heads/master by this push:
new 988783bca update AbstractEventProcessor to abstract
new 68b08632f Merge pull request #2696 from
weihubeats/AbstractEventProcessor
988783bca is described below
commit 988783bcad2bb96030949c1e1304aa2e072c1550
Author: weihu <[email protected]>
AuthorDate: Tue Dec 27 20:00:45 2022 +0800
update AbstractEventProcessor to abstract
---
.../core/protocol/http/processor/LocalSubscribeEventProcessor.java | 2 +-
.../core/protocol/http/processor/LocalUnSubscribeEventProcessor.java | 2 +-
.../core/protocol/http/processor/RemoteSubscribeEventProcessor.java | 2 +-
.../core/protocol/http/processor/RemoteUnSubscribeEventProcessor.java | 2 +-
.../core/protocol/http/processor/inf/AbstractEventProcessor.java | 3 ++-
5 files changed, 6 insertions(+), 5 deletions(-)
diff --git
a/eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/core/protocol/http/processor/LocalSubscribeEventProcessor.java
b/eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/core/protocol/http/processor/LocalSubscribeEventProcessor.java
index 94b14d919..7e5b234b4 100644
---
a/eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/core/protocol/http/processor/LocalSubscribeEventProcessor.java
+++
b/eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/core/protocol/http/processor/LocalSubscribeEventProcessor.java
@@ -60,7 +60,7 @@ import com.fasterxml.jackson.core.type.TypeReference;
@EventMeshTrace(isEnable = false)
-public class LocalSubscribeEventProcessor extends AbstractEventProcessor
implements AsyncHttpProcessor {
+public class LocalSubscribeEventProcessor extends AbstractEventProcessor {
public Logger httpLogger = LoggerFactory.getLogger("http");
diff --git
a/eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/core/protocol/http/processor/LocalUnSubscribeEventProcessor.java
b/eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/core/protocol/http/processor/LocalUnSubscribeEventProcessor.java
index d19aa49d2..454fea3aa 100644
---
a/eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/core/protocol/http/processor/LocalUnSubscribeEventProcessor.java
+++
b/eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/core/protocol/http/processor/LocalUnSubscribeEventProcessor.java
@@ -57,7 +57,7 @@ import com.fasterxml.jackson.core.type.TypeReference;
import com.google.common.collect.Maps;
@EventMeshTrace(isEnable = false)
-public class LocalUnSubscribeEventProcessor extends AbstractEventProcessor
implements AsyncHttpProcessor {
+public class LocalUnSubscribeEventProcessor extends AbstractEventProcessor {
public Logger httpLogger =
LoggerFactory.getLogger(EventMeshConstants.PROTOCOL_HTTP);
diff --git
a/eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/core/protocol/http/processor/RemoteSubscribeEventProcessor.java
b/eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/core/protocol/http/processor/RemoteSubscribeEventProcessor.java
index 96cc3c37a..952daef88 100644
---
a/eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/core/protocol/http/processor/RemoteSubscribeEventProcessor.java
+++
b/eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/core/protocol/http/processor/RemoteSubscribeEventProcessor.java
@@ -63,7 +63,7 @@ import com.google.common.base.Preconditions;
import com.google.common.collect.Maps;
@EventMeshTrace(isEnable = false)
-public class RemoteSubscribeEventProcessor extends AbstractEventProcessor
implements AsyncHttpProcessor {
+public class RemoteSubscribeEventProcessor extends AbstractEventProcessor {
public Logger httpLogger =
LoggerFactory.getLogger(EventMeshConstants.PROTOCOL_HTTP);
diff --git
a/eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/core/protocol/http/processor/RemoteUnSubscribeEventProcessor.java
b/eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/core/protocol/http/processor/RemoteUnSubscribeEventProcessor.java
index 6e61c5b47..3d484af7b 100644
---
a/eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/core/protocol/http/processor/RemoteUnSubscribeEventProcessor.java
+++
b/eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/core/protocol/http/processor/RemoteUnSubscribeEventProcessor.java
@@ -63,7 +63,7 @@ import com.google.common.base.Preconditions;
import com.google.common.collect.Maps;
@EventMeshTrace(isEnable = false)
-public class RemoteUnSubscribeEventProcessor extends AbstractEventProcessor
implements AsyncHttpProcessor {
+public class RemoteUnSubscribeEventProcessor extends AbstractEventProcessor {
public Logger httpLogger =
LoggerFactory.getLogger(EventMeshConstants.PROTOCOL_HTTP);
diff --git
a/eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/core/protocol/http/processor/inf/AbstractEventProcessor.java
b/eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/core/protocol/http/processor/inf/AbstractEventProcessor.java
index c770dc001..9a11dd0dd 100644
---
a/eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/core/protocol/http/processor/inf/AbstractEventProcessor.java
+++
b/eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/core/protocol/http/processor/inf/AbstractEventProcessor.java
@@ -28,6 +28,7 @@ import
org.apache.eventmesh.runtime.core.consumergroup.ConsumerGroupConf;
import org.apache.eventmesh.runtime.core.consumergroup.ConsumerGroupMetadata;
import org.apache.eventmesh.runtime.core.consumergroup.ConsumerGroupTopicConf;
import
org.apache.eventmesh.runtime.core.consumergroup.ConsumerGroupTopicMetadata;
+import
org.apache.eventmesh.runtime.core.protocol.http.processor.AsyncHttpProcessor;
import org.apache.eventmesh.runtime.registry.Registry;
import org.apache.commons.lang3.StringUtils;
@@ -45,7 +46,7 @@ import com.google.common.collect.Maps;
/**
* EventProcessor
*/
-public class AbstractEventProcessor {
+public abstract class AbstractEventProcessor implements AsyncHttpProcessor {
private static final Logger LOGGER =
LoggerFactory.getLogger("AbstractEventProcessor");
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
