test: application reply listener

Author: juanmarin-co

acceptance/async-tests/src/test/java/org/reactivecommons/test/CommandsProcessPerfTest.java

@@ -39,7 +39,7 @@ public class CommandsProcessPerfTest {
 
 
     @Test
-    public void commandShouldArrive() throws InterruptedException {
+    void commandShouldArrive() throws InterruptedException {
         final long init_p = System.currentTimeMillis();
         createMessages(messageCount);
         final long end_p = System.currentTimeMillis() - init_p;

acceptance/async-tests/src/test/java/org/reactivecommons/test/DirectGatewayPerfTest.java

@@ -35,7 +35,7 @@ public class DirectGatewayPerfTest {
 
 
     @Test
-    public void shouldSendInOptimalTime() throws InterruptedException {
+    void shouldSendInOptimalTime() throws InterruptedException {
         final Flux<Command<DummyMessage>> messages = createMessages(messageCount);
         final Flux<Void> target = messages.flatMap(dummyMessageCommand ->
                 gateway.sendCommand(dummyMessageCommand, appName)
@@ -50,17 +50,17 @@ public void shouldSendInOptimalTime() throws InterruptedException {
     }
 
     @Test
-    public void shouldSendBatchInOptimalTime4Channels() throws InterruptedException {
+    void shouldSendBatchInOptimalTime4Channels() throws InterruptedException {
         shouldSendBatchInOptimalTimeNChannels(4);
     }
 
     @Test
-    public void shouldSendBatchInOptimalTime2Channels() throws InterruptedException {
+    void shouldSendBatchInOptimalTime2Channels() throws InterruptedException {
         shouldSendBatchInOptimalTimeNChannels(2);
     }
 
     @Test
-    public void shouldSendBatchInOptimalTime1Channel() throws InterruptedException {
+    void shouldSendBatchInOptimalTime1Channel() throws InterruptedException {
         shouldSendBatchInOptimalTimeNChannels(1);
     }
 

acceptance/async-tests/src/test/java/org/reactivecommons/test/DynamicRegistryTest.java

@@ -34,7 +34,7 @@ public class DynamicRegistryTest {
     private String appName;
 
     @Test
-    public void shouldReceiveResponse() {
+    void shouldReceiveResponse() {
         UnicastProcessor<String> result = UnicastProcessor.create();
         EventHandler<String> fn = message -> fromRunnable(() -> result.onNext(message.getData()));
 

acceptance/async-tests/src/test/java/org/reactivecommons/test/QueryProcessPerfTest.java

@@ -43,7 +43,7 @@ public class QueryProcessPerfTest {
 
 
     @Test
-    public void serveQueryPerformanceTest() throws InterruptedException {
+    void serveQueryPerformanceTest() throws InterruptedException {
         final Flux<AsyncQuery<DummyMessage>> messages = createMessages(messageCount);
 
         final long init = System.currentTimeMillis();

acceptance/async-tests/src/test/java/org/reactivecommons/test/SimpleDirectCommunicationTest.java

@@ -42,7 +42,7 @@ public class SimpleDirectCommunicationTest {
     private Long data = ThreadLocalRandom.current().nextLong();
 
     @Test
-    public void commandShouldArrive() {
+    void commandShouldArrive() {
         Command<Long> command = new Command<>(COMMAND_NAME, commandId, data);
         gateway.sendCommand(command, appName).subscribe();
 
@@ -53,7 +53,7 @@ public void commandShouldArrive() {
     }
 
     @Test
-    public void shouldReceiveResponse() {
+    void shouldReceiveResponse() {
         final Mono<Integer> reply = gateway.requestReply(new AsyncQuery<>("double", 42), appName, Integer.class);
         StepVerifier.create(reply.timeout(Duration.ofSeconds(15)))
             .expectNext(42*2)

acceptance/async-tests/src/test/java/org/reactivecommons/test/SimpleEventNotificationTest.java

@@ -35,7 +35,7 @@ public class SimpleEventNotificationTest {
     private Long data = ThreadLocalRandom.current().nextLong();
 
     @Test
-    public void shouldReceiveEvent() throws InterruptedException {
+    void shouldReceiveEvent() throws InterruptedException {
         DomainEvent<?> event = new DomainEvent<>(EVENT_NAME, eventId, data);
         from(eventBus.emit(event)).subscribe();
         StepVerifier.create(listener.take(1)).assertNext(evt ->

acceptance/async-tests/src/test/java/org/reactivecommons/test/perf/BlockingCommandHandlePerfTest.java

@@ -43,7 +43,7 @@ public class BlockingCommandHandlePerfTest {
     private Long data = ThreadLocalRandom.current().nextLong();
 
     @Test
-    public void commandShouldBeHandledInParallel() throws InterruptedException {
+    void commandShouldBeHandledInParallel() throws InterruptedException {
         Flux.range(0, 12).flatMap(i -> {
             Command<Long> command = new Command<>(COMMAND_NAME, commandId + 1, data + 1);
             return gateway.sendCommand(command, appName);

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

@@ -23,7 +23,7 @@ public class HandlerRegistryTest {
     private String name = "some.event";
 
     @Test
-    public void shouldListenEventWithTypeInferenceWhenClassInstanceIsUsed() {
+    void shouldListenEventWithTypeInferenceWhenClassInstanceIsUsed() {
         SomeEventHandler eventHandler = new SomeEventHandler();
 
         registry.listenEvent(name, eventHandler);
@@ -78,7 +78,7 @@ void shouldRegisterDynamicEventsHandler() {
     }
 
     @Test
-    public void shouldRegisterNotificationEventListener() {
+    void shouldRegisterNotificationEventListener() {
         registry.listenNotificationEvent(name, message -> Mono.empty(), SomeDataClass.class);
         assertThat(registry.getEventNotificationListener()).anySatisfy(listener ->
             assertThat(listener.getPath()).isEqualTo(name));
@@ -98,7 +98,7 @@ public void listenEvent() {
     }
 
     @Test
-    public void handleCommandWithTypeInference() {
+    void handleCommandWithTypeInference() {
         SomeCommandHandler handler = new SomeCommandHandler();
 
         registry.handleCommand(name, handler);
@@ -111,28 +111,28 @@ public void handleCommandWithTypeInference() {
     }
 
     @Test
-    public void handleCommandWithoutTypeShouldFail() {
+    void handleCommandWithoutTypeShouldFail() {
         Assertions.assertThrows(
                 RuntimeException.class,
                 () -> registry.handleCommand(name, (Command<SomeDataClass> message) -> Mono.empty()));
     }
 
     @Test
-    public void listenEventWithoutTypeShouldFail() {
+    void listenEventWithoutTypeShouldFail() {
         Assertions.assertThrows(
                 RuntimeException.class,
                 () -> registry.listenEvent(name, (DomainEvent<SomeDataClass> message) -> Mono.empty()));
     }
 
     @Test
-    public void handleQueryWithoutTypeShouldFail() {
+    void handleQueryWithoutTypeShouldFail() {
         Assertions.assertThrows(
                 RuntimeException.class,
                 () -> registry.serveQuery(name, (SomeDataClass query) -> Mono.empty()));
     }
 
     @Test
-    public void handleCommandWithLambda() {
+    void handleCommandWithLambda() {
         registry.handleCommand(name, (Command<SomeDataClass> message) -> Mono.empty(), SomeDataClass.class);
 
         assertThat(registry.getCommandHandlers()).anySatisfy(registered -> {
@@ -144,7 +144,7 @@ public void handleCommandWithLambda() {
 
 
     @Test
-    public void serveQueryWithLambda() {
+    void serveQueryWithLambda() {
         registry.serveQuery(name, message -> Mono.empty(), SomeDataClass.class);
         assertThat(registry.getHandlers()).anySatisfy(registered -> {
             assertThat(registered).extracting(RegisteredQueryHandler::getPath, RegisteredQueryHandler::getQueryClass)
@@ -153,7 +153,7 @@ public void serveQueryWithLambda() {
     }
 
     @Test
-    public void serveQueryWithTypeInference() {
+    void serveQueryWithTypeInference() {
         QueryHandler<SomeDataClass, SomeDataClass> handler = new SomeQueryHandler();
         registry.serveQuery(name, handler);
         assertThat(registry.getHandlers()).anySatisfy(registered -> {
@@ -164,7 +164,7 @@ public void serveQueryWithTypeInference() {
     }
 
     @Test
-    public void serveQueryDelegate() {
+    void serveQueryDelegate() {
         QueryHandlerDelegate<Void, SomeDataClass> handler = new SomeQueryHandlerDelegate();
         registry.serveQuery(name, handler, SomeDataClass.class);
         assertThat(registry.getHandlers()).anySatisfy(registered -> {
@@ -174,7 +174,7 @@ public void serveQueryDelegate() {
     }
 
     @Test
-    public void serveQueryDelegateWithLambda() {
+    void serveQueryDelegateWithLambda() {
         registry.serveQuery(name, (from, message) -> Mono.empty(), SomeDataClass.class);
         assertThat(registry.getHandlers()).anySatisfy(registered -> {
             assertThat(registered).extracting(RegisteredQueryHandler::getPath, RegisteredQueryHandler::getQueryClass)

async/async-commons/src/test/java/org/reactivecommons/async/commons/converters/json/DefaultObjectMapperSupplierTest.java

@@ -15,7 +15,7 @@ public class DefaultObjectMapperSupplierTest {
 
 
     @Test
-    public void shouldMapWithUnknownProperties() throws IOException {
+    void shouldMapWithUnknownProperties() throws IOException {
         ObjectMapper objectMapper = defaultObjectMapperSupplier.get();
 
         SampleClassExtra base = new SampleClassExtra("23", "one", new Date(), 45l);

async/async-commons/src/test/java/org/reactivecommons/async/commons/reply/ReactiveReplyRouterTest.java

@@ -14,7 +14,7 @@ public class ReactiveReplyRouterTest {
     private ReactiveReplyRouter replyRouter = new ReactiveReplyRouter();
 
     @Test
-    public void shouldRouteReply(){
+    void shouldRouteReply(){
         final String uuid = UUID.randomUUID().toString();
         final Mono<Message> registered = replyRouter.register(uuid);
 
@@ -28,7 +28,7 @@ public void shouldRouteReply(){
     }
 
     @Test
-    public void shouldRouteEmptyResponse(){
+    void shouldRouteEmptyResponse(){
         final String uuid = UUID.randomUUID().toString();
         final Mono<Message> registered = replyRouter.register(uuid);
 
@@ -39,7 +39,7 @@ public void shouldRouteEmptyResponse(){
     }
 
     @Test
-    public void shouldDeRegisterProcessor(){
+    void shouldDeRegisterProcessor(){
         final String uuid = UUID.randomUUID().toString();
         final Mono<Message> registered = replyRouter.register(uuid);