Class DefaultUploadTransportService
java.lang.Object
org.springframework.integration.context.IntegrationObjectSupport
org.springframework.integration.handler.MessageHandlerSupport
org.springframework.integration.handler.AbstractMessageHandler
de.hybris.platform.acceleratorservices.dataexport.generic.impl.DefaultUploadTransportService
- All Implemented Interfaces:
org.reactivestreams.Subscriber<org.springframework.messaging.Message<?>>,org.springframework.beans.factory.Aware,org.springframework.beans.factory.BeanFactoryAware,org.springframework.beans.factory.BeanNameAware,org.springframework.beans.factory.DisposableBean,org.springframework.beans.factory.InitializingBean,org.springframework.context.ApplicationContextAware,org.springframework.core.Ordered,org.springframework.integration.context.ExpressionCapable,org.springframework.integration.context.Orderable,org.springframework.integration.IntegrationPattern,org.springframework.integration.support.context.NamedComponent,org.springframework.integration.support.management.IntegrationManagement,org.springframework.integration.support.management.TrackableComponent,org.springframework.messaging.MessageHandler,reactor.core.CoreSubscriber<org.springframework.messaging.Message<?>>
public class DefaultUploadTransportService
extends org.springframework.integration.handler.AbstractMessageHandler
A basic version of springs default ftp FileTransferringMessageHandler.
-
Nested Class Summary
Nested classes/interfaces inherited from interface org.springframework.integration.support.management.IntegrationManagement
org.springframework.integration.support.management.IntegrationManagement.ManagementOverrides -
Field Summary
Fields inherited from class org.springframework.integration.context.IntegrationObjectSupport
EXPRESSION_PARSER, loggerFields inherited from interface org.springframework.integration.support.management.IntegrationManagement
METER_PREFIX, RECEIVE_COUNTER_NAME, SEND_TIMER_NAMEFields inherited from interface org.springframework.core.Ordered
HIGHEST_PRECEDENCE, LOWEST_PRECEDENCE -
Constructor Summary
Constructors -
Method Summary
Modifier and TypeMethodDescriptionprotected voiddeleteFileAndCloseSession(org.springframework.messaging.Message<?> message, File file, org.springframework.integration.file.remote.session.Session session) protected voidensureDirectoryExists(org.springframework.integration.file.remote.session.Session session, String remoteDirectory, String originalRemoteDirectory) protected org.springframework.integration.file.FileNameGeneratorprotected Stringprotected Stringprotected ConfigurableSessionFactoryprotected Stringprotected voidhandleMessageInternal(org.springframework.messaging.Message<?> message) create a ftp session with information for the connection from the message's header then send the fileprotected booleanprotected voidprocessFile(org.springframework.messaging.Message<?> message, File file) protected voidsendFileToRemoteDirectory(File file, String remoteDirectory, String fileName, org.springframework.integration.file.remote.session.Session session) voidsetAutoCreateDirectory(boolean autoCreateDirectory) voidsetFileNameGenerator(org.springframework.integration.file.FileNameGenerator fileNameGenerator) voidsetRemoteDirectory(String remoteDirectory) voidsetRemoteFileSeparator(String remoteFileSeparator) voidsetSessionFactory(ConfigurableSessionFactory sessionFactory) voidsetTemporaryFileSuffix(String temporaryFileSuffix) Methods inherited from class org.springframework.integration.handler.AbstractMessageHandler
handleMessage, onComplete, onError, onNext, onSubscribeMethods inherited from class org.springframework.integration.handler.MessageHandlerSupport
buildSendTimer, destroy, getComponentType, getIntegrationPatternType, getManagedName, getManagedType, getMetricsCaptor, getOrder, getOverrides, isLoggingEnabled, registerMetricsCaptor, sendTimer, setLoggingEnabled, setManagedName, setManagedType, setOrder, setShouldTrack, shouldTrackMethods inherited from class org.springframework.integration.context.IntegrationObjectSupport
afterPropertiesSet, extractTypeIfPossible, generateId, getApplicationContext, getApplicationContextId, getBeanDescription, getBeanFactory, getBeanName, getChannelResolver, getComponentName, getConversionService, getExpression, getIntegrationProperties, getIntegrationProperty, getMessageBuilderFactory, getTaskScheduler, isInitialized, onInit, setApplicationContext, setBeanFactory, setBeanName, setChannelResolver, setComponentName, setConversionService, setMessageBuilderFactory, setPrimaryExpression, setTaskScheduler, toStringMethods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, waitMethods inherited from interface reactor.core.CoreSubscriber
currentContextMethods inherited from interface org.springframework.integration.support.management.IntegrationManagement
getThisAsMethods inherited from interface org.springframework.integration.support.context.NamedComponent
getBeanName, getComponentName
-
Constructor Details
-
DefaultUploadTransportService
public DefaultUploadTransportService()
-
-
Method Details
-
handleMessageInternal
protected void handleMessageInternal(org.springframework.messaging.Message<?> message) create a ftp session with information for the connection from the message's header then send the file- Specified by:
handleMessageInternalin classorg.springframework.integration.handler.AbstractMessageHandler- Parameters:
message-- Throws:
Exception
-
deleteFileAndCloseSession
protected void deleteFileAndCloseSession(org.springframework.messaging.Message<?> message, File file, org.springframework.integration.file.remote.session.Session session) -
processFile
-
sendFileToRemoteDirectory
protected void sendFileToRemoteDirectory(File file, String remoteDirectory, String fileName, org.springframework.integration.file.remote.session.Session session) throws IOException - Throws:
IOException
-
ensureDirectoryExists
-
getRemoteDirectory
-
setRemoteDirectory
-
getFileNameGenerator
protected org.springframework.integration.file.FileNameGenerator getFileNameGenerator() -
setFileNameGenerator
public void setFileNameGenerator(org.springframework.integration.file.FileNameGenerator fileNameGenerator) -
getRemoteFileSeparator
-
setRemoteFileSeparator
-
isAutoCreateDirectory
protected boolean isAutoCreateDirectory() -
setAutoCreateDirectory
public void setAutoCreateDirectory(boolean autoCreateDirectory) -
getSessionFactory
-
setSessionFactory
-
getTemporaryFileSuffix
-
setTemporaryFileSuffix
-