Merge 2a8a573 into 4db7667

xwm1992 · web-flow · commit 58b23d8e4453 · 2023-05-29T12:37:41.000Z
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
@@ -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
@@ -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();
     }

Original file line number	Diff line number	Diff line change
`@@ -50,7 +50,6 @@ public class SinkWorker implements ConnectorWorker {`
`50`	`50`	`public SinkWorker(Sink sink, SinkConfig config) throws Exception {`
`51`	`51`	`this.sink = sink;`
`52`	`52`	`this.config = config;`
`53`		`- sink.init(config);`
`54`	`53`	`eventMeshTCPClient = buildEventMeshSubClient(config);`
`55`	`54`	`eventMeshTCPClient.init();`
`56`	`55`	`}`
Original file line number	Diff line number	Diff line change
`@@ -55,7 +55,6 @@ public class SourceWorker implements ConnectorWorker {`
`55`	`55`	`public SourceWorker(Source source, SourceConfig config) throws Exception {`
`56`	`56`	`this.source = source;`
`57`	`57`	`this.config = config;`
`58`		`- source.init(config);`
`59`	`58`	`eventMeshTCPClient = buildEventMeshPubClient(config);`
`60`	`59`	`eventMeshTCPClient.init();`
`61`	`60`	`}`