Author: ruwan
Date: Wed Sep 22 18:01:17 2010
New Revision: 1000111
URL: http://svn.apache.org/viewvc?rev=1000111&view=rev
Log:
Backporting the VFS transport
Modified:
synapse/branches/2.0/modules/transports/core/vfs/src/main/java/org/apache/synapse/transport/vfs/PollTableEntry.java
synapse/branches/2.0/modules/transports/core/vfs/src/main/java/org/apache/synapse/transport/vfs/VFSTransportListener.java
Modified:
synapse/branches/2.0/modules/transports/core/vfs/src/main/java/org/apache/synapse/transport/vfs/PollTableEntry.java
URL:
http://svn.apache.org/viewvc/synapse/branches/2.0/modules/transports/core/vfs/src/main/java/org/apache/synapse/transport/vfs/PollTableEntry.java?rev=1000111&r1=1000110&r2=1000111&view=diff
==============================================================================
---
synapse/branches/2.0/modules/transports/core/vfs/src/main/java/org/apache/synapse/transport/vfs/PollTableEntry.java
(original)
+++
synapse/branches/2.0/modules/transports/core/vfs/src/main/java/org/apache/synapse/transport/vfs/PollTableEntry.java
Wed Sep 22 18:01:17 2010
@@ -20,7 +20,6 @@ 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;
@@ -74,7 +73,7 @@ public class PollTableEntry extends Abst
}
@Override
- public EndpointReference[] getEndpointReferences(AxisService service,
String ip) {
+ public EndpointReference[] getEndpointReferences(String ip) {
return new EndpointReference[] { new EndpointReference("vfs:" +
fileURI) };
}
Modified:
synapse/branches/2.0/modules/transports/core/vfs/src/main/java/org/apache/synapse/transport/vfs/VFSTransportListener.java
URL:
http://svn.apache.org/viewvc/synapse/branches/2.0/modules/transports/core/vfs/src/main/java/org/apache/synapse/transport/vfs/VFSTransportListener.java?rev=1000111&r1=1000110&r2=1000111&view=diff
==============================================================================
---
synapse/branches/2.0/modules/transports/core/vfs/src/main/java/org/apache/synapse/transport/vfs/VFSTransportListener.java
(original)
+++
synapse/branches/2.0/modules/transports/core/vfs/src/main/java/org/apache/synapse/transport/vfs/VFSTransportListener.java
Wed Sep 22 18:01:17 2010
@@ -24,7 +24,9 @@ import org.apache.axis2.Constants;
import org.apache.axis2.builder.Builder;
import org.apache.axis2.builder.BuilderUtil;
import org.apache.axis2.builder.SOAPBuilder;
+import org.apache.axis2.context.ConfigurationContext;
import org.apache.axis2.context.MessageContext;
+import org.apache.axis2.description.TransportInDescription;
import org.apache.axis2.description.Parameter;
import org.apache.axis2.format.DataSourceMessageBuilder;
import org.apache.axis2.format.ManagedDataSource;
@@ -119,14 +121,15 @@ public class VFSTransportListener extend
private boolean globalFileLockingFlag = true;
@Override
- protected void doInit() throws AxisFault {
- super.doInit();
+ public void init(ConfigurationContext cfgCtx, TransportInDescription
trpInDesc)
+ throws AxisFault {
+ super.init(cfgCtx, trpInDesc);
try {
StandardFileSystemManager fsm = new StandardFileSystemManager();
fsm.setConfiguration(getClass().getClassLoader().getResource("providers.xml"));
fsm.init();
fsManager = fsm;
- Parameter lockFlagParam =
getTransportInDescription().getParameter(VFSConstants.TRANSPORT_FILE_LOCKING);
+ Parameter lockFlagParam =
trpInDesc.getParameter(VFSConstants.TRANSPORT_FILE_LOCKING);
if (lockFlagParam != null) {
String strLockingFlag = lockFlagParam.getValue().toString();
// by-default enabled, if explicitly specified as "disable"
make it disable
