You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@eventmesh.apache.org by mi...@apache.org on 2023/05/30 11:42:39 UTC
[eventmesh] branch master updated: [ISSUE #4044] Remove duplicate init connector operation in worker (#4046)
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/eventmesh.git
The following commit(s) were added to refs/heads/master by this push:
new 207b9af9b [ISSUE #4044] Remove duplicate init connector operation in worker (#4046)
207b9af9b is described below
commit 207b9af9b121fba02ca6e137ebb4dc2259252abd
Author: mike_xwm <mi...@126.com>
AuthorDate: Tue May 30 19:42:31 2023 +0800
[ISSUE #4044] Remove duplicate init connector operation in worker (#4046)
---
.../src/main/java/org/apache/eventmesh/openconnect/SinkWorker.java | 1 -
.../src/main/java/org/apache/eventmesh/openconnect/SourceWorker.java | 1 -
2 files changed, 2 deletions(-)
diff --git a/eventmesh-openconnect/eventmesh-openconnect-java/src/main/java/org/apache/eventmesh/openconnect/SinkWorker.java b/eventmesh-openconnect/eventmesh-openconnect-java/src/main/java/org/apache/eventmesh/openconnect/SinkWorker.java
index 6cdaa629a..94d52b0f1 100644
--- a/eventmesh-openconnect/eventmesh-openconnect-java/src/main/java/org/apache/eventmesh/openconnect/SinkWorker.java
+++ b/eventmesh-openconnect/eventmesh-openconnect-java/src/main/java/org/apache/eventmesh/openconnect/SinkWorker.java
@@ -50,7 +50,6 @@ public class SinkWorker implements ConnectorWorker {
public SinkWorker(Sink sink, SinkConfig config) throws Exception {
this.sink = sink;
this.config = config;
- sink.init(config);
eventMeshTCPClient = buildEventMeshSubClient(config);
eventMeshTCPClient.init();
}
diff --git a/eventmesh-openconnect/eventmesh-openconnect-java/src/main/java/org/apache/eventmesh/openconnect/SourceWorker.java b/eventmesh-openconnect/eventmesh-openconnect-java/src/main/java/org/apache/eventmesh/openconnect/SourceWorker.java
index b479aa982..93db3fe50 100644
--- a/eventmesh-openconnect/eventmesh-openconnect-java/src/main/java/org/apache/eventmesh/openconnect/SourceWorker.java
+++ b/eventmesh-openconnect/eventmesh-openconnect-java/src/main/java/org/apache/eventmesh/openconnect/SourceWorker.java
@@ -55,7 +55,6 @@ public class SourceWorker implements ConnectorWorker {
public SourceWorker(Source source, SourceConfig config) throws Exception {
this.source = source;
this.config = config;
- source.init(config);
eventMeshTCPClient = buildEventMeshPubClient(config);
eventMeshTCPClient.init();
}
---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscribe@eventmesh.apache.org
For additional commands, e-mail: commits-help@eventmesh.apache.org