fix(async):update unit tests

Author: jcanacon

async/async-commons-api/src/test/java/org/reactivecommons/async/api/HandlerRegistryTest.java

@@ -2,7 +2,6 @@
 
 import io.cloudevents.CloudEvent;
 import lombok.Data;
-import org.junit.jupiter.api.Assertions;
 import org.junit.jupiter.api.Test;
 import org.reactivecommons.api.domain.Command;
 import org.reactivecommons.api.domain.DomainEvent;
@@ -153,7 +152,7 @@ void handleDomainCommand() {
 
     @Test
     void handleCloudEventCommand() {
-        SomeCloudCommandHandler cloudCommandHandler = new SomeCloudCommandHandler();
+        SomeCloudEventCommandHandler cloudCommandHandler = new SomeCloudEventCommandHandler();
 
         registry.handleCloudEventCommand(name, cloudCommandHandler);
 
@@ -164,24 +163,15 @@ void handleCloudEventCommand() {
     }
 
     @Test
-    void handleCommandWithoutTypeShouldFail() {
-        Assertions.assertThrows(
-                RuntimeException.class,
-                () -> registry.handleCommand(name, (Command<SomeDataClass> message) -> Mono.empty()));
-    }
+    void shouldServerCloudEventQuery() {
+        SomeCloudEventQueryHandler queryHandler = new SomeCloudEventQueryHandler();
 
-    @Test
-    void listenEventWithoutTypeShouldFail() {
-        Assertions.assertThrows(
-                RuntimeException.class,
-                () -> registry.listenEvent(name, (DomainEvent<SomeDataClass> message) -> Mono.empty()));
-    }
+        registry.serveCloudEventQuery(name, queryHandler);
 
-    @Test
-    void handleQueryWithoutTypeShouldFail() {
-        Assertions.assertThrows(
-                RuntimeException.class,
-                () -> registry.serveQuery(name, (SomeDataClass query) -> Mono.empty()));
+        assertThat(registry.getHandlers())
+                .anySatisfy(registered -> assertThat(registered)
+                        .extracting(RegisteredQueryHandler::getPath, RegisteredQueryHandler::getQueryClass)
+                        .containsExactly(name, CloudEvent.class)).hasSize(1);
     }
 
     @Test
@@ -207,7 +197,7 @@ void serveQueryWithLambda() {
     @Test
     void serveQueryWithTypeInference() {
         QueryHandler<SomeDataClass, SomeDataClass> handler = new SomeQueryHandler();
-        registry.serveQuery(name, handler);
+        registry.serveQuery(name, handler,SomeDataClass.class);
         assertThat(registry.getHandlers()).anySatisfy(registered -> {
             assertThat(registered).extracting(RegisteredQueryHandler::getPath, RegisteredQueryHandler::getQueryClass)
                     .containsExactly(name, SomeDataClass.class);
@@ -262,7 +252,7 @@ public Mono<Void> handle(Command<SomeDataClass> message) {
         }
     }
 
-    private static class SomeCloudCommandHandler implements CloudCommandHandler {
+    private static class SomeCloudEventCommandHandler implements CloudCommandHandler {
         @Override
         public Mono<Void> handle(CloudEvent message) {
             return null;
@@ -276,6 +266,13 @@ public Mono<SomeDataClass> handle(SomeDataClass message) {
         }
     }
 
+    private static class SomeCloudEventQueryHandler implements QueryHandler<SomeDataClass, CloudEvent> {
+        @Override
+        public Mono<SomeDataClass> handle(CloudEvent message) {
+            return Mono.empty();
+        }
+    }
+
 
     @Data
     private static class SomeDataClass {

async/async-rabbit/src/test/java/org/reactivecommons/async/rabbit/ext/CustomReporterTest.java

@@ -1,10 +1,11 @@
-package org.reactivecommons.async.commons.ext;
+package org.reactivecommons.async.rabbit.ext;
 
 import org.junit.jupiter.api.Test;
 import org.reactivecommons.api.domain.Command;
 import org.reactivecommons.api.domain.DomainEvent;
 import org.reactivecommons.async.api.AsyncQuery;
 import org.reactivecommons.async.commons.communications.Message;
+import org.reactivecommons.async.commons.ext.CustomReporter;
 import reactor.core.publisher.Mono;
 import reactor.test.StepVerifier;
 import reactor.test.publisher.PublisherProbe;