svn commit: r784543 - 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: Sun Jun 14 11:33:02 2009
New Revision: 784543

URL: http://svn.apache.org/viewvc?rev=784543&view=rev
Log:
Some changes to adapt to changes in WS-Commons transport.

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/PipeListener.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=784543&r1=784542&r2=784543&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
 Sun Jun 14 11:33:02 2009
@@ -47,7 +47,8 @@
     }
 
     @Override
-       public EndpointReference getEndpointReference(String ip) {
-               return new EndpointReference("pipe://" + pipe.getAbsolutePath() 
+ "?contentType=" + getContentType());
+       public EndpointReference[] getEndpointReferences(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/PipeListener.java
URL: 
http://svn.apache.org/viewvc/synapse/trunk/java/modules/transports/core/pipe/src/main/java/org/apache/synapse/transport/pipe/PipeListener.java?rev=784543&r1=784542&r2=784543&view=diff
==============================================================================
--- 
synapse/trunk/java/modules/transports/core/pipe/src/main/java/org/apache/synapse/transport/pipe/PipeListener.java
 (original)
+++ 
synapse/trunk/java/modules/transports/core/pipe/src/main/java/org/apache/synapse/transport/pipe/PipeListener.java
 Sun Jun 14 11:33:02 2009
@@ -85,10 +85,14 @@
     }
 
     @Override
-    protected PipeEndpoint createEndpoint(AxisService service) throws 
AxisFault {
-        PipeEndpoint endpoint = new PipeEndpoint();
+    protected PipeEndpoint createEndpoint() {
+        return new PipeEndpoint();
+    }
+
+    @Override
+    protected void configureAndStartEndpoint(PipeEndpoint endpoint, 
AxisService service) throws AxisFault {
         endpoint.setPipe(new File(ParamUtils.getRequiredParam(service, 
PipeConstants.NAME_KEY)));
         endpoint.setProtocol(protocol);
-        return endpoint;
+        super.configureAndStartEndpoint(endpoint, service);
     }
 }

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=784543&r1=784542&r2=784543&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
 Sun Jun 14 11:33:02 2009
@@ -62,8 +62,8 @@
     private long reconnectTimeout;
 
     @Override
-    public EndpointReference getEndpointReference() {
-        return new EndpointReference("vfs:" + fileURI);
+    public EndpointReference[] getEndpointReferences(String ip) {
+        return new EndpointReference[] { new EndpointReference("vfs:" + 
fileURI) };
     }
 
     public String getFileURI() {