This is an automated email from the ASF dual-hosted git repository. shenlin pushed a commit to branch main in repository https://gitbox.apache.org/repos/asf/rocketmq-eventbridge.git
commit 2cd50065578990ea8e17409d8f49373dd560044e Author: wangkai <wang...@zhongan.com> AuthorDate: Fri Nov 3 15:17:09 2023 +0800 [e2eTest] add e2eTest model --- .../src/main/java/org/apache/rocketmq/eventbridge/demo/DefaultDemo.java | 2 +- .../eventbridge/e2etest/controller/ApplicationTagControllerTest.java | 2 +- 2 files changed, 2 insertions(+), 2 deletions(-) diff --git a/test/demo/src/main/java/org/apache/rocketmq/eventbridge/demo/DefaultDemo.java b/test/demo/src/main/java/org/apache/rocketmq/eventbridge/demo/DefaultDemo.java index d9e2b37..f807f12 100644 --- a/test/demo/src/main/java/org/apache/rocketmq/eventbridge/demo/DefaultDemo.java +++ b/test/demo/src/main/java/org/apache/rocketmq/eventbridge/demo/DefaultDemo.java @@ -94,7 +94,7 @@ public class DefaultDemo { if (eventTargets == null || eventTargets.isEmpty()) { List<EventTarget> eventTargetList = Lists.newArrayList(); Map<String, Object> config = Maps.newHashMap(); - config.put("fileName", "/home/runner/demo"); + config.put("fileName", System.getProperty("user.home")+"/demo"); config.put("line", "{\"form\":\"JSONPATH\",\"value\":\"$.data\"}"); EventTarget eventTarget = EventTarget.builder().name(DEFAULT_EVENT_TARGET_NAME).className(DEFAULT_EVENT_TARGET_CLASS).config(config).build(); eventTargetList.add(eventTarget); diff --git a/test/rocketmq-eventbridge-e2etest/src/test/java/org/apache/rocketmq/eventbridge/e2etest/controller/ApplicationTagControllerTest.java b/test/rocketmq-eventbridge-e2etest/src/test/java/org/apache/rocketmq/eventbridge/e2etest/controller/ApplicationTagControllerTest.java index 562e4cd..e7b743a 100644 --- a/test/rocketmq-eventbridge-e2etest/src/test/java/org/apache/rocketmq/eventbridge/e2etest/controller/ApplicationTagControllerTest.java +++ b/test/rocketmq-eventbridge-e2etest/src/test/java/org/apache/rocketmq/eventbridge/e2etest/controller/ApplicationTagControllerTest.java @@ -48,7 +48,7 @@ public class ApplicationTagControllerTest extends BaseTest { if (StringUtils.isNotBlank(data)) { break; } - Thread.sleep(5000); + Thread.sleep(50000); retries++; } Assert.assertEquals("A test recrod.\n", data);