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

[ve...@apache.org]

Author: veithen
Date: Fri May 29 22:16:07 2009
New Revision: 780126

URL: http://svn.apache.org/viewvc?rev=780126&view=rev
Log:
Documentation update and minor generalization.

Modified:
    webservices/commons/trunk/modules/tcpmon/modules/tcpmon-core/src/main/java/org/apache/ws/commons/tcpmon/core/Connection.java
    webservices/commons/trunk/modules/tcpmon/modules/tcpmon-core/src/main/java/org/apache/ws/commons/tcpmon/core/IRequestResponse.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=780126&r1=780125&r2=780126&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:16:07 2009
@@ -147,7 +147,10 @@
             // We log the request data at this stage. This means that the user will see the request
             // as if it had been sent directly from the client to the server (without TCPMon or a proxy
             // in between).
-            requestPipeline.addFilter(new Tee(requestResponse.getRequestOutputStream()));
+            OutputStream requestOutputStream = requestResponse.getRequestOutputStream();
+            if (requestOutputStream != null) {
+                requestPipeline.addFilter(new Tee(requestOutputStream));
+            }
             if (HTTPProxyHost != null) {
                 requestFilter.addHandler(new HttpProxyClientHandler(targetHost, targetPort));
                 outSocket = socketFactory.createSocket(HTTPProxyHost, HTTPProxyPort);
@@ -176,7 +179,10 @@
             if (tmpOut1 != null) {
                 responsePipeline.addFilter(new Tee(tmpOut1));
             }
-            responsePipeline.addFilter(new Tee(requestResponse.getResponseOutputStream()));
+            OutputStream responseOutputStream = requestResponse.getResponseOutputStream();
+            if (responseOutputStream != null) {
+                responsePipeline.addFilter(new Tee(responseOutputStream));
+            }
             
             // this is the channel to the endpoint
             rr1 = new SocketRR(this, inSocket, tmpIn1, outSocket, tmpOut2, requestPipeline);

Modified: webservices/commons/trunk/modules/tcpmon/modules/tcpmon-core/src/main/java/org/apache/ws/commons/tcpmon/core/IRequestResponse.java
URL: http://svn.apache.org/viewvc/webservices/commons/trunk/modules/tcpmon/modules/tcpmon-core/src/main/java/org/apache/ws/commons/tcpmon/core/IRequestResponse.java?rev=780126&r1=780125&r2=780126&view=diff
==============================================================================
--- webservices/commons/trunk/modules/tcpmon/modules/tcpmon-core/src/main/java/org/apache/ws/commons/tcpmon/core/IRequestResponse.java (original)
+++ webservices/commons/trunk/modules/tcpmon/modules/tcpmon-core/src/main/java/org/apache/ws/commons/tcpmon/core/IRequestResponse.java Fri May 29 22:16:07 2009
@@ -31,7 +31,22 @@
     void setTarget(String targetHost, int targetPort);
     void setState(int state);
     void setElapsed(long elapsed);
+    
+    /**
+     * Get the output stream to which a copy of the request will be written.
+     * 
+     * @return an output stream or <code>null</code> if the implementation doesn't
+     *         want to receive a copy of the request
+     */
     OutputStream getRequestOutputStream();
+    
+    /**
+     * Get the output stream to which a copy of the response will be written
+     * 
+     * @return an output stream or <code>null</code> if the implementation doesn't
+     *         want to receive a copy of the response
+     */
     OutputStream getResponseOutputStream();
+    
     void onError(Throwable ex);
 }