org.apache.camel.component.file
Class FileConsumer

java.lang.Object
  extended by org.apache.camel.impl.ServiceSupport
      extended by org.apache.camel.impl.DefaultConsumer<E>
          extended by org.apache.camel.impl.ScheduledPollConsumer<FileExchange>
              extended by org.apache.camel.component.file.FileConsumer
All Implemented Interfaces:
Runnable, Consumer<FileExchange>, Service

public class FileConsumer
extends ScheduledPollConsumer<FileExchange>

For consuming files.

Version:
$Revision: 41272 $

Constructor Summary
FileConsumer(FileEndpoint endpoint, Processor processor)
           
 
Method Summary
 String getRegexPattern()
           
 int getUnchangedDelay()
           
protected  boolean isChanged(File file)
           
 boolean isGenerateEmptyExchangeWhenIdle()
           
protected  boolean isMatched(File file)
           
 boolean isRecursive()
           
 boolean isUnchangedSize()
           
protected  boolean isValidFile(File file)
           
protected  void poll()
          The polling method which is invoked periodically to poll this consumer
protected  int pollFile(File file)
          Polls the given file
protected  int pollFileOrDirectory(File fileOrDirectory, boolean processDir)
          Pools the given file or directory for files to process.
 void setGenerateEmptyExchangeWhenIdle(boolean generateEmptyExchangeWhenIdle)
           
 void setRecursive(boolean recursive)
           
 void setRegexPattern(String regexPattern)
           
 void setUnchangedDelay(int unchangedDelay)
           
 void setUnchangedSize(boolean unchangedSize)
           
 
Methods inherited from class org.apache.camel.impl.ScheduledPollConsumer
doStart, doStop, getDelay, getInitialDelay, getTimeUnit, isUseFixedDelay, run, setDelay, setInitialDelay, setTimeUnit, setUseFixedDelay
 
Methods inherited from class org.apache.camel.impl.DefaultConsumer
getAsyncProcessor, getEndpoint, getExceptionHandler, getProcessor, handleException, setExceptionHandler, toString
 
Methods inherited from class org.apache.camel.impl.ServiceSupport
addChildService, getThreadName, isRunAllowed, isStarted, isStarting, isStopped, isStopping, nextThreadCounter, removeChildService, start, stop
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait
 
Methods inherited from interface org.apache.camel.Service
start, stop
 

Constructor Detail

FileConsumer

public FileConsumer(FileEndpoint endpoint,
                    Processor processor)
Method Detail

poll

protected void poll()
             throws Exception
Description copied from class: ScheduledPollConsumer
The polling method which is invoked periodically to poll this consumer

Specified by:
poll in class ScheduledPollConsumer<FileExchange>
Throws:
Exception

pollFileOrDirectory

protected int pollFileOrDirectory(File fileOrDirectory,
                                  boolean processDir)
Pools the given file or directory for files to process.

Parameters:
fileOrDirectory - file or directory
processDir - recursive
Returns:
the number of files processed or being processed async.

pollFile

protected int pollFile(File file)
Polls the given file

Parameters:
file - the file
Returns:
returns 1 if the file was processed, 0 otherwise.

isValidFile

protected boolean isValidFile(File file)

isChanged

protected boolean isChanged(File file)

isMatched

protected boolean isMatched(File file)

isRecursive

public boolean isRecursive()

setRecursive

public void setRecursive(boolean recursive)

getRegexPattern

public String getRegexPattern()

setRegexPattern

public void setRegexPattern(String regexPattern)

isGenerateEmptyExchangeWhenIdle

public boolean isGenerateEmptyExchangeWhenIdle()

setGenerateEmptyExchangeWhenIdle

public void setGenerateEmptyExchangeWhenIdle(boolean generateEmptyExchangeWhenIdle)

getUnchangedDelay

public int getUnchangedDelay()

setUnchangedDelay

public void setUnchangedDelay(int unchangedDelay)

isUnchangedSize

public boolean isUnchangedSize()

setUnchangedSize

public void setUnchangedSize(boolean unchangedSize)


Copyright © 2008 IONA Open Source Community. All Rights Reserved.