From efdb99f8cecc4afb592afad79c761081d5d5cf22 Mon Sep 17 00:00:00 2001
From: lee <4766465@qq.com>
Date: Wed, 18 Dec 2024 13:27:00 +0800
Subject: [PATCH] init
---
xxl-job/xxl-job-admin/src/test/java/com/xxl/job/executorbiz/ExecutorBizTest.java | 105 ++++++++++++++++++++++++++++++++++++++++++++++++++++
1 files changed, 105 insertions(+), 0 deletions(-)
diff --git a/xxl-job/xxl-job-admin/src/test/java/com/xxl/job/executorbiz/ExecutorBizTest.java b/xxl-job/xxl-job-admin/src/test/java/com/xxl/job/executorbiz/ExecutorBizTest.java
new file mode 100644
index 0000000..4facb89
--- /dev/null
+++ b/xxl-job/xxl-job-admin/src/test/java/com/xxl/job/executorbiz/ExecutorBizTest.java
@@ -0,0 +1,105 @@
+package com.xxl.job.executorbiz;
+
+import com.xxl.job.core.biz.ExecutorBiz;
+import com.xxl.job.core.biz.client.ExecutorBizClient;
+import com.xxl.job.core.biz.model.*;
+import com.xxl.job.core.enums.ExecutorBlockStrategyEnum;
+import com.xxl.job.core.glue.GlueTypeEnum;
+import org.junit.jupiter.api.Assertions;
+import org.junit.jupiter.api.Test;
+
+/**
+ * executor api test
+ *
+ * Created by xuxueli on 17/5/12.
+ */
+public class ExecutorBizTest {
+
+ // admin-client
+ private static String addressUrl = "http://127.0.0.1:9999/";
+ private static String accessToken = null;
+
+ @Test
+ public void beat() throws Exception {
+ ExecutorBiz executorBiz = new ExecutorBizClient(addressUrl, accessToken);
+ // Act
+ final ReturnT<String> retval = executorBiz.beat();
+
+ // Assert result
+ Assertions.assertNotNull(retval);
+ Assertions.assertNull(((ReturnT<String>) retval).getContent());
+ Assertions.assertEquals(200, retval.getCode());
+ Assertions.assertNull(retval.getMsg());
+ }
+
+ @Test
+ public void idleBeat(){
+ ExecutorBiz executorBiz = new ExecutorBizClient(addressUrl, accessToken);
+
+ final int jobId = 0;
+
+ // Act
+ final ReturnT<String> retval = executorBiz.idleBeat(new IdleBeatParam(jobId));
+
+ // Assert result
+ Assertions.assertNotNull(retval);
+ Assertions.assertNull(((ReturnT<String>) retval).getContent());
+ Assertions.assertEquals(500, retval.getCode());
+ Assertions.assertEquals("job thread is running or has trigger queue.", retval.getMsg());
+ }
+
+ @Test
+ public void run(){
+ ExecutorBiz executorBiz = new ExecutorBizClient(addressUrl, accessToken);
+
+ // trigger data
+ final TriggerParam triggerParam = new TriggerParam();
+ triggerParam.setJobId(1);
+ triggerParam.setExecutorHandler("demoJobHandler");
+ triggerParam.setExecutorParams(null);
+ triggerParam.setExecutorBlockStrategy(ExecutorBlockStrategyEnum.COVER_EARLY.name());
+ triggerParam.setGlueType(GlueTypeEnum.BEAN.name());
+ triggerParam.setGlueSource(null);
+ triggerParam.setGlueUpdatetime(System.currentTimeMillis());
+ triggerParam.setLogId(1);
+ triggerParam.setLogDateTime(System.currentTimeMillis());
+
+ // Act
+ final ReturnT<String> retval = executorBiz.run(triggerParam);
+
+ // Assert result
+ Assertions.assertNotNull(retval);
+ }
+
+ @Test
+ public void kill(){
+ ExecutorBiz executorBiz = new ExecutorBizClient(addressUrl, accessToken);
+
+ final int jobId = 0;
+
+ // Act
+ final ReturnT<String> retval = executorBiz.kill(new KillParam(jobId));
+
+ // Assert result
+ Assertions.assertNotNull(retval);
+ Assertions.assertNull(((ReturnT<String>) retval).getContent());
+ Assertions.assertEquals(200, retval.getCode());
+ Assertions.assertNull(retval.getMsg());
+ }
+
+ @Test
+ public void log(){
+ ExecutorBiz executorBiz = new ExecutorBizClient(addressUrl, accessToken);
+
+ final long logDateTim = 0L;
+ final long logId = 0;
+ final int fromLineNum = 0;
+
+ // Act
+ final ReturnT<LogResult> retval = executorBiz.log(new LogParam(logDateTim, logId, fromLineNum));
+
+ // Assert result
+ Assertions.assertNotNull(retval);
+ }
+
+}
--
Gitblit v1.9.3