如何从spring batch processor process（）方法抛出异常到spring batch job started方法？
我使用Web服务方法启动spring batch Job，如果spring batch过程中出现任何异常，控制将返回到processor process方法。但是我需要控制器返回到Web服务方法，在那里我必须捕捉并编写代码以电子邮件发送异常。
public void processInputFiles() throws ServiceFault {
String[] springConfig = { CONTEXT_FILE_NAME };
ApplicationContext context = new ClassPathXmlApplicationContext(springConfig);
try {
setClientInfo();
JobLauncher jobLauncher = (JobLauncher) context.getBean(JOB_LAUNCHER);
Job job = (Job) context.getBean(REMITTANCE_JOB);
jobLauncher.run(job, new JobParameters());
}catch (Exception e) {
String errorMessage = "LockboxService exception:: Could not process Remittance(CSV) files";
final Message message = MessageFactory.createErrorMessage(MyService.class, errorMessage, e);
ErrorSenderFactory.getInstance().send(message, new Instruction[] { Instruction.ERROR_EMAIL });
}
@Override
public Transmission process(InputDetail remrow) throws ServiceException {
try {
business logic here
}
catch(Exception e) {
throw new Exception("Unable to process row having the int number:");
}
}
共有1个答案
这里是startJob，我用它来启动web应用程序中的作业，Tye来抛出特定的异常
public boolean StartJob()
throws MyException{
try {
final JobParameters jobParameters = new JobParametersBuilder()
.addLong("time", System.nanoTime())
.addString("file", jobInputFolder.getAbsolutePath())
.toJobParameters();
final JobExecution execution = jobLauncher.run(job,
jobParameters);
final ExitStatus status = execution.getExitStatus();
if (ExitStatus.COMPLETED.getExitCode().equals(
status.getExitCode())) {
result = true;
} else {
final List<Throwable> exceptions = execution
.getAllFailureExceptions();
for (final Throwable throwable : exceptions) {
if (throwable instanceof MyException) {
throw (MyException) throwable;
}
if (throwable instanceof FlatFileParseException) {
Throwable rootException = throwable.getCause();
if (rootException instanceof IncorrectTokenCountException) {
throw new MyException(logMessage, errorCode);
}
if (rootException instanceof BindException) {
BindException bindException = (BindException) rootException;
final FieldError fieldError = bindException
.getFieldError();
final String field = fieldError.getField();
throw new MyException(logMessage, errorCode);
}
}
}
}
}
} catch (JobExecutionAlreadyRunningException ex) {
} catch (JobRestartException ex) {
} catch (JobInstanceAlreadyCompleteException ex) {
} catch (JobParametersInvalidException ex) {
} catch (IOException ex) {
} finally {
}
return result;
}
如果项目处理器如下所示
@Override
public KPData process(InputDetail inputData) throws MyException {
try {
business logic here
}
catch(Exception e) {
throw new MyException("Some issue");
}
}
-
我有一个类，它有一个方法。我正在做相应的测试，但是我还不能验证是否抛出了定制的异常，我使用的是JUnit5。 我已经复习了这里，但答案并没有帮助我，这是我根据一个示例编写的代码：
-
问题内容： 我有这样的方法： 我想抛出一个内。编译器不允许我这样做，因为不允许将我的方法扔在那里。但是我需要抛出一个的子类来进行测试 （我不能抛出Unchecked）。显然这是一个hack，但我需要进行测试。我尝试过EasyMock，但它也不允许我这样做。任何想法如何做到这一点？ 谢谢，肖恩·阮 问题答案： 方法1： Alexey Ragozin的这篇文章介绍了如何使用泛型技巧引发未声明的检查异常
-
上一节展示了如何为ListOfNumbers类中的writeList方法编写异常处理程序。 有时，它适合代码捕获可能发生在其中的异常。 但在其他情况下，最好让一个方法进一步推给上层来调用堆栈处理异常。 例如，如果您将ListOfNumbers类提供为类包的一部分，则可能无法预期包的所有用户的需求。 在这种情况下，最好不要捕获异常，并允许一个方法进一步推给上层来调用堆栈来处理它。 如果writeLi
-
在你可以捕获异常之前，一些代码必须抛出一个异常。任何代码都可能会抛出异常：您的代码，来自其他人编写的包（例如Java平台附带的包）或Java运行时环境的代码。无论是什么引发的异常，它总是通过 throw 语句抛出。 您可能已经注意到，Java平台提供了许多异常类。所有类都是Throwable类的后代，并且都允许程序区分在程序执行期间可能发生的各种类型的异常。 您还可以创建自己的异常类来表示在您编写
-
假设我有一个类和一个方法 现在，我想为由流传递的的每个实例调用foo，如下所示： 问题：如何正确处理异常？代码在我的机器上没有编译，因为我没有处理foo（）可能引发的异常。的在这里似乎没有用。这是为什么？