diff --git a/eventmesh-connectors/eventmesh-connector-http/src/main/java/org/apache/eventmesh/connector/http/source/connector/HttpSourceConnector.java b/eventmesh-connectors/eventmesh-connector-http/src/main/java/org/apache/eventmesh/connector/http/source/connector/HttpSourceConnector.java index 4dddb752ab..ac431ccad3 100644 --- a/eventmesh-connectors/eventmesh-connector-http/src/main/java/org/apache/eventmesh/connector/http/source/connector/HttpSourceConnector.java +++ b/eventmesh-connectors/eventmesh-connector-http/src/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);