Package org.apache.synapse.transport.vfs

Class 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

      Fields 
      Modifier and Type Field Description
      static String TRANSPORT_NAME  

      • Fields inherited from class org.apache.axis2.transport.base.AbstractTransportSender

        cfgCtx, log, metrics

      • Fields inherited from class org.apache.axis2.handlers.AbstractHandler

        handlerDesc

    • 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 manager
      void init​(org.apache.axis2.context.ConfigurationContext cfgCtx, org.apache.axis2.description.TransportOutDescription transportOut)
      Initialize the VFS file system manager and be ready to send messages
      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)  
      void sendMessage​(org.apache.axis2.context.MessageContext msgCtx, String targetAddress, org.apache.axis2.transport.OutTransportInfo outTransportInfo)
      Send the given message over the VFS transport
      void 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 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

    • Constructor Detail

      • VFSTransportSender

        public VFSTransportSender()
        The public constructor

    • 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 interface org.apache.axis2.transport.TransportSender
        Overrides:
        init in class org.apache.axis2.transport.base.AbstractTransportSender
        Parameters:
        cfgCtx - the axis2 configuration context
        transportOut - 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 class org.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)