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
-
-
Constructor Summary
Constructors Constructor Description PollTableEntry(boolean fileLocking)
-
Method Summary
-
Methods inherited from class org.apache.axis2.transport.base.AbstractPollTableEntry
getLastPollState, getLastPollTime, getNextPollTime, getPollInterval, isConcurrentPollingAllowed, setConcurrentPollingAllowed, setLastPollState, setLastPollTime, setNextPollTime, setPollInterval
-
-
-
-
Field Detail
-
DELETE
public static final int DELETE
- See Also:
- Constant Field Values
-
MOVE
public static final int MOVE
- See Also:
- Constant Field Values
-
NONE
public static final int NONE
- See Also:
- Constant Field Values
-
-
Method Detail
-
getEndpointReferences
public org.apache.axis2.addressing.EndpointReference[] getEndpointReferences(org.apache.axis2.description.AxisService service, String ip)
- Specified by:
getEndpointReferences
in classorg.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()
-
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()
-
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
-
loadConfiguration
public boolean loadConfiguration(org.apache.axis2.description.ParameterInclude params) throws org.apache.axis2.AxisFault
- Overrides:
loadConfiguration
in classorg.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
-
-