svn commit: r947925 - in /synapse/trunk/java/modules/transports/core: pipe/src/main/java/org/apache/synapse/transport/pipe/ vfs/src/main/java/org/apache/synapse/transport/vfs/

[veithen]

Author: veithen
Date: Tue May 25 05:37:14 2010
New Revision: 947925

URL: http://svn.apache.org/viewvc?rev=947925&view=rev
Log:
Adapted the pipe and VFS transports to recent changes in the base transport 
(AbstractTransportListenerEx).

Modified:
    
synapse/trunk/java/modules/transports/core/pipe/src/main/java/org/apache/synapse/transport/pipe/PipeEndpoint.java
    
synapse/trunk/java/modules/transports/core/pipe/src/main/java/org/apache/synapse/transport/pipe/PipeEndpointListener.java
    
synapse/trunk/java/modules/transports/core/vfs/src/main/java/org/apache/synapse/transport/vfs/PollTableEntry.java

Modified: 
synapse/trunk/java/modules/transports/core/pipe/src/main/java/org/apache/synapse/transport/pipe/PipeEndpoint.java
URL: 
http://svn.apache.org/viewvc/synapse/trunk/java/modules/transports/core/pipe/src/main/java/org/apache/synapse/transport/pipe/PipeEndpoint.java?rev=947925&r1=947924&r2=947925&view=diff
==============================================================================
--- 
synapse/trunk/java/modules/transports/core/pipe/src/main/java/org/apache/synapse/transport/pipe/PipeEndpoint.java
 (original)
+++ 
synapse/trunk/java/modules/transports/core/pipe/src/main/java/org/apache/synapse/transport/pipe/PipeEndpoint.java
 Tue May 25 05:37:14 2010
@@ -22,6 +22,7 @@ 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;
@@ -56,7 +57,7 @@ public class PipeEndpoint extends Datagr
     }
 
     @Override
-       public EndpointReference[] getEndpointReferences(String ip) {
+       public EndpointReference[] getEndpointReferences(AxisService service, 
String ip) {
                return new EndpointReference[] { new 
EndpointReference("pipe://" + pipe.getAbsolutePath()
                        + "?contentType=" + getContentType()) };
        }

Modified: 
synapse/trunk/java/modules/transports/core/pipe/src/main/java/org/apache/synapse/transport/pipe/PipeEndpointListener.java
URL: 
http://svn.apache.org/viewvc/synapse/trunk/java/modules/transports/core/pipe/src/main/java/org/apache/synapse/transport/pipe/PipeEndpointListener.java?rev=947925&r1=947924&r2=947925&view=diff
==============================================================================
--- 
synapse/trunk/java/modules/transports/core/pipe/src/main/java/org/apache/synapse/transport/pipe/PipeEndpointListener.java
 (original)
+++ 
synapse/trunk/java/modules/transports/core/pipe/src/main/java/org/apache/synapse/transport/pipe/PipeEndpointListener.java
 Tue May 25 05:37:14 2010
@@ -104,7 +104,7 @@ public class PipeEndpointListener implem
                         readBuffer.rewind();
                     }
                     byte[] message = decoder.getNext();
-                    callback.receive(null, endpoint, message, message.length);
+                    callback.receive(endpoint, message, message.length, null);
                 }
             }
         }

Modified: 
synapse/trunk/java/modules/transports/core/vfs/src/main/java/org/apache/synapse/transport/vfs/PollTableEntry.java
URL: 
http://svn.apache.org/viewvc/synapse/trunk/java/modules/transports/core/vfs/src/main/java/org/apache/synapse/transport/vfs/PollTableEntry.java?rev=947925&r1=947924&r2=947925&view=diff
==============================================================================
--- 
synapse/trunk/java/modules/transports/core/vfs/src/main/java/org/apache/synapse/transport/vfs/PollTableEntry.java
 (original)
+++ 
synapse/trunk/java/modules/transports/core/vfs/src/main/java/org/apache/synapse/transport/vfs/PollTableEntry.java
 Tue May 25 05:37:14 2010
@@ -20,6 +20,7 @@ package org.apache.synapse.transport.vfs
 
 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.AbstractPollTableEntry;
 import org.apache.axis2.transport.base.ParamUtils;
@@ -73,7 +74,7 @@ public class PollTableEntry extends Abst
     }
 
     @Override
-    public EndpointReference[] getEndpointReferences(String ip) {
+    public EndpointReference[] getEndpointReferences(AxisService service, 
String ip) {
         return new EndpointReference[] { new EndpointReference("vfs:" + 
fileURI) };
     }