fix exception

Fungx · Dec 11, 2023 · 44093a7 · 44093a7
1 parent 115e599
commit 44093a7
Showing 1 changed file with 3 additions and 3 deletions.
diff --git a/...c/main/java/org/apache/eventmesh/connector/http/source/connector/HttpSourceConnector.java b/...c/main/java/org/apache/eventmesh/connector/http/source/connector/HttpSourceConnector.java
@@ -72,7 +72,7 @@ public void init(ConnectorContext connectorContext) throws Exception {
         doInit();
     }
 
-    private void doInit() throws Exception {
+    private void doInit() {
         this.queue = new LinkedBlockingQueue<>(1000);
 
         final Vertx vertx = Vertx.vertx();
@@ -100,7 +100,7 @@ private void doInit() throws Exception {
     }
 
     @Override
-    public void start() throws Exception {
+    public void start() {
         Throwable t = this.server.listen().cause();
         if (t != null) {
             log.error("[HttpSourceConnector] Failed to start Vertx server.", t);
@@ -119,7 +119,7 @@ public String name() {
     }
 
     @Override
-    public void stop() throws Exception {
+    public void stop() {
         Throwable t = this.server.close().cause();
         if (t != null) {
             log.error("[HttpSourceConnector] Failed to stop Vertx server.", t);