Author: isudana
Date: Tue Dec 27 09:55:18 2016
New Revision: 1776100

URL: http://svn.apache.org/viewvc?rev=1776100&view=rev
Log:
Refactoring connection factory class names

Added:
    
synapse/trunk/java/modules/transports/core/nhttp/src/main/java/org/apache/synapse/transport/utils/conn/SynapseNHttpClientConnection.java
    
synapse/trunk/java/modules/transports/core/nhttp/src/main/java/org/apache/synapse/transport/utils/conn/SynapseNHttpClientConnectionFactory.java
      - copied, changed from r1776096, 
synapse/trunk/java/modules/transports/core/nhttp/src/main/java/org/apache/synapse/transport/utils/conn/logging/LoggingNHttpClientConnectionFactory.java
    
synapse/trunk/java/modules/transports/core/nhttp/src/main/java/org/apache/synapse/transport/utils/conn/SynapseNHttpSSLClientConnectionFactory.java
      - copied, changed from r1776096, 
synapse/trunk/java/modules/transports/core/nhttp/src/main/java/org/apache/synapse/transport/utils/conn/logging/LoggingNHttpSSLClientConnectionFactory.java
    
synapse/trunk/java/modules/transports/core/nhttp/src/main/java/org/apache/synapse/transport/utils/conn/SynapseNHttpSSLServerConnectionFactory.java
      - copied, changed from r1776096, 
synapse/trunk/java/modules/transports/core/nhttp/src/main/java/org/apache/synapse/transport/utils/conn/logging/LoggingNHttpSSLServerConnectionFactory.java
    
synapse/trunk/java/modules/transports/core/nhttp/src/main/java/org/apache/synapse/transport/utils/conn/SynapseNHttpServerConnectionFactory.java
      - copied, changed from r1776096, 
synapse/trunk/java/modules/transports/core/nhttp/src/main/java/org/apache/synapse/transport/utils/conn/logging/LoggingNHttpServerConnectionFactory.java
Removed:
    
synapse/trunk/java/modules/transports/core/nhttp/src/main/java/org/apache/synapse/transport/utils/conn/logging/LoggingNHttpClientConnectionFactory.java
    
synapse/trunk/java/modules/transports/core/nhttp/src/main/java/org/apache/synapse/transport/utils/conn/logging/LoggingNHttpSSLClientConnectionFactory.java
    
synapse/trunk/java/modules/transports/core/nhttp/src/main/java/org/apache/synapse/transport/utils/conn/logging/LoggingNHttpSSLServerConnectionFactory.java
    
synapse/trunk/java/modules/transports/core/nhttp/src/main/java/org/apache/synapse/transport/utils/conn/logging/LoggingNHttpServerConnectionFactory.java
Modified:
    
synapse/trunk/java/modules/transports/core/nhttp/src/main/java/org/apache/synapse/transport/utils/conn/logging/LoggingNHttpClientConnection.java
    
synapse/trunk/java/modules/transports/core/nhttp/src/main/java/org/apache/synapse/transport/utils/conn/logging/LoggingUtils.java

Added: 
synapse/trunk/java/modules/transports/core/nhttp/src/main/java/org/apache/synapse/transport/utils/conn/SynapseNHttpClientConnection.java
URL: 
http://svn.apache.org/viewvc/synapse/trunk/java/modules/transports/core/nhttp/src/main/java/org/apache/synapse/transport/utils/conn/SynapseNHttpClientConnection.java?rev=1776100&view=auto
==============================================================================
--- 
synapse/trunk/java/modules/transports/core/nhttp/src/main/java/org/apache/synapse/transport/utils/conn/SynapseNHttpClientConnection.java
 (added)
+++ 
synapse/trunk/java/modules/transports/core/nhttp/src/main/java/org/apache/synapse/transport/utils/conn/SynapseNHttpClientConnection.java
 Tue Dec 27 09:55:18 2016
