我是新来的春天数据反应卡桑德拉。在我服务类我正在对注射执行ReactiveCassandraRepository的返回我的POJO的单声道,如果它被赋予的ID找到它。
public Mono<MyPojo> getResult(String id) {
return myRepository.findById(id)
.flatMap(result -> result!=null ? getDecision(result) :
Mono.error(new Exception("result not found for id: "+id)));
}
private Mono<? extends MyPojo> getDecision(MyPojoDto result) {
if(result.getRecommendation()==0) {
return Mono.just(MyPojo.builder().result("Accept").build());
}
else
{
return Mono.just(MyPojo.builder().result("Reject").build());
}
}
当资源库找到给定ID的记录上面的代码工作正常。但是,如果没有找到记录,然后我不知道发生了什么。我没有收到返回的任何异常任何日志。
上述的getResult方法由我的弹簧控制器调用。但我不知道如何在我的控制器处理,这样我可以把我的消费者相关回应。
下面给出的是我的控制器代码。
@RequestMapping(value = “/check/order/{id}", method = RequestMethod.GET, produces = MediaType.APPLICATION_JSON_UTF8_VALUE)
public Mono<ResponseEntity<MyPojo>> getResult(
@PathVariable(“id") id id) {
return myService.getResult(id)
.flatMap(result -> result!=null ?
getCustomResponse(id, result,HttpStatus.OK) :
getCustomResponse(id,result, HttpStatus.INTERNAL_SERVER_ERROR));
}
我们如何在调用方法处理Mono.error()。
问候,
Vinoth
看起来像你的资料库返回空Mono
当它不能找到任何记录。
你可以改变你getResult
方法:
return myRepository.findById(id)
.flatMap(result -> getDecision(result))
.switchIfEmpty(Mono.error(new Exception("result not found for id: " + id)));
或者更好的,你可以改变你的控制,如果你不希望创建任何异常的实例:
return myService.getResult(id)
.flatMap(result -> getCustomResponse(id, result, HttpStatus.OK))
.switchIfEmpty(getCustomResponse(id, result, HttpStatus.NOT_FOUND));