add idleTimeout

Fungx · Dec 8, 2023 · a8dd5a3 · a8dd5a3
1 parent 7c34e8e
commit a8dd5a3
Show file tree

Hide file tree

Showing 3 changed files with 7 additions and 2 deletions.
diff --git a/...rc/main/java/org/apache/eventmesh/connector/http/source/config/SourceConnectorConfig.java b/...rc/main/java/org/apache/eventmesh/connector/http/source/config/SourceConnectorConfig.java
@@ -27,4 +27,6 @@ public class SourceConnectorConfig {
     private String path;
 
     private int port;
+
+    private int idleTimeout;
 }
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
@@ -91,7 +91,9 @@ private void doInit() throws Exception {
                     });
             });
         this.server = vertx.createHttpServer(new HttpServerOptions()
-            .setPort(this.sourceConfig.connectorConfig.getPort())).requestHandler(router);
+            .setPort(this.sourceConfig.connectorConfig.getPort())
+            .setIdleTimeout(this.sourceConfig.connectorConfig.getIdleTimeout())
+        ).requestHandler(router);
     }
 
     @Override

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
@@ -27,4 +27,5 @@ pubSubConfig:
 connectorConfig:
     connectorName: httpSource
     path: /test
-    port: 3755
+    port: 3755
+    idleTimeout: 5