Activity build for the REST client

Build: #201 was successful Changes by Arnaud Cogoluègnes

Code commits

Plan Repository

  • Arnaud Cogoluègnes

    Arnaud Cogoluègnes 3533c66ff0c6347fbf6f52aea9a4152d25aea158

    Merge pull request #136 from rabbitmq/hop-135-upgrade-to-reactor-netty-0-9
    Bump Reactor to 3.2.0 and Reactor Netty to 0.8.0

  • Arnaud Cogoluègnes

    Arnaud Cogoluègnes cd17feb7f187ef45a81ae6b642cb05377d909f0c

    Merge branch 'master' into hop-135-upgrade-to-reactor-netty-0-9
    Conflicts:
            build.gradle

  • Arnaud Cogoluègnes

    Arnaud Cogoluègnes 5519f1f39d8b69991f62aa0a387e0274dd3cb547 m

    Bump Reactor Core to 3.2.1, Reactor Netty to 0.8.1
    Reworked the onResponse callback mechanism to be inside the usual flux
    flow, because the HttpClient onResponse callbacks wouldn't propagate
    exceptions.

    References #135

    • src/test/groovy/com/rabbitmq/http/client/ReactorNettyClientSpec.groovy (version 5519f1f39d8b69991f62aa0a387e0274dd3cb547)
    • src/main/java/com/rabbitmq/http/client/ReactorNettyClient.java (version 5519f1f39d8b69991f62aa0a387e0274dd3cb547)
    • build.gradle (version 5519f1f39d8b69991f62aa0a387e0274dd3cb547)
  • Arnaud Cogoluègnes

    Arnaud Cogoluègnes b91cc16d4bfa78165a42fd14df4d75a18627dcd3 m

    Call block() instead of hasElement() in test
    References #135

    • src/test/groovy/com/rabbitmq/http/client/ReactorNettyClientSpec.groovy (version b91cc16d4bfa78165a42fd14df4d75a18627dcd3)
  • Arnaud Cogoluègnes

    Arnaud Cogoluègnes 5a6ed168e1f3c69ac1423f4e40133dd68e0e8517 m

    Bump Reactor to 3.2.0, Reactor Netty to 0.8.0 (WIP)
    Exceptions thrown in onResponse callback are no longer propagated to the
    caller.

    References #135

    • src/test/groovy/com/rabbitmq/http/client/ReactorNettyClientSpec.groovy (version 5a6ed168e1f3c69ac1423f4e40133dd68e0e8517)
    • src/main/java/com/rabbitmq/http/client/ReactorNettyClient.java (version 5a6ed168e1f3c69ac1423f4e40133dd68e0e8517)
    • build.gradle (version 5a6ed168e1f3c69ac1423f4e40133dd68e0e8517)
  • Arnaud Cogoluègnes

    Arnaud Cogoluègnes dbd55d007e20908dcb0f55c980ef455b7f5f1755 m

    Use InputStream instead of byte array
    When deserializing in ReactorNettyClient.

    References #135

    • src/main/java/com/rabbitmq/http/client/ReactorNettyClient.java (version dbd55d007e20908dcb0f55c980ef455b7f5f1755)
  • Arnaud Cogoluègnes

    Arnaud Cogoluègnes 5dfdee51f20d29da7bd0ade2f15871b12e757da6 m

    Be more tolerant with error on permissions update
    The error shows up sometimes on Travis CI environment, it's likely to be
    due to Cowboy as of RabbitMQ 3.7.4.

    • src/test/groovy/com/rabbitmq/http/client/ReactorNettyClientSpec.groovy (version 5dfdee51f20d29da7bd0ade2f15871b12e757da6)
  • Arnaud Cogoluègnes

    Arnaud Cogoluègnes a16d65a8b444d2441cad48625678aac675a64771 m

    Merge branch 'master' into hop-135-upgrade-to-reactor-netty-0-9

  • Arnaud Cogoluègnes

    Arnaud Cogoluègnes d9afb6108c2d6d4948bd86108db7499247ac1299 m

    Fix generic issue on JDK 8
    References #135

    • src/main/java/com/rabbitmq/http/client/ReactorNettyClient.java (version d9afb6108c2d6d4948bd86108db7499247ac1299)
  • Arnaud Cogoluègnes

    Arnaud Cogoluègnes 32641bbc692aca17c2d490d96f3628456eb4b634 m

    Add Supplier<ByteBuf>, use ByteBufFlux
    Per discussion with @smaldini.

    References #135

    • src/main/java/com/rabbitmq/http/client/ReactorNettyClient.java (version 32641bbc692aca17c2d490d96f3628456eb4b634)
    • src/main/java/com/rabbitmq/http/client/HttpEndpoint.java (version 32641bbc692aca17c2d490d96f3628456eb4b634)
  • Michael Klishin <michael@clojurewerkz.org>

    Michael Klishin <michael@clojurewerkz.org> 42f538afd4f67cfb4e4414a5c879200b536b9f2e m

    HttpRequest => HttpEndpoint
    Since it only carries a URI and an HTTP method.

    Per discussion with @acogoluegnes.

    • src/main/java/com/rabbitmq/http/client/ReactorNettyClientOptions.java (version 42f538afd4f67cfb4e4414a5c879200b536b9f2e)
    • src/main/java/com/rabbitmq/http/client/ReactorNettyClient.java (version 42f538afd4f67cfb4e4414a5c879200b536b9f2e)
    • src/main/java/com/rabbitmq/http/client/HttpRequest.java (version 42f538afd4f67cfb4e4414a5c879200b536b9f2e)
    • src/main/java/com/rabbitmq/http/client/HttpEndpoint.java (version 42f538afd4f67cfb4e4414a5c879200b536b9f2e)
  • Arnaud Cogoluègnes

    Arnaud Cogoluègnes 2884033ea964604db0f0ea98f6ff3495aedaa39b m

    Remove commented code
    References #135

    • src/main/java/com/rabbitmq/http/client/ReactorNettyClient.java (version 2884033ea964604db0f0ea98f6ff3495aedaa39b)
  • Arnaud Cogoluègnes

    Arnaud Cogoluègnes 1ca7fda60fc5a55c7ff1b1edefdc2e9da8574ae4 m

    Bump Reactor to 3.2.0.RC1 and Reactor Netty to 0.8.0.M3
    References #135

    • src/test/groovy/com/rabbitmq/http/client/ReactorNettyClientSpec.groovy (version 1ca7fda60fc5a55c7ff1b1edefdc2e9da8574ae4)
    • src/main/java/com/rabbitmq/http/client/ReactorNettyClientOptions.java (version 1ca7fda60fc5a55c7ff1b1edefdc2e9da8574ae4)
    • src/main/java/com/rabbitmq/http/client/ReactorNettyClient.java (version 1ca7fda60fc5a55c7ff1b1edefdc2e9da8574ae4)
    • src/main/java/com/rabbitmq/http/client/HttpServerException.java (version 1ca7fda60fc5a55c7ff1b1edefdc2e9da8574ae4)
    • src/main/java/com/rabbitmq/http/client/HttpResponse.java (version 1ca7fda60fc5a55c7ff1b1edefdc2e9da8574ae4)
    • src/main/java/com/rabbitmq/http/client/HttpRequest.java (version 1ca7fda60fc5a55c7ff1b1edefdc2e9da8574ae4)
    • src/main/java/com/rabbitmq/http/client/HttpException.java (version 1ca7fda60fc5a55c7ff1b1edefdc2e9da8574ae4)
    • src/main/java/com/rabbitmq/http/client/HttpClientException.java (version 1ca7fda60fc5a55c7ff1b1edefdc2e9da8574ae4)
    • gradle.properties (version 1ca7fda60fc5a55c7ff1b1edefdc2e9da8574ae4)
    • build.gradle (version 1ca7fda60fc5a55c7ff1b1edefdc2e9da8574ae4)