Skip to content

Commit 6e5d08b

Browse files
author
Daniel Bustamante Ospina
committed
Prevent ClassCastException and add proper message when query handler is not registered
Fixes: gh-3
1 parent 72ae3d3 commit 6e5d08b

File tree

1 file changed

+3
-0
lines changed

1 file changed

+3
-0
lines changed

async/async-commons/src/main/java/org/reactivecommons/async/impl/listeners/ApplicationQueryListener.java

Lines changed: 3 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -51,6 +51,9 @@ public ApplicationQueryListener(ReactiveMessageListener listener, String queueNa
5151
@Override
5252
protected Function<Message, Mono<Object>> rawMessageHandler(String executorPath) {
5353
final RegisteredQueryHandler<Object, Object> handler1 = handlerResolver.getQueryHandler(executorPath);
54+
if (handler1 == null) {
55+
return message -> Mono.error(new RuntimeException("Handler Not registered for Query: " + executorPath));
56+
}
5457
final Class<?> handlerClass = (Class<?>) handler1.getQueryClass();
5558
Function<Message, Object> messageConverter = msj -> converter.readAsyncQuery(msj, handlerClass).getQueryData();
5659
final QueryExecutor executor = new QueryExecutor(handler1.getHandler(), messageConverter);

0 commit comments

Comments
 (0)