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 <[email protected]>
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: [email protected]
For additional commands, e-mail: [email protected]
