content: 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.Assert;
  import org.junit.Test;
  
  /**
   * executor api test
   * <p>
   * Created by xuxueli on 17/5/12.
   */
  public class ExecutorBizTest {
  
      // admin-client
      private static String addressUrl = "http://128.14.163.18:9999/";
      private static String accessToken = "member";
  
      @Test
      public void beat() throws Exception {
          ExecutorBiz executorBiz = new ExecutorBizClient(addressUrl, accessToken);
          // Act
          final ReturnT<String> retval = executorBiz.beat();
  
          // Assert result
          Assert.assertNotNull(retval);
          Assert.assertNull(((ReturnT<String>) retval).getContent());
          Assert.assertEquals(200, retval.getCode());
          Assert.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
          Assert.assertNotNull(retval);
          Assert.assertNull(((ReturnT<String>) retval).getContent());
          Assert.assertEquals(500, retval.getCode());
          Assert.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
          Assert.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
          Assert.assertNotNull(retval);
          Assert.assertNull(((ReturnT<String>) retval).getContent());
          Assert.assertEquals(200, retval.getCode());
          Assert.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
          Assert.assertNotNull(retval);
      }
  
  }
  