@@ -0,0 +1,84 @@
+/*
+ *  Licensed to the Apache Software Foundation (ASF) under one
+ *  or more contributor license agreements.  See the NOTICE file
+ *  distributed with this work for additional information
+ *  regarding copyright ownership.  The ASF licenses this file
+ *  to you 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 org.apache.synapse.transport.utils.conn;
+
+import org.apache.http.HttpException;
+import org.apache.http.HttpRequest;
+import org.apache.http.HttpResponse;
+import org.apache.http.config.MessageConstraints;
+import org.apache.http.entity.ContentLengthStrategy;
+import org.apache.http.impl.nio.DefaultNHttpClientConnection;
+import org.apache.http.nio.NHttpClientEventHandler;
+import org.apache.http.nio.NHttpMessageParserFactory;
+import org.apache.http.nio.NHttpMessageWriterFactory;
+import org.apache.http.nio.reactor.IOSession;
+import org.apache.http.nio.util.ByteBufferAllocator;
+
+import java.io.IOException;
+import java.nio.charset.CharsetDecoder;
+import java.nio.charset.CharsetEncoder;
+
+/**
+ * An extension of the DefaultNHttpClientConnection class, that has some
+ * additional stuff related to synapse NHttp transport implementation
+ */
+public class SynapseNHttpClientConnection extends DefaultNHttpClientConnection 
{
+
+    public SynapseNHttpClientConnection(IOSession session,
+                                        int bufferSize,
+                                        int fragmentSizeHint,
+                                        ByteBufferAllocator allocator,
+                                        CharsetDecoder charDecoder,
+                                        CharsetEncoder charEncoder,
+                                        MessageConstraints constraints,
+                                        ContentLengthStrategy 
incomingContentStrategy,
+                                        ContentLengthStrategy 
outgoingContentStrategy,
+                                        NHttpMessageWriterFactory<HttpRequest> 
requestWriterFactory,
+                                        
NHttpMessageParserFactory<HttpResponse> responseParserFactory) {
+        super(session, bufferSize, fragmentSizeHint, allocator,
+              charDecoder, charEncoder, constraints, incomingContentStrategy,
+              outgoingContentStrategy, requestWriterFactory, 
responseParserFactory);
+    }
+
+    @Override
+    public void close() throws IOException {
+        super.close();
+    }
+
+    @Override
+    public void shutdown() throws IOException {
+        super.shutdown();
+    }
+
+    @Override
+    public void submitRequest(final HttpRequest request) throws IOException, 
HttpException {
+        super.submitRequest(request);
+    }
+
+    @Override
+    public void consumeInput(final NHttpClientEventHandler handler) {
+        super.consumeInput(handler);
+    }
+
+    @Override
+    public void produceOutput(final NHttpClientEventHandler handler) {
+        super.produceOutput(handler);
+    }
+}

Copied: 
synapse/trunk/java/modules/transports/core/nhttp/src/main/java/org/apache/synapse/transport/utils/conn/SynapseNHttpClientConnectionFactory.java
 (from r1776096, 
synapse/trunk/java/modules/transports/core/nhttp/src/main/java/org/apache/synapse/transport/utils/conn/logging/LoggingNHttpClientConnectionFactory.java)
URL: 
http://svn.apache.org/viewvc/synapse/trunk/java/modules/transports/core/nhttp/src/main/java/org/apache/synapse/transport/utils/conn/SynapseNHttpClientConnectionFactory.java?p2=synapse/trunk/java/modules/transports/core/nhttp/src/main/java/org/apache/synapse/transport/utils/conn/SynapseNHttpClientConnectionFactory.java&p1=synapse/trunk/java/modules/transports/core/nhttp/src/main/java/org/apache/synapse/transport/utils/conn/logging/LoggingNHttpClientConnectionFactory.java&r1=1776096&r2=1776100&rev=1776100&view=diff
==============================================================================
--- 
synapse/trunk/java/modules/transports/core/nhttp/src/main/java/org/apache/synapse/transport/utils/conn/logging/LoggingNHttpClientConnectionFactory.java
 (original)
+++ 
synapse/trunk/java/modules/transports/core/nhttp/src/main/java/org/apache/synapse/transport/utils/conn/SynapseNHttpClientConnectionFactory.java
 Tue Dec 27 09:55:18 2016
@@ -17,7 +17,7 @@
  *  under the License.
  */
 
-package org.apache.synapse.transport.utils.conn.logging;
+package org.apache.synapse.transport.utils.conn;
 
 import org.apache.commons.logging.Log;
 import org.apache.commons.logging.LogFactory;
@@ -38,17 +38,21 @@ import org.apache.http.nio.reactor.Sessi
 import org.apache.http.nio.reactor.SessionOutputBuffer;
 import org.apache.http.nio.util.HeapByteBufferAllocator;
 import org.apache.synapse.transport.nhttp.AccessHandler;
