Author: olegk
Date: Wed Aug 1 15:20:23 2012
New Revision: 1368051
URL: http://svn.apache.org/viewvc?rev=1368051&view=rev
Log:
Fixed HTTP protocol and i/o level logging
Added:
cxf/sandbox/dkulp_async_clients/http-hc/src/test/resources/
cxf/sandbox/dkulp_async_clients/http-hc/src/test/resources/log4j.properties
(with props)
Modified:
cxf/sandbox/dkulp_async_clients/http-hc/pom.xml
cxf/sandbox/dkulp_async_clients/http-hc/src/main/java/org/apache/cxf/transport/http/asyncclient/AsyncHTTPTransportFactory.java
cxf/sandbox/dkulp_async_clients/http-hc/src/main/java/org/apache/cxf/transport/http/asyncclient/LoggingNHttpClientConnectionFactory.java
Modified: cxf/sandbox/dkulp_async_clients/http-hc/pom.xml
URL:
http://svn.apache.org/viewvc/cxf/sandbox/dkulp_async_clients/http-hc/pom.xml?rev=1368051&r1=1368050&r2=1368051&view=diff
==============================================================================
--- cxf/sandbox/dkulp_async_clients/http-hc/pom.xml (original)
+++ cxf/sandbox/dkulp_async_clients/http-hc/pom.xml Wed Aug 1 15:20:23 2012
@@ -72,6 +72,12 @@
<artifactId>slf4j-api</artifactId>
</dependency>
<dependency>
+ <groupId>org.slf4j</groupId>
+ <artifactId>slf4j-log4j12</artifactId>
+ <version>1.6.2</version>
+ <scope>test</scope>
+ </dependency>
+ <dependency>
<groupId>org.apache.httpcomponents</groupId>
<artifactId>httpcore-nio</artifactId>
<version>4.2.1</version>
Modified:
cxf/sandbox/dkulp_async_clients/http-hc/src/main/java/org/apache/cxf/transport/http/asyncclient/AsyncHTTPTransportFactory.java
URL:
http://svn.apache.org/viewvc/cxf/sandbox/dkulp_async_clients/http-hc/src/main/java/org/apache/cxf/transport/http/asyncclient/AsyncHTTPTransportFactory.java?rev=1368051&r1=1368050&r2=1368051&view=diff
==============================================================================
---
cxf/sandbox/dkulp_async_clients/http-hc/src/main/java/org/apache/cxf/transport/http/asyncclient/AsyncHTTPTransportFactory.java
(original)
+++
cxf/sandbox/dkulp_async_clients/http-hc/src/main/java/org/apache/cxf/transport/http/asyncclient/AsyncHTTPTransportFactory.java
Wed Aug 1 15:20:23 2012
@@ -115,15 +115,15 @@ public class AsyncHTTPTransportFactory e
// Create client-side HTTP protocol handler
HttpAsyncRequestExecutor protocolHandler = new
HttpAsyncRequestExecutor();
// Create client-side I/O event dispatch
- final IOEventDispatch ioEventDispatch = new
DefaultHttpClientIODispatch(protocolHandler,
- new LoggingNHttpClientConnectionFactory(params));
+ final LoggingNHttpClientConnectionFactory connFactory = new
LoggingNHttpClientConnectionFactory(params);
+ final IOEventDispatch ioEventDispatch = new
DefaultHttpClientIODispatch(protocolHandler, connFactory);
// Create client-side I/O reactor
IOReactorConfig config = new IOReactorConfig();
config.setTcpNoDelay(true);
final ConnectingIOReactor ioReactor = new
DefaultConnectingIOReactor(config);
// Create HTTP connection pool
- pool = new BasicNIOConnPool(ioReactor, params);
+ pool = new BasicNIOConnPool(ioReactor, connFactory, params);
pool.setDefaultMaxPerRoute(1000);
pool.setMaxTotal(5000);
Modified:
cxf/sandbox/dkulp_async_clients/http-hc/src/main/java/org/apache/cxf/transport/http/asyncclient/LoggingNHttpClientConnectionFactory.java
URL:
http://svn.apache.org/viewvc/cxf/sandbox/dkulp_async_clients/http-hc/src/main/java/org/apache/cxf/transport/http/asyncclient/LoggingNHttpClientConnectionFactory.java?rev=1368051&r1=1368050&r2=1368051&view=diff
==============================================================================
---
cxf/sandbox/dkulp_async_clients/http-hc/src/main/java/org/apache/cxf/transport/http/asyncclient/LoggingNHttpClientConnectionFactory.java
(original)
+++
cxf/sandbox/dkulp_async_clients/http-hc/src/main/java/org/apache/cxf/transport/http/asyncclient/LoggingNHttpClientConnectionFactory.java
Wed Aug 1 15:20:23 2012
@@ -19,18 +19,24 @@
package org.apache.cxf.transport.http.asyncclient;
+import java.io.IOException;
+
+import org.apache.http.HttpHost;
import org.apache.http.HttpResponseFactory;
import org.apache.http.annotation.Immutable;
import org.apache.http.impl.DefaultHttpResponseFactory;
import org.apache.http.impl.nio.DefaultNHttpClientConnection;
import org.apache.http.impl.nio.DefaultNHttpClientConnectionFactory;
+import org.apache.http.nio.NHttpClientConnection;
+import org.apache.http.nio.pool.NIOConnFactory;
import org.apache.http.nio.reactor.IOSession;
import org.apache.http.nio.util.ByteBufferAllocator;
import org.apache.http.nio.util.HeapByteBufferAllocator;
import org.apache.http.params.HttpParams;
@Immutable
-public class LoggingNHttpClientConnectionFactory extends
DefaultNHttpClientConnectionFactory {
+public class LoggingNHttpClientConnectionFactory extends
DefaultNHttpClientConnectionFactory
+ implements NIOConnFactory<HttpHost, NHttpClientConnection> {
public LoggingNHttpClientConnectionFactory(
final HttpResponseFactory responseFactory,
@@ -52,4 +58,10 @@ public class LoggingNHttpClientConnectio
return new LoggingNHttpClientConnection(session, responseFactory,
allocator, params);
}
+ @Override
+ public NHttpClientConnection create(
+ final HttpHost route, final IOSession session) throws IOException {
+ return createConnection(session);
+ }
+
}
Added:
cxf/sandbox/dkulp_async_clients/http-hc/src/test/resources/log4j.properties
URL:
http://svn.apache.org/viewvc/cxf/sandbox/dkulp_async_clients/http-hc/src/test/resources/log4j.properties?rev=1368051&view=auto
==============================================================================
--- cxf/sandbox/dkulp_async_clients/http-hc/src/test/resources/log4j.properties
(added)
+++ cxf/sandbox/dkulp_async_clients/http-hc/src/test/resources/log4j.properties
Wed Aug 1 15:20:23 2012
@@ -0,0 +1,8 @@
+log4j.appender.stdout=org.apache.log4j.ConsoleAppender
+log4j.appender.stdout.Target=System.out
+log4j.appender.stdout.layout=org.apache.log4j.PatternLayout
+log4j.appender.stdout.layout.ConversionPattern=%d{ABSOLUTE} %5p %c{1}:%L - %m%n
+
+log4j.rootLogger=WARN, stdout
+log4j.logger.org.apache.http=WARN
+
\ No newline at end of file
Propchange:
cxf/sandbox/dkulp_async_clients/http-hc/src/test/resources/log4j.properties
------------------------------------------------------------------------------
svn:eol-style = native
Propchange:
cxf/sandbox/dkulp_async_clients/http-hc/src/test/resources/log4j.properties
------------------------------------------------------------------------------
svn:keywords = Date Revision
Propchange:
cxf/sandbox/dkulp_async_clients/http-hc/src/test/resources/log4j.properties
------------------------------------------------------------------------------
svn:mime-type = text/plain