svn commit: r1341674 - in /incubator/directmemory/trunk/server/directmemory-server-client/src/main/java/org/apache/directmemory/server/client: DirectMemoryClientConfiguration.java providers/asynchttpclient/AsyncHttpClientDirectMemoryHttpClient.java

[olamy]

Author: olamy
Date: Tue May 22 23:03:06 2012
New Revision: 1341674

URL: http://svn.apache.org/viewvc?rev=1341674&view=rev
Log:
add a field in configuration to pass AsyncHttpClientConfig bean

Modified:
    
incubator/directmemory/trunk/server/directmemory-server-client/src/main/java/org/apache/directmemory/server/client/DirectMemoryClientConfiguration.java
    
incubator/directmemory/trunk/server/directmemory-server-client/src/main/java/org/apache/directmemory/server/client/providers/asynchttpclient/AsyncHttpClientDirectMemoryHttpClient.java

Modified: 
incubator/directmemory/trunk/server/directmemory-server-client/src/main/java/org/apache/directmemory/server/client/DirectMemoryClientConfiguration.java
URL: 
http://svn.apache.org/viewvc/incubator/directmemory/trunk/server/directmemory-server-client/src/main/java/org/apache/directmemory/server/client/DirectMemoryClientConfiguration.java?rev=1341674&r1=1341673&r2=1341674&view=diff
==============================================================================
--- 
incubator/directmemory/trunk/server/directmemory-server-client/src/main/java/org/apache/directmemory/server/client/DirectMemoryClientConfiguration.java
 (original)
+++ 
incubator/directmemory/trunk/server/directmemory-server-client/src/main/java/org/apache/directmemory/server/client/DirectMemoryClientConfiguration.java
 Tue May 22 23:03:06 2012
@@ -18,6 +18,7 @@ package org.apache.directmemory.server.c
  * under the License.
  */
 
+import com.ning.http.client.AsyncHttpClientConfig;
 import org.apache.directmemory.serialization.Serializer;
 import org.apache.directmemory.server.commons.ExchangeType;
 
@@ -54,6 +55,7 @@ public class DirectMemoryClientConfigura
 
     private String httpClientClassName = 
DirectMemoryClientBuilder.DEFAULT_HTTP_CLIENT_INSTANCE;
 
+    private AsyncHttpClientConfig asyncHttpClientConfig;
     /**
      * http provider class for async http client
      * default value is <code>NettyAsyncHttpProvider</code>
@@ -187,6 +189,17 @@ public class DirectMemoryClientConfigura
         return this;
     }
 
+    public AsyncHttpClientConfig getAsyncHttpClientConfig()
+    {
+        return asyncHttpClientConfig;
+    }
+
+    public DirectMemoryClientConfiguration setAsyncHttpClientConfig( 
AsyncHttpClientConfig asyncHttpClientConfig )
+    {
+        this.asyncHttpClientConfig = asyncHttpClientConfig;
+        return this;
+    }
+
     @Override
     public String toString()
     {

Modified: 
incubator/directmemory/trunk/server/directmemory-server-client/src/main/java/org/apache/directmemory/server/client/providers/asynchttpclient/AsyncHttpClientDirectMemoryHttpClient.java
URL: 
http://svn.apache.org/viewvc/incubator/directmemory/trunk/server/directmemory-server-client/src/main/java/org/apache/directmemory/server/client/providers/asynchttpclient/AsyncHttpClientDirectMemoryHttpClient.java?rev=1341674&r1=1341673&r2=1341674&view=diff
==============================================================================
--- 
incubator/directmemory/trunk/server/directmemory-server-client/src/main/java/org/apache/directmemory/server/client/providers/asynchttpclient/AsyncHttpClientDirectMemoryHttpClient.java
 (original)
+++ 
incubator/directmemory/trunk/server/directmemory-server-client/src/main/java/org/apache/directmemory/server/client/providers/asynchttpclient/AsyncHttpClientDirectMemoryHttpClient.java
 Tue May 22 23:03:06 2012
@@ -62,8 +62,9 @@ public class AsyncHttpClientDirectMemory
 
         asyncHttpClient = new AsyncHttpClient(
             httpProviderClassName != null ? httpProviderClassName : 
NettyAsyncHttpProvider.class.getName(),
-            builder.build() );
-
+            configuration.getAsyncHttpClientConfig() == null
+                ? builder.build()
+                : configuration.getAsyncHttpClientConfig() );
     }
 
     @Override