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, logger

    Fields inherited from interface org.springframework.integration.support.management.IntegrationManagement

    METER_PREFIX, RECEIVE_COUNTER_NAME, SEND_TIMER_NAME

    Fields inherited from interface org.springframework.core.Ordered

    HIGHEST_PRECEDENCE, LOWEST_PRECEDENCE
  • Constructor Summary

    Constructors
    Constructor
    Description
     
  • Method Summary

    Modifier and Type
    Method
    Description
    protected void
    deleteFileAndCloseSession(org.springframework.messaging.Message<?> message, File file, org.springframework.integration.file.remote.session.Session session)
     
    protected void
    ensureDirectoryExists(org.springframework.integration.file.remote.session.Session session, String remoteDirectory, String originalRemoteDirectory)
     
    protected org.springframework.integration.file.FileNameGenerator
     
    protected String
     
    protected String
     
     
    protected String
     
    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
    protected boolean
     
    protected void
    processFile(org.springframework.messaging.Message<?> message, File file)
     
    protected void
    sendFileToRemoteDirectory(File file, String remoteDirectory, String fileName, org.springframework.integration.file.remote.session.Session session)
     
    void
    setAutoCreateDirectory(boolean autoCreateDirectory)
     
    void
    setFileNameGenerator(org.springframework.integration.file.FileNameGenerator fileNameGenerator)
     
    void
    setRemoteDirectory(String remoteDirectory)
     
    void
    setRemoteFileSeparator(String remoteFileSeparator)
     
    void
     
    void
    setTemporaryFileSuffix(String temporaryFileSuffix)
     

    Methods inherited from class org.springframework.integration.handler.AbstractMessageHandler

    handleMessage, onComplete, onError, onNext, onSubscribe

    Methods 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, shouldTrack

    Methods 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, toString

    Methods inherited from class java.lang.Object

    clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait

    Methods inherited from interface reactor.core.CoreSubscriber

    currentContext

    Methods inherited from interface org.springframework.integration.support.management.IntegrationManagement

    getThisAs

    Methods 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:
      handleMessageInternal in class org.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

      protected void processFile(org.springframework.messaging.Message<?> message, File file)
    • sendFileToRemoteDirectory

      protected void sendFileToRemoteDirectory(File file, String remoteDirectory, String fileName, org.springframework.integration.file.remote.session.Session session) throws IOException
      Throws:
      IOException
    • ensureDirectoryExists

      protected void ensureDirectoryExists(org.springframework.integration.file.remote.session.Session session, String remoteDirectory, String originalRemoteDirectory)
    • getRemoteDirectory

      protected String getRemoteDirectory()
    • setRemoteDirectory

      public void setRemoteDirectory(String remoteDirectory)
    • getFileNameGenerator

      protected org.springframework.integration.file.FileNameGenerator getFileNameGenerator()
    • setFileNameGenerator

      public void setFileNameGenerator(org.springframework.integration.file.FileNameGenerator fileNameGenerator)
    • getRemoteFileSeparator

      protected String getRemoteFileSeparator()
    • setRemoteFileSeparator

      public void setRemoteFileSeparator(String remoteFileSeparator)
    • isAutoCreateDirectory

      protected boolean isAutoCreateDirectory()
    • setAutoCreateDirectory

      public void setAutoCreateDirectory(boolean autoCreateDirectory)
    • getSessionFactory

      protected ConfigurableSessionFactory getSessionFactory()
    • setSessionFactory

      public void setSessionFactory(ConfigurableSessionFactory sessionFactory)
    • getTemporaryFileSuffix

      protected String getTemporaryFileSuffix()
    • setTemporaryFileSuffix

      public void setTemporaryFileSuffix(String temporaryFileSuffix)