Skip to content

Commit

Permalink
#705 格式化queueName
Browse files Browse the repository at this point in the history
  • Loading branch information
RolfHeG authored and rolf.he committed Jul 19, 2020
1 parent d0e60a8 commit d67331c
Showing 1 changed file with 1 addition and 0 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -561,6 +561,7 @@ protected void validateQueue(JobConfig jobConfig) throws SaturnJobConsoleExcepti
if (StringUtils.isBlank(jobConfig.getQueueName())) {
throw new SaturnJobConsoleException(ERROR_CODE_BAD_REQUEST, "对于消息作业,queue必填");
}
jobConfig.setQueueName(jobConfig.getQueueName().trim().replaceAll("\r\n", ""));
}

private void validateGroupsFieldOfJobConfig(JobConfig jobConfig) throws SaturnJobConsoleException {
Expand Down

0 comments on commit d67331c

Please sign in to comment.