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 definition
enable|disable ?
-
Nested Class Summary
Nested classes/interfaces inherited from interface org.apache.axis2.engine.Handler
org.apache.axis2.engine.Handler.InvocationResponse -
Field Summary
FieldsFields inherited from class org.apache.axis2.transport.base.AbstractTransportSender
cfgCtx, log, metricsFields inherited from class org.apache.axis2.handlers.AbstractHandler
handlerDesc -
Constructor Summary
Constructors -
Method Summary
Modifier and TypeMethodDescriptionprotected voidacquireLockForSending(org.apache.commons.vfs2.FileObject responseFile, org.apache.synapse.commons.vfs.VFSOutTransportInfo vfsOutInfo, org.apache.commons.vfs2.FileSystemOptions fso, String configName) org.apache.commons.vfs2.FileSystemManagerThe VFS file system managervoidinit(org.apache.axis2.context.ConfigurationContext cfgCtx, org.apache.axis2.description.TransportOutDescription transportOut) Initialize the VFS file system manager and be ready to send messagesprotected voidpopulateResponseFile(org.apache.commons.vfs2.FileObject responseFile, org.apache.axis2.context.MessageContext msgContext, boolean append, boolean lockingEnabled, boolean updateLastModified, org.apache.commons.vfs2.FileSystemOptions fso) voidsendMessage(org.apache.axis2.context.MessageContext msgCtx, String targetAddress, org.apache.axis2.transport.OutTransportInfo outTransportInfo) Send the given message over the VFS transportvoidsetFsManager(org.apache.commons.vfs2.FileSystemManager fsManager) protected voidwriteFile(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, waitForSynchronousResponseMethods inherited from class org.apache.axis2.handlers.AbstractHandler
cleanup, flowComplete, getHandlerDesc, getName, getParameter, init, toStringMethods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, waitMethods inherited from interface org.apache.axis2.engine.Handler
cleanup, flowComplete, getHandlerDesc, getName, getParameter, initMethods 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, resumeMethods inherited from interface org.apache.axis2.transport.TransportSender
onAppError
-
Field Details
-
TRANSPORT_NAME
- See Also:
-
-
Constructor Details
-
VFSTransportSender
public VFSTransportSender()The public constructor
-
-
Method Details
-
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:
initin interfaceorg.apache.axis2.transport.TransportSender- Overrides:
initin 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:
sendMessagein 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, boolean updateLastModified, 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, String configName) 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)
-