Class ApacheCommonsFileTailingMessageProducer

All Implemented Interfaces:
org.apache.commons.io.input.TailerListener, Aware, BeanFactoryAware, BeanNameAware, DisposableBean, InitializingBean, SmartInitializingSingleton, ApplicationContextAware, ApplicationEventPublisherAware, Lifecycle, Phased, SmartLifecycle, ExpressionCapable, MessageProducer, IntegrationPattern, NamedComponent, ManageableLifecycle, ManageableSmartLifecycle, TrackableComponent

public class ApacheCommonsFileTailingMessageProducer
extends FileTailingMessageProducerSupport
implements org.apache.commons.io.input.TailerListener
File tailer that delegates to the Apache Commons Tailer.
Since:
3.0
Author:
Gary Russell, Artem Bilan
  • Constructor Details

  • Method Details

    • setPollingDelay

      public void setPollingDelay​(long pollingDelay)
      The delay between checks of the file for new content in milliseconds.
      Parameters:
      pollingDelay - The delay.
    • setEnd

      public void setEnd​(boolean end)
      If true, tail from the end of the file, otherwise include all lines from the beginning. Default true.
      Parameters:
      end - true or false
    • setReopen

      public void setReopen​(boolean reopen)
      If true, close and reopen the file between reading chunks; default false.
      Parameters:
      reopen - true or false.
    • getComponentType

      public String getComponentType()
      Description copied from class: IntegrationObjectSupport
      Subclasses may implement this method to provide component type information.
      Specified by:
      getComponentType in interface NamedComponent
      Overrides:
      getComponentType in class FileTailingMessageProducerSupport
    • doStart

      protected void doStart()
      Description copied from class: MessageProducerSupport
      Take no action by default. Subclasses may override this if they need lifecycle-managed behavior. Protected by 'lifecycleLock'.
      Overrides:
      doStart in class FileTailingMessageProducerSupport
    • doStop

      protected void doStop()
      Description copied from class: MessageProducerSupport
      Take no action by default. Subclasses may override this if they need lifecycle-managed behavior.
      Overrides:
      doStop in class FileTailingMessageProducerSupport
    • init

      public void init​(org.apache.commons.io.input.Tailer tailer)
      Specified by:
      init in interface org.apache.commons.io.input.TailerListener
    • fileNotFound

      public void fileNotFound()
      Specified by:
      fileNotFound in interface org.apache.commons.io.input.TailerListener
    • fileRotated

      public void fileRotated()
      Specified by:
      fileRotated in interface org.apache.commons.io.input.TailerListener
    • handle

      public void handle​(String line)
      Specified by:
      handle in interface org.apache.commons.io.input.TailerListener
    • handle

      public void handle​(Exception ex)
      Specified by:
      handle in interface org.apache.commons.io.input.TailerListener