org.apache.camel.component.file
Class FileEndpoint

java.lang.Object
  extended by org.apache.camel.impl.DefaultEndpoint
      extended by org.apache.camel.impl.ScheduledPollEndpoint
          extended by org.apache.camel.component.file.GenericFileEndpoint<File>
              extended by org.apache.camel.component.file.FileEndpoint
All Implemented Interfaces:
CamelContextAware, Endpoint, IsSingleton

public class FileEndpoint
extends GenericFileEndpoint<File>

File endpoint.


Field Summary
 
Fields inherited from class org.apache.camel.component.file.GenericFileEndpoint
autoCreate, bufferSize, configuration, DEFAULT_IDEMPOTENT_CACHE_SIZE, DEFAULT_STRATEGYFACTORY_CLASS, delete, eagerDeleteTargetFile, exclude, exclusiveReadLockStrategy, fileExist, fileName, filter, flatten, idempotent, idempotentRepository, include, inProgressRepository, keepLastModified, localWorkDirectory, log, maxMessagesPerPoll, move, moveFailed, noop, preMove, processStrategy, readLock, readLockTimeout, recursive, sortBy, sorter, tempFileName, tempPrefix
 
Constructor Summary
FileEndpoint()
           
FileEndpoint(String endpointUri, Component component)
           
 
Method Summary
 FileConsumer createConsumer(Processor processor)
          Creates a new Event Driven Consumer which consumes messages from the endpoint using the given processor
protected  String createEndpointUri()
          A factory method to lazily create the endpointUri if none is specified
 Exchange createExchange(GenericFile<File> file)
           
 GenericFileProducer<File> createProducer()
          Creates a new producer which is used send messages into the endpoint
 File getFile()
           
 char getFileSeparator()
           
 String getScheme()
           
 boolean isAbsolute(String name)
           
 void setFile(File file)
           
 
Methods inherited from class org.apache.camel.component.file.GenericFileEndpoint
configureMessage, configureMoveOrPreMoveExpression, createGenericFileStrategy, getBufferSize, getConfiguration, getExclude, getExclusiveReadLockStrategy, getFileExist, getFileName, getFilter, getGeneratedFileName, getGenericFileProcessStrategy, getIdempotentRepository, getInclude, getInProgressRepository, getLocalWorkDirectory, getMaxMessagesPerPoll, getMove, getMoveFailed, getParamsAsMap, getPreMove, getProcessStrategy, getReadLock, getReadLockTimeout, getSortBy, getSorter, getTempFileName, getTempPrefix, isAutoCreate, isDelete, isEagerDeleteTargetFile, isFlatten, isIdempotent, isKeepLastModified, isNoop, isRecursive, isSingleton, setAutoCreate, setBufferSize, setConfiguration, setDelete, setEagerDeleteTargetFile, setExclude, setExclusiveReadLockStrategy, setFileExist, setFileName, setFileName, setFilter, setFlatten, setIdempotent, setIdempotentRepository, setInclude, setInProgressRepository, setKeepLastModified, setLocalWorkDirectory, setMaxMessagesPerPoll, setMove, setMove, setMoveFailed, setMoveFailed, setNoop, setPreMove, setPreMove, setProcessStrategy, setReadLock, setReadLockTimeout, setRecursive, setSortBy, setSortBy, setSortBy, setSorter, setTempFileName, setTempFileName, setTempPrefix
 
Methods inherited from class org.apache.camel.impl.ScheduledPollEndpoint
configureConsumer, configureProperties, getConsumerProperties, setConsumerProperties
 
Methods inherited from class org.apache.camel.impl.DefaultEndpoint
createExchange, createExchange, createExchange, createPollingConsumer, equals, getCamelContext, getComponent, getEndpointKey, getEndpointUri, getExchangePattern, getExchangeType, hashCode, isLenientProperties, setCamelContext, setEndpointUri, setEndpointUriIfNotSpecified, setExchangePattern, toString
 
Methods inherited from class java.lang.Object
clone, finalize, getClass, notify, notifyAll, wait, wait, wait
 

Constructor Detail

FileEndpoint

public FileEndpoint()

FileEndpoint

public FileEndpoint(String endpointUri,
                    Component component)
Method Detail

createConsumer

public FileConsumer createConsumer(Processor processor)
                            throws Exception
Description copied from interface: Endpoint
Creates a new Event Driven Consumer which consumes messages from the endpoint using the given processor

Specified by:
createConsumer in interface Endpoint
Specified by:
createConsumer in class GenericFileEndpoint<File>
Parameters:
processor - the given processor
Returns:
a newly created consumer
Throws:
Exception - can be thrown

createProducer

public GenericFileProducer<File> createProducer()
                                         throws Exception
Description copied from interface: Endpoint
Creates a new producer which is used send messages into the endpoint

Specified by:
createProducer in interface Endpoint
Specified by:
createProducer in class GenericFileEndpoint<File>
Returns:
a newly created producer
Throws:
Exception - can be thrown

createExchange

public Exchange createExchange(GenericFile<File> file)
Specified by:
createExchange in class GenericFileEndpoint<File>

getFile

public File getFile()

setFile

public void setFile(File file)

getScheme

public String getScheme()
Specified by:
getScheme in class GenericFileEndpoint<File>

createEndpointUri

protected String createEndpointUri()
Description copied from class: DefaultEndpoint
A factory method to lazily create the endpointUri if none is specified

Overrides:
createEndpointUri in class DefaultEndpoint

getFileSeparator

public char getFileSeparator()
Specified by:
getFileSeparator in class GenericFileEndpoint<File>

isAbsolute

public boolean isAbsolute(String name)
Specified by:
isAbsolute in class GenericFileEndpoint<File>


Copyright © 2007-2010 IONA Open Source Community. All Rights Reserved.