refactor: 设置资源池,校验资源池修改
This commit is contained in:
parent
21b4d9c568
commit
fc660b6c2c
|
@ -6,6 +6,7 @@ import io.metersphere.base.domain.TestResource;
|
|||
import io.metersphere.commons.constants.ResourceStatusEnum;
|
||||
import io.metersphere.commons.exception.MSException;
|
||||
import io.metersphere.commons.utils.CommonBeanFactory;
|
||||
import io.metersphere.config.JmeterProperties;
|
||||
import io.metersphere.config.KafkaProperties;
|
||||
import io.metersphere.controller.ResultHolder;
|
||||
import io.metersphere.dto.BaseSystemConfigDTO;
|
||||
|
@ -70,6 +71,7 @@ public class DockerTestEngine extends AbstractEngine {
|
|||
|
||||
BaseSystemConfigDTO baseInfo = CommonBeanFactory.getBean(SystemParameterService.class).getBaseInfo();
|
||||
KafkaProperties kafkaProperties = CommonBeanFactory.getBean(KafkaProperties.class);
|
||||
JmeterProperties jmeterProperties = CommonBeanFactory.getBean(JmeterProperties.class);
|
||||
String metersphereUrl = "http://localhost:8081";
|
||||
if (baseInfo != null) {
|
||||
metersphereUrl = baseInfo.getUrl();
|
||||
|
@ -86,6 +88,7 @@ public class DockerTestEngine extends AbstractEngine {
|
|||
env.put("LOG_TOPIC", kafkaProperties.getLog().getTopic());
|
||||
env.put("RESOURCE_ID", resource.getId());
|
||||
env.put("THREAD_NUM", "" + threadNum);
|
||||
env.put("HEAP", jmeterProperties.getHeap());
|
||||
|
||||
|
||||
StartTestRequest startTestRequest = new StartTestRequest();
|
||||
|
|
|
@ -1 +1 @@
|
|||
Subproject commit fece9598da37b1737ca285d41f1f517c70035246
|
||||
Subproject commit 6269b43749e4f6485be5429350c1e3101b2c53cf
|
Loading…
Reference in New Issue