public class FileTransportListener
extends org.adroitlogic.ultraesb.transport.base.AbstractPollingTransportListener
The File transport listener supporting polling of messages from: file, ftp, sftp and ftps protocols
Most of the file transport configuration is performed at the transport configuration section of the Proxy service using the file transport. Proxy services are triggered either on a specified cron expression, or as per specified {ultra.polling.start_delay, ultra.polling.repeat_interval, [ultra.polling.repeat_count]}
The available properties are as follows:
e.g. see sample # 350
For normal operations, there are no specific properties to be tuned. However, the number of threads used maybe tuned where applicable by using the relevant constructor
Note: Remote files are always first fully downloaded before processing. File messages set the following values as transport headers:
See http://epaul.github.com/jsch-documentation/simple.javadoc/com/jcraft/jsch/JSch.html#setConfig%28java.lang.String,%20java.lang.String%29 for a list of properties applicable to SFTP URLs
org.adroitlogic.ultraesb.transport.base.AbstractPollingTransportListener.PollingJob
ConfigurationElement.State
PARAMETERS
logger, metrics, properties, serverName, transportName
Constructor and Description |
---|
FileTransportListener()
Default constructor
|
FileTransportListener(int threads)
The constructor allowing the tuning of allocated threads for polling
|
Modifier and Type | Method and Description |
---|---|
void |
setTempDirectory(java.io.File tempDirectory) |
void |
setUseSafeLock(boolean useSafeLock) |
customizeJobDataMap, execute, maintenanceShutdown, onPoll, pause, registerProxyService, resume, start, stop, unregisterProxyService
getAccessURLs, getDetails, init, resetStatistics, setProperties, toBasicView, toDetailedView, toDetailedViewExt
equals, getDeploymentUnit, getDerivedName, getId, getState, getStreamCount, getTimerStreamMax, getTimerStreamMean, getTimerStreamMin, getTimerStreamPer, hashCode, init, isDebugOn, isStarted, markAsOutdated, resetCounter, resetTimer, resolveMetricsStreams, setBeanName, setConfig, setDebugOn, setDerivedName, setId, setMetricsEngine, setState, throwIllegalStateException, undeploy
clone, finalize, getClass, notify, notifyAll, toString, wait, wait, wait
retire