Query delegate API

Author: Daniel Bustamante Ospina

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

@@ -6,4 +6,5 @@
 public interface DirectAsyncGateway {
     <T> Mono<Void> sendCommand(Command<T> command, String targetName);
     <T, R> Mono<R> requestReply(AsyncQuery<T> query, String targetName, Class<R> type);
+    <T> Mono<Void> reply(T response, From from);
 }

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

@@ -0,0 +1,7 @@
+package org.reactivecommons.async.api;
+
+public class From {
+    //String getCorrelationID();
+    //String getReplyID();
+    ///...
+}

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

@@ -6,6 +6,7 @@
 import org.reactivecommons.async.api.handlers.CommandHandler;
 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.RegisteredCommandHandler;
 import org.reactivecommons.async.api.handlers.registered.RegisteredEventListener;
 import org.reactivecommons.async.api.handlers.registered.RegisteredQueryHandler;
@@ -61,6 +62,11 @@ public <T, R> HandlerRegistry serveQuery(String resource, QueryHandler<T, R> han
         return this;
     }
 
+    public <T, R> HandlerRegistry serveQuery(String resource, QueryHandlerDelegate<R> handler, Class<R> queryClass){
+        //handlers.add(new RegisteredQueryHandler<>(resource, handler, queryClass));
+        return this;
+    }
+
 
     @SuppressWarnings("unchecked")
     private <T, R> Class<R> inferGenericParameterType(QueryHandler<T, R> handler){

async/async-commons-api/src/main/java/org/reactivecommons/async/api/handlers/QueryHandlerDelegate.java

@@ -0,0 +1,8 @@
+package org.reactivecommons.async.api.handlers;
+
+import org.reactivecommons.async.api.From;
+import reactor.core.publisher.Mono;
+
+public interface QueryHandlerDelegate<M> {
+    Mono<Void> handle(From from, M message);
+}