Package org.apache.synapse.transport.vfs

Class PollTableEntry

java.lang.Object
org.apache.axis2.transport.base.ProtocolEndpoint
org.apache.axis2.transport.base.AbstractPollTableEntry
org.apache.synapse.transport.vfs.PollTableEntry
public class PollTableEntry extends org.apache.axis2.transport.base.AbstractPollTableEntry
Holds information about an entry in the VFS transport poll table used by the VFS Transport Listener

  • Field Details

  • Constructor Details

    • PollTableEntry

      public PollTableEntry(boolean fileLocking)

  • Method Details

    • getEndpointReferences

      public org.apache.axis2.addressing.EndpointReference[] getEndpointReferences(org.apache.axis2.description.AxisService service, String ip)
      Specified by:
      getEndpointReferences in class org.apache.axis2.transport.base.ProtocolEndpoint

    • getFileURI

      public String getFileURI()

    • getReplyFileURI

      public String getReplyFileURI()

    • getFileNamePattern

      public String getFileNamePattern()

    • getContentType

      public String getContentType()

    • getUpdateLastModified

      public boolean getUpdateLastModified()

    • getActionAfterProcess

      public int getActionAfterProcess()

    • getActionAfterErrors

      public int getActionAfterErrors()

    • getActionAfterFailure

      public int getActionAfterFailure()

    • getMoveAfterProcess

      public String getMoveAfterProcess()

    • getMoveAfterMoveFailure

      public String getMoveAfterMoveFailure()

    • getNextRetryDuration

      public int getNextRetryDuration()

    • getFailedRecordFileName

      public String getFailedRecordFileName()

    • getFailedRecordFileDestination

      public String getFailedRecordFileDestination()

    • getFailedRecordTimestampFormat

      public String getFailedRecordTimestampFormat()

    • getFileProcessingInterval

      public Integer getFileProcessingInterval()

    • getFileProcessingCount

      public Integer getFileProcessingCount()

    • getMoveAfterErrors

      public String getMoveAfterErrors()

    • getMoveAfterFailure

      public String getMoveAfterFailure()

    • setCheckSizeInterval

      public void setCheckSizeInterval(String checkSizeInterval)

    • getCheckSizeInterval

      public String getCheckSizeInterval()

    • hasCheckSizeInterval

      public boolean hasCheckSizeInterval()

    • setCheckSizeIgnoreEmpty

      public void setCheckSizeIgnoreEmpty(String checkSizeIgnoreEmpty)

    • getCheckSizeIgnoreEmpty

      public String getCheckSizeIgnoreEmpty()

    • isCheckSizeIgnoreEmpty

      public boolean isCheckSizeIgnoreEmpty()

    • isStreaming

      public boolean isStreaming()

    • getMaxRetryCount

      public int getMaxRetryCount()

    • isFileLockingEnabled

      public boolean isFileLockingEnabled()

    • setSecureVaultProperties

      public void setSecureVaultProperties(Properties secureVaultProperties)

    • getFileSizeLimit

      public double getFileSizeLimit()

    • getReconnectTimeout

      public long getReconnectTimeout()

    • getMoveTimestampFormat

      public DateFormat getMoveTimestampFormat()

    • getAutoLockRelease

      public Boolean getAutoLockRelease()
      Returns:
      the autoLockRelease

    • setAutoLockRelease

      public void setAutoLockRelease(Boolean autoLockRelease)
      Parameters:
      autoLockRelease - the autoLockRelease to set

    • getAutoLockReleaseInterval

      public Long getAutoLockReleaseInterval()
      Returns:
      the autoLockReleaseInterval

    • setAutoLockReleaseInterval

      public void setAutoLockReleaseInterval(Long autoLockReleaseInterval)
      Parameters:
      autoLockReleaseInterval - the autoLockReleaseInterval to set

    • getAutoLockReleaseSameNode

      public Boolean getAutoLockReleaseSameNode()
      Returns:
      the autoLockReleaseSameNode

    • setAutoLockReleaseSameNode

      public void setAutoLockReleaseSameNode(Boolean autoLockReleaseSameNode)
      Parameters:
      autoLockReleaseSameNode - the autoLockReleaseSameNode to set

    • isDistributedLock

      public boolean isDistributedLock()
      Returns:
      the distributedLock

    • getFileSortParam

      public String getFileSortParam()
      Returns:
      the fileSortParam

    • setFileSortParam

      public void setFileSortParam(String fileSortParam)
      Parameters:
      fileSortParam - the fileSortParam to set

    • isFileSortAscending

      public boolean isFileSortAscending()
      Returns:
      the fileSortAscending

    • setFileSortAscending

      public void setFileSortAscending(boolean fileSortAscending)
      Parameters:
      fileSortAscending - the fileSortAscending to set

    • getDistributedLockTimeout

      public Long getDistributedLockTimeout()
      Returns:
      the distributedLockTimeout

    • isCanceled

      public boolean isCanceled()

    • setCanceled

      public void setCanceled(boolean canceled)

    • isClusterAware

      public boolean isClusterAware()

    • setClusterAware

      public void setClusterAware(boolean clusterAware)

    • isResolveHostsDynamically

      public boolean isResolveHostsDynamically()

    • getVfsSchemeProperties

      public Map<String,String> getVfsSchemeProperties()

    • setVfsSchemeProperties

      public void setVfsSchemeProperties(Map<String,String> vfsSchemeProperties)

    • isFileNotFoundLogged

      public boolean isFileNotFoundLogged()
      Checks if the file not found warning has been logged.
      Returns:
      true if the file not found warning has been logged, false otherwise.

    • setFileNotFoundLogged

      public void setFileNotFoundLogged(boolean fileNotFoundLogged)
      Sets the file not found logged flag.
      Parameters:
      fileNotFoundLogged - true to indicate that the file not found warning has been logged, false otherwise.

    • getParams

      public org.apache.axis2.description.ParameterInclude getParams()

    • isForceCreateFolder

      public boolean isForceCreateFolder()
      Returns:
      the forceCreateFolder

    • setForceCreateFolder

      public void setForceCreateFolder(boolean forceCreateFolder)
      Parameters:
      forceCreateFolder - the forceCreateFolder to set

    • getSubfolderTimestamp

      public String getSubfolderTimestamp()
      Returns:
      the subfolderTimestamp

    • setSubfolderTimestamp

      public void setSubfolderTimestamp(String subfolderTimestamp)
      Parameters:
      subfolderTimestamp - the subfolderTimestamp to set

    • getMinimumAge

      public Long getMinimumAge()

    • getMaximumAge

      public Long getMaximumAge()

    • loadConfiguration

      public boolean loadConfiguration(org.apache.axis2.description.ParameterInclude params) throws org.apache.axis2.AxisFault
      Overrides:
      loadConfiguration in class org.apache.axis2.transport.base.AbstractPollTableEntry
      Throws:
      org.apache.axis2.AxisFault

    • loadConfigurationsFromService

      protected boolean loadConfigurationsFromService(org.apache.axis2.description.ParameterInclude params) throws org.apache.axis2.AxisFault
      Throws:
      org.apache.axis2.AxisFault