svn commit: r1000112 - in /synapse/branches/2.0/modules/transports/core/pipe/src/main/java/org/apache/synapse/transport/pipe: PipeEndpoint.java PipeEndpointListener.java PipeListener.java

[ruwan]

Author: ruwan
Date: Wed Sep 22 18:02:12 2010
New Revision: 1000112

URL: http://svn.apache.org/viewvc?rev=1000112&view=rev
Log:
Backporting the PIPE transport

Modified:
    
synapse/branches/2.0/modules/transports/core/pipe/src/main/java/org/apache/synapse/transport/pipe/PipeEndpoint.java
    
synapse/branches/2.0/modules/transports/core/pipe/src/main/java/org/apache/synapse/transport/pipe/PipeEndpointListener.java
    
synapse/branches/2.0/modules/transports/core/pipe/src/main/java/org/apache/synapse/transport/pipe/PipeListener.java

Modified: 
synapse/branches/2.0/modules/transports/core/pipe/src/main/java/org/apache/synapse/transport/pipe/PipeEndpoint.java
URL: 
http://svn.apache.org/viewvc/synapse/branches/2.0/modules/transports/core/pipe/src/main/java/org/apache/synapse/transport/pipe/PipeEndpoint.java?rev=1000112&r1=1000111&r2=1000112&view=diff
==============================================================================
--- 
synapse/branches/2.0/modules/transports/core/pipe/src/main/java/org/apache/synapse/transport/pipe/PipeEndpoint.java
 (original)
+++ 
synapse/branches/2.0/modules/transports/core/pipe/src/main/java/org/apache/synapse/transport/pipe/PipeEndpoint.java
 Wed Sep 22 18:02:12 2010
@@ -22,7 +22,6 @@ import java.io.File;
 
 import org.apache.axis2.AxisFault;
 import org.apache.axis2.addressing.EndpointReference;
-import org.apache.axis2.description.AxisService;
 import org.apache.axis2.description.ParameterInclude;
 import org.apache.axis2.transport.base.ParamUtils;
 import org.apache.axis2.transport.base.datagram.DatagramEndpoint;
@@ -57,7 +56,7 @@ public class PipeEndpoint extends Datagr
     }
 
     @Override
-       public EndpointReference[] getEndpointReferences(AxisService service, 
String ip) {
+       public EndpointReference[] getEndpointReferences(String ip) {
                return new EndpointReference[] { new 
EndpointReference("pipe://" + pipe.getAbsolutePath()
                        + "?contentType=" + getContentType()) };
        }

Modified: 
synapse/branches/2.0/modules/transports/core/pipe/src/main/java/org/apache/synapse/transport/pipe/PipeEndpointListener.java
URL: 
http://svn.apache.org/viewvc/synapse/branches/2.0/modules/transports/core/pipe/src/main/java/org/apache/synapse/transport/pipe/PipeEndpointListener.java?rev=1000112&r1=1000111&r2=1000112&view=diff
==============================================================================
--- 
synapse/branches/2.0/modules/transports/core/pipe/src/main/java/org/apache/synapse/transport/pipe/PipeEndpointListener.java
 (original)
+++ 
synapse/branches/2.0/modules/transports/core/pipe/src/main/java/org/apache/synapse/transport/pipe/PipeEndpointListener.java
 Wed Sep 22 18:02:12 2010
@@ -104,7 +104,7 @@ public class PipeEndpointListener implem
                         readBuffer.rewind();
                     }
                     byte[] message = decoder.getNext();
-                    callback.receive(endpoint, message, message.length, null);
+                    callback.receive(endpoint, message, message.length);
                 }
             }
         }

Modified: 
synapse/branches/2.0/modules/transports/core/pipe/src/main/java/org/apache/synapse/transport/pipe/PipeListener.java
URL: 
http://svn.apache.org/viewvc/synapse/branches/2.0/modules/transports/core/pipe/src/main/java/org/apache/synapse/transport/pipe/PipeListener.java?rev=1000112&r1=1000111&r2=1000112&view=diff
==============================================================================
--- 
synapse/branches/2.0/modules/transports/core/pipe/src/main/java/org/apache/synapse/transport/pipe/PipeListener.java
 (original)
+++ 
synapse/branches/2.0/modules/transports/core/pipe/src/main/java/org/apache/synapse/transport/pipe/PipeListener.java
 Wed Sep 22 18:02:12 2010
@@ -21,6 +21,7 @@ package org.apache.synapse.transport.pip
 import java.io.IOException;
 
 import org.apache.axis2.AxisFault;
+import org.apache.axis2.context.ConfigurationContext;
 import org.apache.axis2.description.TransportInDescription;
 import org.apache.axis2.transport.base.ManagementSupport;
 import org.apache.axis2.transport.base.ParamUtils;
@@ -55,8 +56,8 @@ public class PipeListener extends Abstra
     private Protocol protocol;
     
     @Override
-    protected void doInit() throws AxisFault {
-        TransportInDescription transportIn = getTransportInDescription();
+    public void init(ConfigurationContext cfgCtx, TransportInDescription 
transportIn) throws AxisFault {
+        super.init(cfgCtx, transportIn);
         String protocolClassName = ParamUtils.getRequiredParam(transportIn, 
"protocol");
         Class<? extends Protocol> protocolClass;
         try {