You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@synapse.apache.org by ve...@apache.org on 2009/06/14 13:33:03 UTC
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/
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() {