fix exception & config

Fungx · Dec 11, 2023 · cf49f64 · cf49f64
1 parent 115e599
commit cf49f64
Show file tree

Hide file tree

Showing 2 changed files with 10 additions and 10 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
@@ -60,19 +60,19 @@ public Class<? extends Config> configClass() {
     }
 
     @Override
-    public void init(Config config) throws Exception {
+    public void init(Config config) {
         this.sourceConfig = (HttpSourceConfig) config;
         doInit();
     }
 
     @Override
-    public void init(ConnectorContext connectorContext) throws Exception {
+    public void init(ConnectorContext connectorContext) {
         SourceConnectorContext sourceConnectorContext = (SourceConnectorContext) connectorContext;
         this.sourceConfig = (HttpSourceConfig) sourceConnectorContext.getSourceConfig();
         doInit();
     }
 
-    private void doInit() throws Exception {
+    private void doInit() {
         this.queue = new LinkedBlockingQueue<>(1000);
 
         final Vertx vertx = Vertx.vertx();
@@ -100,11 +100,11 @@ 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);
-            throw new EventMeshException("Failed to start Vertx server");
+            log.error("[HttpSourceConnector] Failed to start Vertx server.");
+            throw new EventMeshException(t);
         }
     }
 
@@ -119,11 +119,11 @@ 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);
-            throw new EventMeshException("Failed to stop Vertx server");
+            log.error("[HttpSourceConnector] Failed to stop Vertx server.");
+            throw new EventMeshException(t);
         }
     }
 

diff --git a/eventmesh-connectors/eventmesh-connector-http/src/main/resources/source-config.yml b/eventmesh-connectors/eventmesh-connector-http/src/main/resources/source-config.yml
@@ -23,7 +23,7 @@ pubSubConfig:
     group: httpSource
     appId: 5032
     userName: httpSourceUser
-    passWord: httpmqPassWord
+    passWord: httpPassWord
 connectorConfig:
     connectorName: httpSource
     path: /test