| commit | 8804deb0506503c756643d77565ed743c9bef49c | [log] [tgz] |
|---|---|---|
| author | xwm1992 <mike_xwm@126.com> | Mon Jul 01 19:28:26 2024 +0800 |
| committer | xwm1992 <mike_xwm@126.com> | Mon Jul 01 19:28:26 2024 +0800 |
| tree | 7cc32a36a4de817ee80a51a775a2c011a8efbe2e | |
| parent | e91ae105d44d750f5f0e7b595686cfc68ec8c5e4 [diff] |
fix http source connector test error
diff --git a/eventmesh-connectors/eventmesh-connector-http/src/test/java/org/apache/eventmesh/connector/http/source/connector/HttpSourceConnectorTest.java b/eventmesh-connectors/eventmesh-connector-http/src/test/java/org/apache/eventmesh/connector/http/source/connector/HttpSourceConnectorTest.java index b764b4a..b4cad14 100644 --- a/eventmesh-connectors/eventmesh-connector-http/src/test/java/org/apache/eventmesh/connector/http/source/connector/HttpSourceConnectorTest.java +++ b/eventmesh-connectors/eventmesh-connector-http/src/test/java/org/apache/eventmesh/connector/http/source/connector/HttpSourceConnectorTest.java
@@ -57,6 +57,9 @@ connector.init(sourceConfig); connector.start(); + // Add delay to ensure the server is fully started before the tests begin + Thread.sleep(2000); + url = new URL("http", "127.0.0.1", config.getPort(), config.getPath()).toString(); httpClient = new OkHttpClient(); }