public class FileTransferringMessageHandler<F> extends AbstractMessageHandler
MessageHandler
implementation that transfers files to a remote server.Modifier and Type | Field and Description |
---|---|
protected RemoteFileTemplate<F> |
remoteFileTemplate |
logger
Constructor and Description |
---|
FileTransferringMessageHandler(RemoteFileTemplate<F> remoteFileTemplate) |
FileTransferringMessageHandler(RemoteFileTemplate<F> remoteFileTemplate,
FileExistsMode mode) |
FileTransferringMessageHandler(SessionFactory<F> sessionFactory) |
Modifier and Type | Method and Description |
---|---|
protected java.lang.String |
getTemporaryFileSuffix() |
protected void |
handleMessageInternal(org.springframework.messaging.Message<?> message) |
protected boolean |
isUseTemporaryFileName() |
protected void |
onInit()
Subclasses may implement this for initialization logic.
|
void |
setAutoCreateDirectory(boolean autoCreateDirectory) |
void |
setCharset(java.lang.String charset) |
void |
setFileNameGenerator(FileNameGenerator fileNameGenerator) |
void |
setRemoteDirectoryExpression(org.springframework.expression.Expression remoteDirectoryExpression) |
void |
setRemoteFileSeparator(java.lang.String remoteFileSeparator) |
void |
setTemporaryFileSuffix(java.lang.String temporaryFileSuffix) |
void |
setTemporaryRemoteDirectoryExpression(org.springframework.expression.Expression temporaryRemoteDirectoryExpression) |
void |
setUseTemporaryFileName(boolean useTemporaryFileName) |
configureMetrics, getActiveCount, getActiveCountLong, getComponentType, getDuration, getErrorCount, getErrorCountLong, getHandleCount, getHandleCountLong, getManagedName, getManagedType, getMaxDuration, getMeanDuration, getMinDuration, getOrder, getStandardDeviationDuration, handleMessage, isCountsEnabled, isLoggingEnabled, isStatsEnabled, reset, setCountsEnabled, setLoggingEnabled, setManagedName, setManagedType, setOrder, setShouldTrack, setStatsEnabled
afterPropertiesSet, extractTypeIfPossible, getApplicationContext, getApplicationContextId, getBeanFactory, getChannelResolver, getComponentName, getConversionService, getIntegrationProperties, getIntegrationProperty, getMessageBuilderFactory, getTaskScheduler, setApplicationContext, setBeanFactory, setBeanName, setChannelResolver, setComponentName, setConversionService, setMessageBuilderFactory, setTaskScheduler, toString
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait
getComponentName
protected final RemoteFileTemplate<F> remoteFileTemplate
public FileTransferringMessageHandler(SessionFactory<F> sessionFactory)
public FileTransferringMessageHandler(RemoteFileTemplate<F> remoteFileTemplate)
public FileTransferringMessageHandler(RemoteFileTemplate<F> remoteFileTemplate, FileExistsMode mode)
public void setAutoCreateDirectory(boolean autoCreateDirectory)
autoCreateDirectory
- true to automatically create the direcotory.RemoteFileTemplate.setAutoCreateDirectory(boolean)
public void setRemoteFileSeparator(java.lang.String remoteFileSeparator)
remoteFileSeparator
- the remote file separator.RemoteFileTemplate.setRemoteFileSeparator(String)
public void setRemoteDirectoryExpression(org.springframework.expression.Expression remoteDirectoryExpression)
remoteDirectoryExpression
- the remote directory expressionRemoteFileTemplate.setRemoteDirectoryExpression(Expression)
public void setTemporaryRemoteDirectoryExpression(org.springframework.expression.Expression temporaryRemoteDirectoryExpression)
temporaryRemoteDirectoryExpression
- the temporary remote directory expressionRemoteFileTemplate.setTemporaryRemoteDirectoryExpression(Expression)
protected java.lang.String getTemporaryFileSuffix()
protected boolean isUseTemporaryFileName()
public void setUseTemporaryFileName(boolean useTemporaryFileName)
useTemporaryFileName
- true to use a temporary file name.RemoteFileTemplate.setUseTemporaryFileName(boolean)
public void setFileNameGenerator(FileNameGenerator fileNameGenerator)
fileNameGenerator
- the file name generator.RemoteFileTemplate.setFileNameGenerator(FileNameGenerator)
public void setCharset(java.lang.String charset)
charset
- the charset.RemoteFileTemplate.setCharset(String)
public void setTemporaryFileSuffix(java.lang.String temporaryFileSuffix)
temporaryFileSuffix
- the temporary file suffix.RemoteFileTemplate.setTemporaryFileSuffix(String)
protected void onInit() throws java.lang.Exception
IntegrationObjectSupport
onInit
in class AbstractMessageHandler
java.lang.Exception
- Any exception.protected void handleMessageInternal(org.springframework.messaging.Message<?> message) throws java.lang.Exception
handleMessageInternal
in class AbstractMessageHandler
java.lang.Exception