GH-386 Fixed NPE for non-existing functions invoked as REST endpoints

Resolves #386
This commit is contained in:
Oleg Zhurakousky
2019-07-09 16:35:06 +02:00
parent 3ae9d0523d
commit 70d46f8b9f
2 changed files with 17 additions and 1 deletions

View File

@@ -233,7 +233,11 @@ public class RequestProcessor {
}
Mono<ResponseEntity<?>> responseEntityMono = null;
if (function instanceof FluxedConsumer || function instanceof FluxConsumer) {
if (function == null) {
responseEntityMono = Mono.just(ResponseEntity.status(HttpStatus.NOT_FOUND)
.body("Function for provided path can not be found"));
}
else if (function instanceof FluxedConsumer || function instanceof FluxConsumer) {
((Mono<?>) function.apply(flux)).subscribe();
logger.debug("Handled POST with consumer");
responseEntityMono = Mono