add dynamic query handler delegate

Author: juancgalvis

async/async-commons-api/src/main/java/org/reactivecommons/async/api/DynamicRegistry.java

@@ -2,6 +2,7 @@
 
 import org.reactivecommons.async.api.handlers.EventHandler;
 import org.reactivecommons.async.api.handlers.QueryHandler;
+import org.reactivecommons.async.api.handlers.QueryHandlerDelegate;
 import reactor.core.publisher.Mono;
 
 public interface DynamicRegistry {
@@ -11,6 +12,8 @@ public interface DynamicRegistry {
 
     <T, R> void serveQuery(String resource, QueryHandler<T, R> handler, Class<R> queryClass);
 
+    <R> void serveQuery(String resource, QueryHandlerDelegate<Void, R> handler, Class<R> queryClass);
+
     Mono<Void> startListeningEvent(String eventName);
 
     Mono<Void> stopListeningEvent(String eventName);

async/async-rabbit/src/main/java/org/reactivecommons/async/rabbit/DynamicRegistryImp.java

@@ -5,6 +5,7 @@
 import org.reactivecommons.async.api.DynamicRegistry;
 import org.reactivecommons.async.api.handlers.EventHandler;
 import org.reactivecommons.async.api.handlers.QueryHandler;
+import org.reactivecommons.async.api.handlers.QueryHandlerDelegate;
 import org.reactivecommons.async.api.handlers.registered.RegisteredEventListener;
 import org.reactivecommons.async.api.handlers.registered.RegisteredQueryHandler;
 import org.reactivecommons.async.commons.config.IBrokerConfigProps;
@@ -33,6 +34,11 @@ public <T, R> void serveQuery(String resource, QueryHandler<T, R> handler, Class
         resolver.addQueryHandler(new RegisteredQueryHandler<>(resource, (ignored, message) -> handler.handle(message), queryClass));
     }
 
+    @Override
+    public <R> void serveQuery(String resource, QueryHandlerDelegate<Void, R> handler, Class<R> queryClass) {
+        resolver.addQueryHandler(new RegisteredQueryHandler<>(resource, handler, queryClass));
+    }
+
     @Override
     public Mono<Void> startListeningEvent(String eventName) {
         return topologyCreator.bind(buildBindingSpecification(eventName))