+import org.apache.synapse.transport.utils.conn.SynapseNHttpClientConnection;
+import org.apache.synapse.transport.utils.conn.logging.LoggingConstants;
+import org.apache.synapse.transport.utils.conn.logging.LoggingIOSession;
+import 
org.apache.synapse.transport.utils.conn.logging.LoggingNHttpClientConnection;
 
 import java.io.IOException;
 
 /**
  * A connection factory implementation for DefaultNHttpClientConnection 
instances.
  * Based on the current logging configuration, this factory decides whether to 
create
- * regular DefaultNHttpClientConnection objects or to create 
LoggingNHttpClientConnection
+ * regular SynapseNHttpClientConnection objects or to create 
LoggingNHttpClientConnection
  * objects. Also, depending on the logging configuration, this factory may 
choose to
  * wrap IOSession instances in LoggingIOSession objects.
  */
-public class LoggingNHttpClientConnectionFactory implements 
NHttpConnectionFactory<DefaultNHttpClientConnection> {
+public class SynapseNHttpClientConnectionFactory implements 
NHttpConnectionFactory<DefaultNHttpClientConnection> {
 
     private static final Log targetConnLog = LogFactory.getLog(
             LoggingConstants.TARGET_CONNECTION_LOG_ID);
@@ -66,14 +70,14 @@ public class LoggingNHttpClientConnectio
 
     private final ConnectionConfig config;
 
-    public LoggingNHttpClientConnectionFactory(ConnectionConfig config) {
+    public SynapseNHttpClientConnectionFactory(ConnectionConfig config) {
         this.config = config;
     }
 
     public DefaultNHttpClientConnection createConnection(IOSession session) {
         if (targetSessionLog.isDebugEnabled() || 
targetWireLog.isDebugEnabled()) {
             session = new LoggingIOSession(targetSessionLog, targetWireLog,
-                    session, "http-sender");
+                                           session, "http-sender");
         }
 
         if (targetConnLog.isDebugEnabled() || 
targetHeaderLog.isDebugEnabled()) {
@@ -91,7 +95,7 @@ public class LoggingNHttpClientConnectio
                     responseParserFactory,
                     targetConnLog);
         } else {
-            return new DefaultNHttpClientConnection(
+            return new SynapseNHttpClientConnection(
                     session,
                     config.getBufferSize(),
                     config.getFragmentSizeHint(),

Copied: 
synapse/trunk/java/modules/transports/core/nhttp/src/main/java/org/apache/synapse/transport/utils/conn/SynapseNHttpSSLClientConnectionFactory.java
 (from r1776096, 
synapse/trunk/java/modules/transports/core/nhttp/src/main/java/org/apache/synapse/transport/utils/conn/logging/LoggingNHttpSSLClientConnectionFactory.java)
URL: 
http://svn.apache.org/viewvc/synapse/trunk/java/modules/transports/core/nhttp/src/main/java/org/apache/synapse/transport/utils/conn/SynapseNHttpSSLClientConnectionFactory.java?p2=synapse/trunk/java/modules/transports/core/nhttp/src/main/java/org/apache/synapse/transport/utils/conn/SynapseNHttpSSLClientConnectionFactory.java&p1=synapse/trunk/java/modules/transports/core/nhttp/src/main/java/org/apache/synapse/transport/utils/conn/logging/LoggingNHttpSSLClientConnectionFactory.java&r1=1776096&r2=1776100&rev=1776100&view=diff
==============================================================================
--- 
synapse/trunk/java/modules/transports/core/nhttp/src/main/java/org/apache/synapse/transport/utils/conn/logging/LoggingNHttpSSLClientConnectionFactory.java
 (original)
+++ 
synapse/trunk/java/modules/transports/core/nhttp/src/main/java/org/apache/synapse/transport/utils/conn/SynapseNHttpSSLClientConnectionFactory.java
 Tue Dec 27 09:55:18 2016
@@ -17,7 +17,7 @@
  *  under the License.
  */
 
-package org.apache.synapse.transport.utils.conn.logging;
+package org.apache.synapse.transport.utils.conn;
 
 import org.apache.http.config.ConnectionConfig;
 import org.apache.http.impl.nio.DefaultNHttpClientConnection;
@@ -31,18 +31,18 @@ import java.net.InetSocketAddress;
 import java.util.Map;
 
 /**
- * The SSL-enabled version of the LoggingNHttpClientConnectionFactory. 
Identical in behavior
+ * The SSL-enabled version of the SynapseNHttpClientConnectionFactory. 
Identical in behavior
  * to the parent class, but wraps IOSession instances with SSLIOSession 
instances. This
  * implementation also supports using different SSLContext instances for 
different target
  * I/O sessions.
  */
-public class LoggingNHttpSSLClientConnectionFactory extends 
LoggingNHttpClientConnectionFactory {
+public class SynapseNHttpSSLClientConnectionFactory extends 
SynapseNHttpClientConnectionFactory {
 
     private SSLContext sslContext;
     private SSLSetupHandler sslSetupHandler;
     private Map<String,SSLContext> customContexts;
 
-    public LoggingNHttpSSLClientConnectionFactory(ConnectionConfig config,
+    public SynapseNHttpSSLClientConnectionFactory(ConnectionConfig config,
                                                   SSLContext sslContext,
                                                   SSLSetupHandler 
sslSetupHandler,
                                                   Map<String, SSLContext> 
customContexts) {

Copied: 
synapse/trunk/java/modules/transports/core/nhttp/src/main/java/org/apache/synapse/transport/utils/conn/SynapseNHttpSSLServerConnectionFactory.java
 (from r1776096, 
synapse/trunk/java/modules/transports/core/nhttp/src/main/java/org/apache/synapse/transport/utils/conn/logging/LoggingNHttpSSLServerConnectionFactory.java)
URL: 
http://svn.apache.org/viewvc/synapse/trunk/java/modules/transports/core/nhttp/src/main/java/org/apache/synapse/transport/utils/conn/SynapseNHttpSSLServerConnectionFactory.java?p2=synapse/trunk/java/modules/transports/core/nhttp/src/main/java/org/apache/synapse/transport/utils/conn/SynapseNHttpSSLServerConnectionFactory.java&p1=synapse/trunk/java/modules/transports/core/nhttp/src/main/java/org/apache/synapse/transport/utils/conn/logging/LoggingNHttpSSLServerConnectionFactory.java&r1=1776096&r2=1776100&rev=1776100&view=diff
==============================================================================
--- 
synapse/trunk/java/modules/transports/core/nhttp/src/main/java/org/apache/synapse/transport/utils/conn/logging/LoggingNHttpSSLServerConnectionFactory.java
 (original)
+++ 
synapse/trunk/java/modules/transports/core/nhttp/src/main/java/org/apache/synapse/transport/utils/conn/SynapseNHttpSSLServerConnectionFactory.java
 Tue Dec 27 09:55:18 2016
@@ -17,7 +17,7 @@
  *  under the License.
  */
 
-package org.apache.synapse.transport.utils.conn.logging;
+package org.apache.synapse.transport.utils.conn;
 
 import org.apache.http.config.ConnectionConfig;
 import org.apache.http.impl.nio.DefaultNHttpServerConnection;
@@ -29,15 +29,15 @@ import org.apache.http.nio.reactor.ssl.S
 import javax.net.ssl.SSLContext;
 
 /**
- * The SSL-enabled version of the LoggingNHttpServerConnectionFactory. 
Identical in behavior
+ * The SSL-enabled version of the SynapseNHttpServerConnectionFactory. 
Identical in behavior
  * to the parent class, but wraps IOSession instances with SSLIOSession 
instances.
  */
-public class LoggingNHttpSSLServerConnectionFactory extends 
LoggingNHttpServerConnectionFactory {
+public class SynapseNHttpSSLServerConnectionFactory extends 
SynapseNHttpServerConnectionFactory {
 
     private SSLContext sslContext;
     private SSLSetupHandler sslSetupHandler;
 
-    public LoggingNHttpSSLServerConnectionFactory(ConnectionConfig config, 
SSLContext sslContext,
+    public SynapseNHttpSSLServerConnectionFactory(ConnectionConfig config, 
SSLContext sslContext,
                                                   SSLSetupHandler 
sslSetupHandler) {
         super(config);
         this.sslContext = sslContext;

Copied: 
synapse/trunk/java/modules/transports/core/nhttp/src/main/java/org/apache/synapse/transport/utils/conn/SynapseNHttpServerConnectionFactory.java
 (from r1776096, 
synapse/trunk/java/modules/transports/core/nhttp/src/main/java/org/apache/synapse/transport/utils/conn/logging/LoggingNHttpServerConnectionFactory.java)
URL: 
http://svn.apache.org/viewvc/synapse/trunk/java/modules/transports/core/nhttp/src/main/java/org/apache/synapse/transport/utils/conn/SynapseNHttpServerConnectionFactory.java?p2=synapse/trunk/java/modules/transports/core/nhttp/src/main/java/org/apache/synapse/transport/utils/conn/SynapseNHttpServerConnectionFactory.java&p1=synapse/trunk/java/modules/transports/core/nhttp/src/main/java/org/apache/synapse/transport/utils/conn/logging/LoggingNHttpServerConnectionFactory.java&r1=1776096&r2=1776100&rev=1776100&view=diff
==============================================================================
--- 
synapse/trunk/java/modules/transports/core/nhttp/src/main/java/org/apache/synapse/transport/utils/conn/logging/LoggingNHttpServerConnectionFactory.java
 (original)
+++ 
synapse/trunk/java/modules/transports/core/nhttp/src/main/java/org/apache/synapse/transport/utils/conn/SynapseNHttpServerConnectionFactory.java
 Tue Dec 27 09:55:18 2016
@@ -17,7 +17,7 @@
  *  under the License.
  */
 
-package org.apache.synapse.transport.utils.conn.logging;
+package org.apache.synapse.transport.utils.conn;
 
 import org.apache.commons.logging.Log;
 import org.apache.commons.logging.LogFactory;
@@ -38,6 +38,9 @@ import org.apache.http.nio.reactor.Sessi
 import org.apache.http.nio.reactor.SessionOutputBuffer;
 import org.apache.http.nio.util.HeapByteBufferAllocator;
 import org.apache.synapse.transport.nhttp.AccessHandler;
+import org.apache.synapse.transport.utils.conn.logging.LoggingConstants;
+import org.apache.synapse.transport.utils.conn.logging.LoggingIOSession;
+import 
org.apache.synapse.transport.utils.conn.logging.LoggingNHttpServerConnection;
 
 import java.io.IOException;
 
@@ -48,7 +51,7 @@ import java.io.IOException;
  * objects. Also, depending on the logging configuration, this factory may 
choose to
  * wrap IOSession instances in LoggingIOSession objects.
  */
-public class LoggingNHttpServerConnectionFactory implements 
NHttpConnectionFactory<DefaultNHttpServerConnection> {
+public class SynapseNHttpServerConnectionFactory implements 
NHttpConnectionFactory<DefaultNHttpServerConnection> {
 
     private static final Log sourceConnLog = LogFactory.getLog(
             LoggingConstants.SOURCE_CONNECTION_LOG_ID);
@@ -66,14 +69,14 @@ public class LoggingNHttpServerConnectio
 
     private final ConnectionConfig config;
 
-    public LoggingNHttpServerConnectionFactory(ConnectionConfig config) {
+    public SynapseNHttpServerConnectionFactory(ConnectionConfig config) {
         this.config = config;
     }
 
     public DefaultNHttpServerConnection createConnection(IOSession session) {
         if (sourceSessionLog.isDebugEnabled() || 
sourceWireLog.isDebugEnabled()) {
             session = new LoggingIOSession(sourceSessionLog, sourceWireLog,
-                    session, "http-listener");
+                                           session, "http-listener");
         }
 
         if (sourceConnLog.isDebugEnabled()) {

Modified: 
synapse/trunk/java/modules/transports/core/nhttp/src/main/java/org/apache/synapse/transport/utils/conn/logging/LoggingNHttpClientConnection.java
URL: 
http://svn.apache.org/viewvc/synapse/trunk/java/modules/transports/core/nhttp/src/main/java/org/apache/synapse/transport/utils/conn/logging/LoggingNHttpClientConnection.java?rev=1776100&r1=1776099&r2=1776100&view=diff
==============================================================================
--- 
synapse/trunk/java/modules/transports/core/nhttp/src/main/java/org/apache/synapse/transport/utils/conn/logging/LoggingNHttpClientConnection.java
 (original)
+++ 
synapse/trunk/java/modules/transports/core/nhttp/src/main/java/org/apache/synapse/transport/utils/conn/logging/LoggingNHttpClientConnection.java
 Tue Dec 27 09:55:18 2016
@@ -25,12 +25,12 @@ import org.apache.http.HttpRequest;
 import org.apache.http.HttpResponse;
 import org.apache.http.config.MessageConstraints;
 import org.apache.http.entity.ContentLengthStrategy;
-import org.apache.http.impl.nio.DefaultNHttpClientConnection;
 import org.apache.http.nio.NHttpClientEventHandler;
 import org.apache.http.nio.NHttpMessageParserFactory;
 import org.apache.http.nio.NHttpMessageWriterFactory;
 import org.apache.http.nio.reactor.IOSession;
 import org.apache.http.nio.util.ByteBufferAllocator;
+import org.apache.synapse.transport.utils.conn.SynapseNHttpClientConnection;
 
 import java.io.IOException;
 import java.nio.charset.CharsetDecoder;
@@ -41,7 +41,7 @@ import java.nio.charset.CharsetEncoder;
  * additional logging features. This implementation enhances the default 
connection
  * class by logging all the major events that occur on the connection instance.
  */
-public class LoggingNHttpClientConnection extends DefaultNHttpClientConnection 
{
+public class LoggingNHttpClientConnection extends SynapseNHttpClientConnection 
{
 
     private final Log log;
 

Modified: 
synapse/trunk/java/modules/transports/core/nhttp/src/main/java/org/apache/synapse/transport/utils/conn/logging/LoggingUtils.java
URL: 
http://svn.apache.org/viewvc/synapse/trunk/java/modules/transports/core/nhttp/src/main/java/org/apache/synapse/transport/utils/conn/logging/LoggingUtils.java?rev=1776100&r1=1776099&r2=1776100&view=diff
==============================================================================
--- 
synapse/trunk/java/modules/transports/core/nhttp/src/main/java/org/apache/synapse/transport/utils/conn/logging/LoggingUtils.java
 (original)
+++ 
synapse/trunk/java/modules/transports/core/nhttp/src/main/java/org/apache/synapse/transport/utils/conn/logging/LoggingUtils.java
 Tue Dec 27 09:55:18 2016
@@ -27,6 +27,10 @@ import org.apache.http.impl.nio.DefaultH
 import org.apache.http.nio.NHttpClientEventHandler;
 import org.apache.http.nio.NHttpServerEventHandler;
 import org.apache.http.nio.reactor.ssl.SSLSetupHandler;
+import 
org.apache.synapse.transport.utils.conn.SynapseNHttpClientConnectionFactory;
+import 
org.apache.synapse.transport.utils.conn.SynapseNHttpSSLClientConnectionFactory;
+import 
org.apache.synapse.transport.utils.conn.SynapseNHttpSSLServerConnectionFactory;
+import 
org.apache.synapse.transport.utils.conn.SynapseNHttpServerConnectionFactory;
 
 import javax.net.ssl.SSLContext;
 import java.util.Map;
@@ -45,7 +49,7 @@ public class LoggingUtils {
     public static DefaultHttpServerIODispatch getServerIODispatch(final 
NHttpServerEventHandler handler,
                                                                   final 
ConnectionConfig config) {
         return new DefaultHttpServerIODispatch(decorate(handler),
-                new LoggingNHttpServerConnectionFactory(config));
+                new SynapseNHttpServerConnectionFactory(config));
     }
 
     /**
@@ -64,7 +68,7 @@ public class LoggingUtils {
                                                                   final 
SSLContext sslContext,
                                                                   final 
SSLSetupHandler sslSetupHandler) {
         return new DefaultHttpServerIODispatch(decorate(handler),
-                new LoggingNHttpSSLServerConnectionFactory(config, sslContext, 
sslSetupHandler));
+                new SynapseNHttpSSLServerConnectionFactory(config, sslContext, 
sslSetupHandler));
     }
 
     /**
@@ -79,7 +83,7 @@ public class LoggingUtils {
     public static DefaultHttpClientIODispatch getClientIODispatch(final 
NHttpClientEventHandler handler,
                                                                   final 
ConnectionConfig config) {
         return new DefaultHttpClientIODispatch(decorate(handler),
-                new LoggingNHttpClientConnectionFactory(config));
+                new SynapseNHttpClientConnectionFactory(config));
     }
 
     /**
@@ -100,7 +104,7 @@ public class LoggingUtils {
                                                                   final 
SSLSetupHandler sslSetupHandler,
                                                                   Map<String, 
SSLContext> customContexts) {
         return new DefaultHttpClientIODispatch(decorate(handler),
-                new LoggingNHttpSSLClientConnectionFactory(config, sslContext, 
sslSetupHandler, customContexts));
+                new SynapseNHttpSSLClientConnectionFactory(config, sslContext, 
sslSetupHandler, customContexts));
     }
 
     private static NHttpClientEventHandler decorate(NHttpClientEventHandler 
handler) {


Reply via email to