public/liteFlow
1
0
Fork 0
mirror of https://gitee.com/dromara/liteFlow.git synced 2026-05-23 23:18:12 +08:00
Code Issues Packages Projects Releases Wiki Activity

新增部分单元测试

Browse Source
This commit is contained in:
zendwang
2021-04-07 06:08:27 +08:00
parent 0aec022ad8
commit cd16006b20
2 changed files with 40 additions and 6 deletions
Download Patch File Download Diff File Expand all files Collapse all files

23
liteflow-spring-boot-starter/src/test/java/com/yomahub/liteflow/test/config/LiteflowConfigNoSpringTest.java
View File

@@ -1,9 +1,12 @@
package com.yomahub.liteflow.test.config;
import com.yomahub.liteflow.core.FlowExecutor;
import com.yomahub.liteflow.entity.data.LiteflowResponse;
import com.yomahub.liteflow.entity.data.Slot;
import com.yomahub.liteflow.exception.ConfigErrorException;
import com.yomahub.liteflow.property.LiteflowConfig;
import com.yomahub.liteflow.test.BaseTest;
import org.junit.Assert;
import org.junit.Test;
/**
@@ -19,14 +22,22 @@ public class LiteflowConfigNoSpringTest extends BaseTest {
executor.init();
}
@Test(expected = ConfigErrorException.class)
public void testConfigError() throws Exception {
LiteflowConfig liteflowConfig = new LiteflowConfig();
liteflowConfig.setRuleSource("json:127.0.0.1:2181:/");
@Test
public void testConfig() throws Exception {
FlowExecutor executor = new FlowExecutor();
executor.setLiteflowConfig(liteflowConfig);
LiteflowConfig config = new LiteflowConfig();
config.setRuleSource("config/flow.json");
executor.setLiteflowConfig(config);
executor.init();
LiteflowResponse<Slot> response = executor.execute("chain1", "arg");
Assert.assertTrue(response.isSuccess());
Assert.assertEquals(15, config.getWhenMaxWaitSeconds().intValue());
Assert.assertEquals(200, config.getQueueLimit().intValue());
Assert.assertEquals(300000L, config.getDelay().longValue());
Assert.assertEquals(300000L, config.getPeriod().longValue());
Assert.assertFalse(config.getEnableLog());
Assert.assertEquals(Runtime.getRuntime().availableProcessors() * 2, config.getWhenMaxWorkers().longValue());
Assert.assertEquals(512, config.getWhenQueueLimit().longValue());
}
}

23
liteflow-spring-boot-starter/src/test/resources/config/application-local.xml Normal file
View File

@@ -0,0 +1,23 @@
<?xml version="1.0" encoding="UTF-8"?>
<beans xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
xmlns="http://www.springframework.org/schema/beans"
xmlns:context="http://www.springframework.org/schema/context"
xsi:schemaLocation="http://www.springframework.org/schema/beans
http://www.springframework.org/schema/beans/spring-beans-4.0.xsd
http://www.springframework.org/schema/context
http://www.springframework.org/schema/context/spring-context-4.0.xsd">
<context:component-scan base-package="com.yomahub.liteflow.test.config.cmp" />
<bean id="springAware" class="com.yomahub.liteflow.util.SpringAware"/>
<bean class="com.yomahub.liteflow.spring.ComponentScanner"/>
<bean id="liteflowConfig" class="com.yomahub.liteflow.property.LiteflowConfig">
<property name="ruleSource" value="config/flow.json"/>
</bean>
<bean id="flowExecutor" class="com.yomahub.liteflow.core.FlowExecutor">
<property name="liteflowConfig" ref="liteflowConfig"/>
</bean>
</beans>