Create new async client based on Reactor Netty

README.md

@@ -35,7 +35,7 @@ Add the following to your `pom.xml`:
 <dependency>
   <groupId>com.rabbitmq</groupId>
   <artifactId>http-client</artifactId>
-  <version>2.0.1.RELEASE</version>
+  <version>2.0.2.RELEASE</version>
 </dependency>
 ```
 
@@ -44,7 +44,7 @@ Add the following to your `pom.xml`:
 Add the following to your `build.gradle`:
 
 ``` groovy
-compile "com.rabbitmq:http-client:2.0.1.RELEASE"
+compile "com.rabbitmq:http-client:2.0.2.RELEASE"
 ```
 
 

build.gradle

@@ -32,20 +32,27 @@ compileTestJava {
 }
 
 ext {
-  amqpClientVersion='5.1.2'
-  commonsHttpClientVersion = '4.5.3'
-  groovyVersion = '2.4.13'
-  jacksonVersion = '2.9.4'
+  amqpClientVersion='5.2.0'
+  commonsHttpClientVersion = '4.5.5'
+  groovyVersion = '2.4.15'
+  jacksonVersion = '2.9.5'
   spockVersion = "1.1-groovy-2.4"
-  reactorVersion = "Bismuth-SR3"
-  springVersion = '5.0.3.RELEASE'
+  reactorVersion = "Bismuth-SR9"
+  springVersion = '5.0.6.RELEASE'
+  reactorNettyVersion = '0.7.7.RELEASE'
 
   linkHomepage = 'https://github.com/rabbitmq/hop'
   linkCi       = 'https://build.spring.io/browse/RMQ'
   linkIssue    = 'https://github.com/rabbitmq/hop/issues'
   linkScmUrl           = 'https://github.com/rabbitmq/hop'
   linkScmConnection    = 'https://github.com/rabbitmq/hop.git'
   linkScmDevConnection = '[email protected]:rabbitmq/hop.git'
+
+  javadocLinks = ["http://docs.oracle.com/javase/7/docs/api/",
+                  "http://docs.oracle.com/javaee/6/api/",
+                  "http://www.reactive-streams.org/reactive-streams-1.0.2-javadoc/",
+                  "http://projectreactor.io/docs/core/release/api/",
+                  "https://fasterxml.github.io/jackson-databind/javadoc/2.9/"] as String[]
 }
 
 dependencyManagement {
@@ -63,7 +70,7 @@ dependencies {
   compile "org.springframework:spring-webflux:$springVersion"
   compile "org.apache.httpcomponents:httpclient:$commonsHttpClientVersion"
   compile "com.fasterxml.jackson.core:jackson-databind:$jacksonVersion"
-  compile "io.projectreactor.ipc:reactor-netty"
+  compile "io.projectreactor.ipc:reactor-netty:$reactorNettyVersion"
 
   testCompile "org.codehaus.groovy:groovy-all:$groovyVersion"
   testCompile "org.spockframework:spock-core:$spockVersion"

gradle.properties

@@ -1 +1 @@
-version=2.0.2.BUILD-SNAPSHOT
+version=2.0.3.BUILD-SNAPSHOT

src/main/java/com/rabbitmq/http/client/Client.java

@@ -803,12 +803,7 @@ private URI uriWithPath(final String path) {
   }
 
   private String encodePathSegment(final String pathSegment) {
-    try {
-      return UriUtils.encodePathSegment(pathSegment, "UTF-8");
-    } catch (UnsupportedEncodingException e) {
-      // the best we can do without messing up all caller signatures :/ MK.
-      return pathSegment;
-    }
+    return UriUtils.encodePathSegment(pathSegment, "UTF-8");
   }
 
   private List<HttpMessageConverter<?>> getMessageConverters() {

src/main/java/com/rabbitmq/http/client/HttpClientException.java

@@ -0,0 +1,41 @@
+/*
+ * Copyright 2018 the original author or authors.
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ *      http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+
+package com.rabbitmq.http.client;
+
+/**
+ *
+ */
+public class HttpClientException extends HttpException {
+
+    static final long serialVersionUID = 1;
+
+    public HttpClientException(reactor.ipc.netty.http.client.HttpClientException cause) {
+        super(cause);
+    }
+
+    public int status() {
+        return cause().status().code();
+    }
+
+    public String reason() {
+        return cause().status().reasonPhrase();
+    }
+
+    private reactor.ipc.netty.http.client.HttpClientException cause() {
+        return (reactor.ipc.netty.http.client.HttpClientException) getCause();
+    }
+}

src/main/java/com/rabbitmq/http/client/HttpException.java

@@ -0,0 +1,29 @@
+/*
+ * Copyright 2018 the original author or authors.
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ *      http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+
+package com.rabbitmq.http.client;
+
+/**
+ *
+ */
+public class HttpException extends RuntimeException {
+
+    static final long serialVersionUID = 1;
+
+    public HttpException(Throwable cause) {
+        super(cause);
+    }
+}

src/main/java/com/rabbitmq/http/client/HttpResponse.java

@@ -0,0 +1,50 @@
+/*
+ * Copyright 2018 the original author or authors.
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ *      http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+
+package com.rabbitmq.http.client;
+
+import java.util.Collections;
+import java.util.Map;
+
+/**
+ *
+ */
+public class HttpResponse {
+
+    private final int status;
+
+    private final String reason;
+
+    private final Map<String, String> headers;
+
+    public HttpResponse(int status, String reason, Map<String, String> headers) {
+        this.status = status;
+        this.reason = reason;
+        this.headers = Collections.unmodifiableMap(headers);
+    }
+
+    public int getStatus() {
+        return status;
+    }
+
+    public String getReason() {
+        return reason;
+    }
+
+    public Map<String, String> getHeaders() {
+        return headers;
+    }
+}