feat(connector): add S3SourceWorker

1. add S3SourceWorker Closes apache#4082
TheR1sing3un · Jun 25, 2023 · 45c1b3f · 45c1b3f
1 parent ac6fb84
commit 45c1b3f
Showing 1 changed file with 9 additions and 0 deletions.
diff --git a/...e-connector-s3/src/main/java/org/apache/eventmesh/source/connector/s3/S3SourceWorker.java b/...e-connector-s3/src/main/java/org/apache/eventmesh/source/connector/s3/S3SourceWorker.java
@@ -17,6 +17,15 @@
 
 package org.apache.eventmesh.source.connector.s3;
 
+import org.apache.eventmesh.openconnect.Application;
+import org.apache.eventmesh.source.connector.s3.connector.S3SourceConnector;
+
 public class S3SourceWorker {
 
+    public static void main(String[] args) throws Exception {
+
+        Application rocketmqSourceApp = new Application();
+        rocketmqSourceApp.run(S3SourceConnector.class);
+
+    }
 }