svn commit: r780128 - /webservices/commons/trunk/modules/tcpmon/modules/tcpmon-core/src/main/java/org/apache/ws/commons/tcpmon/core/Connection.java

[veithen]

Author: veithen
Date: Fri May 29 22:25:39 2009
New Revision: 780128

URL: http://svn.apache.org/viewvc?rev=780128&view=rev
Log:
Removed dead code.

Modified:
    
webservices/commons/trunk/modules/tcpmon/modules/tcpmon-core/src/main/java/org/apache/ws/commons/tcpmon/core/Connection.java

Modified: 
webservices/commons/trunk/modules/tcpmon/modules/tcpmon-core/src/main/java/org/apache/ws/commons/tcpmon/core/Connection.java
URL: 
http://svn.apache.org/viewvc/webservices/commons/trunk/modules/tcpmon/modules/tcpmon-core/src/main/java/org/apache/ws/commons/tcpmon/core/Connection.java?rev=780128&r1=780127&r2=780128&view=diff
==============================================================================
--- 
webservices/commons/trunk/modules/tcpmon/modules/tcpmon-core/src/main/java/org/apache/ws/commons/tcpmon/core/Connection.java
 (original)
+++ 
webservices/commons/trunk/modules/tcpmon/modules/tcpmon-core/src/main/java/org/apache/ws/commons/tcpmon/core/Connection.java
 Fri May 29 22:25:39 2009
@@ -65,11 +65,6 @@
      */
     private SocketRR rr2 = null;
 
-    /**
-     * Field inputStream
-     */
-    private InputStream inputStream = null;
-    
     private IRequestResponse requestResponse;
 
     /**
@@ -85,18 +80,6 @@
     }
 
     /**
-     * Constructor Connection
-     *
-     * @param listener
-     * @param in
-     */
-    public Connection(AbstractListener listener, InputStream in) {
-        this.listener = listener;
-        config = listener.getConfiguration();
-        inputStream = in;
-    }
-
-    /**
      * Method run
      */
     public void run() {
@@ -106,24 +89,11 @@
             int HTTPProxyPort = config.getHttpProxyPort();
             ThrottleConfiguration throttleConfig = 
config.getThrottleConfiguration();
             final SocketFactory socketFactory = config.getSocketFactory();
-            String fromHost;
-            if (inSocket != null) {
-                fromHost = (inSocket.getInetAddress()).getHostName();
-            } else {
-                fromHost = "resend";
-            }
             String targetHost = config.getTargetHost();
-            requestResponse = listener.createRequestResponse(fromHost);
+            requestResponse = 
listener.createRequestResponse(inSocket.getInetAddress().getHostName());
             int targetPort = config.getTargetPort();
-            InputStream tmpIn1 = inputStream;
-            OutputStream tmpOut1 = null;
-            OutputStream tmpOut2 = null;
-            if (tmpIn1 == null) {
-                tmpIn1 = inSocket.getInputStream();
-            }
-            if (inSocket != null) {
-                tmpOut1 = inSocket.getOutputStream();
-            }
+            InputStream tmpIn1 = inSocket.getInputStream();
+            OutputStream tmpOut1 = inSocket.getOutputStream();
             
             Pipeline requestPipeline = new Pipeline();
             HttpRequestFilter requestFilter = new HttpRequestFilter(false);
@@ -169,7 +139,7 @@
                 requestPipeline.readFrom(tmpIn1);
             }
             
-            tmpOut2 = outSocket.getOutputStream();
+            OutputStream tmpOut2 = outSocket.getOutputStream();
             requestTee.setOutputStream(tmpOut2);
             
             Pipeline responsePipeline = new Pipeline();