axis-java-dev mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From d...@apache.org
Subject svn commit: r289289 [25/134] - in /webservices/axis2/trunk/java: ./ etc/ modules/addressing/ modules/addressing/src/META-INF/ modules/addressing/src/org/apache/axis2/handlers/addressing/ modules/addressing/test-resources/ modules/addressing/test/org/ap...
Date Thu, 15 Sep 2005 19:07:03 GMT
Modified: webservices/axis2/trunk/java/modules/core/src/org/apache/axis2/transport/tcp/TCPTransportSender.java
URL: http://svn.apache.org/viewcvs/webservices/axis2/trunk/java/modules/core/src/org/apache/axis2/transport/tcp/TCPTransportSender.java?rev=289289&r1=289288&r2=289289&view=diff
==============================================================================
--- webservices/axis2/trunk/java/modules/core/src/org/apache/axis2/transport/tcp/TCPTransportSender.java
(original)
+++ webservices/axis2/trunk/java/modules/core/src/org/apache/axis2/transport/tcp/TCPTransportSender.java
Thu Sep 15 11:52:11 2005
@@ -1,123 +1,123 @@
-/*
-* Copyright 2004,2005 The Apache Software Foundation.
-*
-* Licensed 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.axis2.transport.tcp;
-
-import org.apache.axis2.AxisFault;
-import org.apache.axis2.addressing.EndpointReference;
-import org.apache.axis2.context.MessageContext;
-import org.apache.axis2.i18n.Messages;
-import org.apache.axis2.transport.AbstractTransportSender;
-import org.apache.axis2.util.URL;
-
-import java.io.ByteArrayOutputStream;
-import java.io.IOException;
-import java.io.OutputStream;
-import java.io.Writer;
-import java.net.InetSocketAddress;
-import java.net.MalformedURLException;
-import java.net.Socket;
-import java.net.SocketAddress;
-
-
-public class TCPTransportSender extends AbstractTransportSender {
-    /**
-     * Field out
-     */
-    protected Writer out;
-
-    /**
-     * Field socket
-     */
-    private Socket socket;
-    private ByteArrayOutputStream outputStream;
-
-    /**
-     * Method writeTransportHeaders
-     *
-     * @param out
-     * @param url
-     * @param msgContext
-     * @throws IOException
-     */
-    protected void writeTransportHeaders(Writer out,
-                                         URL url,
-                                         MessageContext msgContext,
-                                         int contentLength)
-            throws IOException {
-        //TCP no headers   :)
-    }
-
-    public void finalizeSendWithOutputStreamFromIncomingConnection(
-            MessageContext msgContext, OutputStream out) {
-    }
-
-    public void finalizeSendWithToAddress(MessageContext msgContext,
-                                          OutputStream out) throws AxisFault {
-        try {
-            socket.shutdownOutput();
-            msgContext.setProperty(MessageContext.TRANSPORT_IN,
-                    socket.getInputStream());
-        } catch (IOException e) {
-            throw new AxisFault(e);
-        }
-    }
-
-    protected OutputStream openTheConnection(EndpointReference toURL,
-                                             MessageContext msgContext) throws AxisFault
{
-        if (toURL != null) {
-            try {
-                URL url = new URL(toURL.getAddress());
-                SocketAddress add =
-                        new InetSocketAddress(url.getHost(),
-                                url.getPort() == -1 ? 80 : url.getPort());
-                socket = new Socket();
-                socket.connect(add);
-                return socket.getOutputStream();
-            } catch (MalformedURLException e) {
-                throw new AxisFault(e.getMessage(), e);
-            } catch (IOException e) {
-                throw new AxisFault(e.getMessage(), e);
-            }
-        } else {
-            throw new AxisFault(Messages.getMessage("canNotBeNull","Can not Be Null"));
-        }
-    }
-
-    public OutputStream startSendWithOutputStreamFromIncomingConnection(
-            MessageContext msgContext,
-            OutputStream out)
-            throws AxisFault {
-        return out;
-    }
-
-    public OutputStream startSendWithToAddress(MessageContext msgContext,
-                                               OutputStream out) {
-        return out;
-    }
-
-    public void cleanUp(MessageContext msgContext) throws AxisFault {
-        try {
-            if (socket != null) {
-                socket.close();
-                socket = null;
-            }
-
-        } catch (IOException e) {
-        }
-
-    }
-
-}
+/*
+* Copyright 2004,2005 The Apache Software Foundation.
+*
+* Licensed 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.axis2.transport.tcp;
+
+import org.apache.axis2.AxisFault;
+import org.apache.axis2.addressing.EndpointReference;
+import org.apache.axis2.context.MessageContext;
+import org.apache.axis2.i18n.Messages;
+import org.apache.axis2.transport.AbstractTransportSender;
+import org.apache.axis2.util.URL;
+
+import java.io.ByteArrayOutputStream;
+import java.io.IOException;
+import java.io.OutputStream;
+import java.io.Writer;
+import java.net.InetSocketAddress;
+import java.net.MalformedURLException;
+import java.net.Socket;
+import java.net.SocketAddress;
+
+
+public class TCPTransportSender extends AbstractTransportSender {
+    /**
+     * Field out
+     */
+    protected Writer out;
+
+    /**
+     * Field socket
+     */
+    private Socket socket;
+    private ByteArrayOutputStream outputStream;
+
+    /**
+     * Method writeTransportHeaders
+     *
+     * @param out
+     * @param url
+     * @param msgContext
+     * @throws IOException
+     */
+    protected void writeTransportHeaders(Writer out,
+                                         URL url,
+                                         MessageContext msgContext,
+                                         int contentLength)
+            throws IOException {
+        //TCP no headers   :)
+    }
+
+    public void finalizeSendWithOutputStreamFromIncomingConnection(
+            MessageContext msgContext, OutputStream out) {
+    }
+
+    public void finalizeSendWithToAddress(MessageContext msgContext,
+                                          OutputStream out) throws AxisFault {
+        try {
+            socket.shutdownOutput();
+            msgContext.setProperty(MessageContext.TRANSPORT_IN,
+                    socket.getInputStream());
+        } catch (IOException e) {
+            throw new AxisFault(e);
+        }
+    }
+
+    protected OutputStream openTheConnection(EndpointReference toURL,
+                                             MessageContext msgContext) throws AxisFault
{
+        if (toURL != null) {
+            try {
+                URL url = new URL(toURL.getAddress());
+                SocketAddress add =
+                        new InetSocketAddress(url.getHost(),
+                                url.getPort() == -1 ? 80 : url.getPort());
+                socket = new Socket();
+                socket.connect(add);
+                return socket.getOutputStream();
+            } catch (MalformedURLException e) {
+                throw new AxisFault(e.getMessage(), e);
+            } catch (IOException e) {
+                throw new AxisFault(e.getMessage(), e);
+            }
+        } else {
+            throw new AxisFault(Messages.getMessage("canNotBeNull","Can not Be Null"));
+        }
+    }
+
+    public OutputStream startSendWithOutputStreamFromIncomingConnection(
+            MessageContext msgContext,
+            OutputStream out)
+            throws AxisFault {
+        return out;
+    }
+
+    public OutputStream startSendWithToAddress(MessageContext msgContext,
+                                               OutputStream out) {
+        return out;
+    }
+
+    public void cleanUp(MessageContext msgContext) throws AxisFault {
+        try {
+            if (socket != null) {
+                socket.close();
+                socket = null;
+            }
+
+        } catch (IOException e) {
+        }
+
+    }
+
+}

Propchange: webservices/axis2/trunk/java/modules/core/src/org/apache/axis2/transport/tcp/TCPTransportSender.java
------------------------------------------------------------------------------
    svn:eol-style = native

Propchange: webservices/axis2/trunk/java/modules/core/src/org/apache/axis2/transport/tcp/TCPWorker.java
------------------------------------------------------------------------------
    svn:eol-style = native

Propchange: webservices/axis2/trunk/java/modules/core/src/org/apache/axis2/util/URL.java
------------------------------------------------------------------------------
    svn:eol-style = native

Propchange: webservices/axis2/trunk/java/modules/core/src/org/apache/axis2/util/Utils.java
------------------------------------------------------------------------------
    svn:eol-style = native



Mime
View raw message