Test travis config

Author: Daniel Bustamante Ospina

.travis.yml

@@ -1,9 +1,19 @@
 language: java
 
+git:
+  quiet: true
+
+services:
+  - rabbitmq
+
 jdk:
   - oraclejdk8
+  - oraclejdk11
 
-os:
-  - linux
-
-script: ./gradlew build
+before_cache:
+  - rm -f  $HOME/.gradle/caches/modules-2/modules-2.lock
+  - rm -fr $HOME/.gradle/caches/*/plugin-resolution/
+cache:
+  directories:
+    - $HOME/.gradle/caches/
+    - $HOME/.gradle/wrapper/

acceptance/async-tests/async-tests.gradle

@@ -0,0 +1,4 @@
+dependencies {
+    compile project(":async-commons-starter")
+    compile('org.springframework.boot:spring-boot-starter')
+}

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

@@ -0,0 +1,56 @@
+package org.reactivecommons.test;
+
+import org.junit.Test;
+import org.junit.runner.RunWith;
+import org.reactivecommons.async.api.AsyncQuery;
+import org.reactivecommons.async.api.DirectAsyncGateway;
+import org.reactivecommons.async.api.HandlerRegistry;
+import org.reactivecommons.async.impl.config.annotations.EnableDirectAsyncGateway;
+import org.reactivecommons.async.impl.config.annotations.EnableMessageListeners;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.beans.factory.annotation.Value;
+import org.springframework.boot.SpringApplication;
+import org.springframework.boot.autoconfigure.SpringBootApplication;
+import org.springframework.boot.test.context.SpringBootTest;
+import org.springframework.context.annotation.Bean;
+import org.springframework.test.context.junit4.SpringRunner;
+import reactor.core.publisher.Mono;
+import reactor.test.StepVerifier;
+
+import java.time.Duration;
+
+import static reactor.core.publisher.Mono.*;
+
+@SpringBootTest
+@RunWith(SpringRunner.class)
+public class DirectAsyncGatewayTest {
+
+    @Autowired
+    private DirectAsyncGateway gateway;
+
+    @Value("${spring.application.name}")
+    private String appName;
+
+    @Test
+    public 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)
+            .verifyComplete();
+    }
+
+
+    @SpringBootApplication
+    @EnableDirectAsyncGateway
+    @EnableMessageListeners
+    static class App{
+        public static void main(String[] args) {
+            SpringApplication.run(App.class, args);
+        }
+
+        @Bean
+        public HandlerRegistry registry() {
+            return HandlerRegistry.register().serveQuery("double", rqt -> just(rqt*2), Long.class);
+        }
+    }
+}

acceptance/async-tests/src/test/resources/application.properties

@@ -0,0 +1 @@
+spring.application.name=testApp

gradle.properties

@@ -1,2 +1,2 @@
-version=0.0.3-beta1
+version=0.0.5-beta1
 springBootVersion=2.1.1.RELEASE

main.gradle

@@ -29,6 +29,7 @@ subprojects {
 
     dependencies {
         testImplementation 'org.springframework.boot:spring-boot-starter-test'
+        testImplementation 'io.projectreactor:reactor-test'
         compileOnly 'org.projectlombok:lombok'
         annotationProcessor 'org.projectlombok:lombok'
         testAnnotationProcessor 'org.projectlombok:lombok'