#532 fix ut

vipshop · Nov 8, 2018 · 7c46166 · 7c46166
1 parent 7a98859
commit 7c46166
Showing 1 changed file with 7 additions and 0 deletions.
diff --git a/...console-api/src/test/java/com/vip/saturn/job/console/service/impl/JobServiceImplTest.java b/...console-api/src/test/java/com/vip/saturn/job/console/service/impl/JobServiceImplTest.java
@@ -660,6 +660,7 @@ public void testAddJobFailByLocalModeJobHasDownStream() throws SaturnJobConsoleE
 		JobConfig jobConfig = new JobConfig();
 		jobConfig.setJobName(jobName);
 		jobConfig.setJobType(JobType.MSG_JOB.name());
+		jobConfig.setQueueName("queue");
 		jobConfig.setJobClass("testCLass");
 		jobConfig.setLocalMode(true);
 		jobConfig.setShardingItemParameters("*=xx");
@@ -674,6 +675,7 @@ public void testAddJobFailByHasDownStreamButShardingTotalCountIsNotOne() throws
 		JobConfig jobConfig = new JobConfig();
 		jobConfig.setJobName(jobName);
 		jobConfig.setJobType(JobType.MSG_JOB.name());
+		jobConfig.setQueueName("queue");
 		jobConfig.setJobClass("testCLass");
 		jobConfig.setShardingTotalCount(2);
 		jobConfig.setShardingItemParameters("0=0,1=1");
@@ -688,6 +690,7 @@ public void testAddJobFailByHasDownStreamButIsSelf() throws SaturnJobConsoleExce
 		JobConfig jobConfig = new JobConfig();
 		jobConfig.setJobName(jobName);
 		jobConfig.setJobType(JobType.MSG_JOB.name());
+		jobConfig.setQueueName("queue");
 		jobConfig.setJobClass("testCLass");
 		jobConfig.setShardingTotalCount(1);
 		jobConfig.setShardingItemParameters("0=0");
@@ -702,6 +705,7 @@ public void testAddJobFailByHasDownStreamButNotExisting() throws SaturnJobConsol
 		JobConfig jobConfig = new JobConfig();
 		jobConfig.setJobName(jobName);
 		jobConfig.setJobType(JobType.MSG_JOB.name());
+		jobConfig.setQueueName("queue");
 		jobConfig.setJobClass("testCLass");
 		jobConfig.setShardingTotalCount(1);
 		jobConfig.setShardingItemParameters("0=0");
@@ -716,6 +720,7 @@ public void testAddJobFailByHasDownStreamButIsAncestor() throws SaturnJobConsole
 		JobConfig jobConfig = new JobConfig();
 		jobConfig.setJobName(jobName);
 		jobConfig.setJobType(JobType.MSG_JOB.name());
+		jobConfig.setQueueName("queue");
 		jobConfig.setJobClass("testCLass");
 		jobConfig.setShardingTotalCount(1);
 		jobConfig.setShardingItemParameters("0=0");
@@ -734,6 +739,7 @@ public void testAddJobFailByHasDownStreamButIsNotPassive() throws SaturnJobConso
 		JobConfig jobConfig = new JobConfig();
 		jobConfig.setJobName(jobName);
 		jobConfig.setJobType(JobType.MSG_JOB.name());
+		jobConfig.setQueueName("queue");
 		jobConfig.setJobClass("testCLass");
 		jobConfig.setShardingTotalCount(1);
 		jobConfig.setShardingItemParameters("0=0");
@@ -751,6 +757,7 @@ public void testAddJobFailByHasDownStreamButIsAncestor2() throws SaturnJobConsol
 		JobConfig jobConfig = new JobConfig();
 		jobConfig.setJobName(jobName);
 		jobConfig.setJobType(JobType.MSG_JOB.name());
+		jobConfig.setQueueName("queue");
 		jobConfig.setJobClass("testCLass");
 		jobConfig.setShardingTotalCount(1);
 		jobConfig.setShardingItemParameters("0=0");