First batch of update for ribbon 1.x branch.

- Added ribbon-rxnetty module for asynchronous HTTP communication based on Netty and RxJava
- IClientConfig and IClientConfigKey supports typed property
- Updates to serialization factory and serializer interfaces (replaced Guava TypeToken with TypeDef in the interfaces)
- Updates to HttpRequest and HttpResponse interfaces with addition of HttpHeaders

build.gradle

@@ -59,6 +59,15 @@ project(':ribbon-httpclient') {
     }
 }
 
+project(':ribbon-rxnetty') {
+    dependencies {
+        compile project(':ribbon-core')
+        compile 'com.netflix.rxnetty:rx-netty:0.2.0'
+        testCompile project(':ribbon-test')        
+    }
+}
+
+
 project(':ribbon-eureka') {   
     dependencies {
         compile project(':ribbon-core')
@@ -87,3 +96,13 @@ project(':ribbon-examples') {
     }
 }
 
+project(':ribbon-test') {
+    dependencies {
+        compile project(':ribbon-core')
+        compile 'com.sun.jersey:jersey-server:1.11'
+        compile 'javax.ws.rs:jsr311-api:1.1.1' 
+        compile 'com.sun.jersey:jersey-core:1.11'    
+        compile 'junit:junit:4.10'
+    }
+}
+

ribbon-core/src/main/java/com/netflix/client/LoadBalancerContext.java

@@ -245,7 +245,7 @@ private ClientException generateTimeoutNIWSException(String uri, Throwable e){
      * This is called after a response is received or an exception is thrown from the client
      * to update related stats.  
      */
-    protected void noteRequestCompletion(ServerStats stats, ClientRequest request, IResponse response, Throwable e, long responseTime) {        
+    protected void noteRequestCompletion(ServerStats stats, ClientRequest request, Object response, Throwable e, long responseTime) {        
         try {
             if (stats != null) {
                 stats.decrementActiveRequestsCount();
@@ -259,7 +259,7 @@ protected void noteRequestCompletion(ServerStats stats, ClientRequest request, I
             logger.error("Unexpected exception", ex);
         }            
     }
-       
+
     /**
      * This is usually called just before client execute a request.
      */

ribbon-core/src/main/java/com/netflix/client/ResponseWithTypedEntity.java

@@ -19,7 +19,7 @@
 
 import java.io.InputStream;
 
-import com.google.common.reflect.TypeToken;
+import com.netflix.serialization.TypeDef;
 
 /**
  * A response type that includes a typed entity in its content.
@@ -31,7 +31,7 @@ public interface ResponseWithTypedEntity extends IResponse {
 
     public <T> T getEntity(Class<T> type) throws Exception;
 
-    public <T> T getEntity(TypeToken<T> type) throws Exception;
+    public <T> T getEntity(TypeDef<T> type) throws Exception;
 
     public boolean hasEntity();
 

ribbon-core/src/main/java/com/netflix/client/UnexpectedResponseException.java

@@ -0,0 +1,21 @@
+package com.netflix.client;
+
+public class UnexpectedResponseException extends Exception {
+
+    /**
+     * 
+     */
+    private static final long serialVersionUID = 1L;
+
+    public UnexpectedResponseException(String arg0, Throwable arg1) {
+        super(arg0, arg1);
+    }
+
+    public UnexpectedResponseException(String arg0) {
+        super(arg0);
+    }
+
+    public UnexpectedResponseException(Throwable arg0) {
+        super(arg0);
+    }
+}