Package org.apache.synapse.transport.vfs
Class VFSTransportSender
- java.lang.Object
-
- org.apache.axis2.handlers.AbstractHandler
-
- org.apache.axis2.transport.base.AbstractTransportSender
-
- org.apache.synapse.transport.vfs.VFSTransportSender
-
- All Implemented Interfaces:
org.apache.axis2.engine.Handler
,org.apache.axis2.transport.base.ManagementSupport
,org.apache.axis2.transport.TransportSender
public class VFSTransportSender extends org.apache.axis2.transport.base.AbstractTransportSender implements org.apache.axis2.transport.base.ManagementSupport
axis2.xml - transport definitionenable|disable ?
-
-
Field Summary
Fields Modifier and Type Field Description static String
TRANSPORT_NAME
-
Constructor Summary
Constructors Constructor Description VFSTransportSender()
The public constructor
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description protected void
acquireLockForSending(org.apache.commons.vfs2.FileObject responseFile, org.apache.synapse.commons.vfs.VFSOutTransportInfo vfsOutInfo, org.apache.commons.vfs2.FileSystemOptions fso)
org.apache.commons.vfs2.FileSystemManager
getFsManager()
The VFS file system managervoid
init(org.apache.axis2.context.ConfigurationContext cfgCtx, org.apache.axis2.description.TransportOutDescription transportOut)
Initialize the VFS file system manager and be ready to send messagesprotected void
populateResponseFile(org.apache.commons.vfs2.FileObject responseFile, org.apache.axis2.context.MessageContext msgContext, boolean append, boolean lockingEnabled, org.apache.commons.vfs2.FileSystemOptions fso)
void
sendMessage(org.apache.axis2.context.MessageContext msgCtx, String targetAddress, org.apache.axis2.transport.OutTransportInfo outTransportInfo)
Send the given message over the VFS transportvoid
setFsManager(org.apache.commons.vfs2.FileSystemManager fsManager)
protected void
writeFile(org.apache.axis2.context.MessageContext msgCtx, org.apache.synapse.commons.vfs.VFSOutTransportInfo vfsOutInfo)
-
Methods inherited from class org.apache.axis2.transport.base.AbstractTransportSender
cleanup, createResponseMessageContext, getActiveThreadCount, getAvgSizeReceived, getAvgSizeSent, getBytesReceived, getBytesSent, getFaultsReceiving, getFaultsSending, getLastResetTime, getMaxSizeReceived, getMaxSizeSent, getMessagesReceived, getMessagesSent, getMetricsWindow, getMinSizeReceived, getMinSizeSent, getQueueSize, getResponseCodeTable, getTimeoutsReceiving, getTimeoutsSending, getTransportName, handleException, handleException, handleIncomingMessage, invoke, logException, maintenenceShutdown, pause, resetStatistics, resume, stop, waitForSynchronousResponse
-
Methods inherited from class org.apache.axis2.handlers.AbstractHandler
cleanup, flowComplete, getHandlerDesc, getName, getParameter, init, toString
-
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait
-
Methods inherited from interface org.apache.axis2.engine.Handler
cleanup, flowComplete, getHandlerDesc, getName, getParameter, init
-
Methods inherited from interface org.apache.axis2.transport.base.ManagementSupport
getActiveThreadCount, getAvgSizeReceived, getAvgSizeSent, getBytesReceived, getBytesSent, getFaultsReceiving, getFaultsSending, getLastResetTime, getMaxSizeReceived, getMaxSizeSent, getMessagesReceived, getMessagesSent, getMetricsWindow, getMinSizeReceived, getMinSizeSent, getQueueSize, getResponseCodeTable, getTimeoutsReceiving, getTimeoutsSending, maintenenceShutdown, pause, resetStatistics, resume
-
-
-
-
Field Detail
-
TRANSPORT_NAME
public static final String TRANSPORT_NAME
- See Also:
- Constant Field Values
-
-
Method Detail
-
init
public void init(org.apache.axis2.context.ConfigurationContext cfgCtx, org.apache.axis2.description.TransportOutDescription transportOut) throws org.apache.axis2.AxisFault
Initialize the VFS file system manager and be ready to send messages- Specified by:
init
in interfaceorg.apache.axis2.transport.TransportSender
- Overrides:
init
in classorg.apache.axis2.transport.base.AbstractTransportSender
- Parameters:
cfgCtx
- the axis2 configuration contexttransportOut
- the transport-out description- Throws:
org.apache.axis2.AxisFault
- on error
-
sendMessage
public void sendMessage(org.apache.axis2.context.MessageContext msgCtx, String targetAddress, org.apache.axis2.transport.OutTransportInfo outTransportInfo) throws org.apache.axis2.AxisFault
Send the given message over the VFS transport- Specified by:
sendMessage
in classorg.apache.axis2.transport.base.AbstractTransportSender
- Parameters:
msgCtx
- the axis2 message context- Throws:
org.apache.axis2.AxisFault
- on error
-
writeFile
protected void writeFile(org.apache.axis2.context.MessageContext msgCtx, org.apache.synapse.commons.vfs.VFSOutTransportInfo vfsOutInfo) throws org.apache.axis2.AxisFault
- Throws:
org.apache.axis2.AxisFault
-
populateResponseFile
protected void populateResponseFile(org.apache.commons.vfs2.FileObject responseFile, org.apache.axis2.context.MessageContext msgContext, boolean append, boolean lockingEnabled, org.apache.commons.vfs2.FileSystemOptions fso) throws org.apache.axis2.AxisFault
- Throws:
org.apache.axis2.AxisFault
-
acquireLockForSending
protected void acquireLockForSending(org.apache.commons.vfs2.FileObject responseFile, org.apache.synapse.commons.vfs.VFSOutTransportInfo vfsOutInfo, org.apache.commons.vfs2.FileSystemOptions fso) throws org.apache.axis2.AxisFault
- Throws:
org.apache.axis2.AxisFault
-
getFsManager
public org.apache.commons.vfs2.FileSystemManager getFsManager()
The VFS file system manager
-
setFsManager
public void setFsManager(org.apache.commons.vfs2.FileSystemManager fsManager)
-
-