[e2eTest] add e2eTest model
diff --git a/pom.xml b/pom.xml
index b60d031..7854332 100644
--- a/pom.xml
+++ b/pom.xml
@@ -105,6 +105,9 @@
<module>domain</module>
<module>common</module>
<module>infrastructure</module>
+ <module>supports/connect-eventbridge-transform</module>
+ <module>supports/connect-filter-transform</module>
+ <module>supports/eventbridge-connect-file</module>
<module>test</module>
<module>dist</module>
</modules>
diff --git a/test/rocketmq-eventbridge-e2etest/pom.xml b/test/rocketmq-eventbridge-e2etest/pom.xml
index ac82308..e5abdb9 100644
--- a/test/rocketmq-eventbridge-e2etest/pom.xml
+++ b/test/rocketmq-eventbridge-e2etest/pom.xml
@@ -44,6 +44,26 @@
</exclusion>
</exclusions>
</dependency>
+ <dependency>
+ <groupId>org.apache.rocketmq</groupId>
+ <artifactId>connect-eventbridge-transform</artifactId>
+ <version>1.0.0-SNAPSHOT</version>
+ </dependency>
+ <dependency>
+ <groupId>org.apache.rocketmq</groupId>
+ <artifactId>connect-eventbridge-transform</artifactId>
+ <version>1.0.0-SNAPSHOT</version>
+ </dependency>
+ <dependency>
+ <groupId>org.apache.rocketmq</groupId>
+ <artifactId>connect-filter-transform</artifactId>
+ <version>1.0.0-SNAPSHOT</version>
+ </dependency>
+ <dependency>
+ <groupId>org.apache.rocketmq</groupId>
+ <artifactId>eventbridge-connect-file</artifactId>
+ <version>1.0.0-SNAPSHOT</version>
+ </dependency>
</dependencies>
</project>
\ No newline at end of file
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 bac500b..7998783 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
@@ -2,6 +2,7 @@
import lombok.extern.slf4j.Slf4j;
import org.apache.commons.io.FileUtils;
+import org.apache.commons.lang3.StringUtils;
import org.apache.rocketmq.eventbridge.Main;
import org.apache.rocketmq.eventbridge.e2etest.BaseTest;
import org.apache.rocketmq.eventbridge.e2etest.util.Utils;
@@ -39,19 +40,18 @@
ResponseEntity<Void> response = Utils.request(template, url, HttpMethod.POST, "A test recrod.", Void.class, headers);
Assert.assertTrue(response.getStatusCode().is2xxSuccessful());
-
File file = new File(System.getProperty("user.home") + "/demo");
String data = null;
- long current = System.currentTimeMillis();
- while((System.currentTimeMillis() - current)/1000 <300 ) {
+ int retries = 0;
+ while( retries < 10 ) {
data = FileUtils.readFileToString(file, "UTF-8");
- if (data != null) {
+ if (StringUtils.isNotBlank(data)) {
+ Assert.assertEquals("A test recrod.\n", data);
break;
}
- Thread.sleep(1000);
+ Thread.sleep(50000);
+ retries++;
}
-
- Assert.assertEquals("A test recrod.\n", data);
}
