org.apache.camel.component.file
Class FileEndpoint

java.lang.Object
  org.apache.camel.impl.ServiceSupport
      org.apache.camel.impl.DefaultEndpoint
          org.apache.camel.impl.ScheduledPollEndpoint
              org.apache.camel.component.file.GenericFileEndpoint<File>
                  org.apache.camel.component.file.FileEndpoint

All Implemented Interfaces:

CamelContextAware, Endpoint, IsSingleton, Service, ShutdownableService, BrowsableEndpoint, HasId

public class FileEndpoint
extends GenericFileEndpoint<File>

File endpoint.

Field Summary

Fields inherited from class org.apache.camel.component.file.GenericFileEndpoint

autoCreate, bufferSize, charset, configuration, DEFAULT_IDEMPOTENT_CACHE_SIZE, DEFAULT_STRATEGYFACTORY_CLASS, delete, directoryMustExist, doneFileName, eagerDeleteTargetFile, exclude, exclusiveReadLockStrategy, fileExist, fileName, filter, flatten, idempotent, idempotentRepository, include, inProgressRepository, keepLastModified, localWorkDirectory, log, maxDepth, maxMessagesPerPoll, minDepth, move, moveFailed, noop, preMove, processStrategy, readLock, readLockCheckInterval, readLockTimeout, recursive, sortBy, sorter, startingDirectoryMustExist, 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

configureExchange, configureMessage, configureMoveOrPreMoveExpression, createDoneFileName, createGenericFileStrategy, doStart, doStop, getBufferSize, getCharset, getConfiguration, getDoneFileName, getExchanges, getExclude, getExclusiveReadLockStrategy, getFileExist, getFileName, getFilter, getGeneratedFileName, getGenericFileProcessStrategy, getIdempotentRepository, getInclude, getInProgressRepository, getLocalWorkDirectory, getMaxDepth, getMaxMessagesPerPoll, getMinDepth, getMove, getMoveFailed, getParamsAsMap, getPreMove, getProcessStrategy, getReadLock, getReadLockCheckInterval, getReadLockTimeout, getSortBy, getSorter, getTempFileName, getTempPrefix, isAutoCreate, isDelete, isDirectoryMustExist, isDoneFile, isEagerDeleteTargetFile, isFlatten, isIdempotent, isKeepLastModified, isNoop, isRecursive, isSingleton, isStartingDirectoryMustExist, setAutoCreate, setBufferSize, setCharset, setConfiguration, setDelete, setDirectoryMustExist, setDoneFileName, setEagerDeleteTargetFile, setExclude, setExclusiveReadLockStrategy, setFileExist, setFileName, setFileName, setFilter, setFlatten, setIdempotent, setIdempotentRepository, setInclude, setInProgressRepository, setKeepLastModified, setLocalWorkDirectory, setMaxDepth, setMaxMessagesPerPoll, setMinDepth, setMove, setMove, setMoveFailed, setMoveFailed, setNoop, setPreMove, setPreMove, setProcessStrategy, setReadLock, setReadLockCheckInterval, setReadLockTimeout, setRecursive, setSortBy, setSortBy, setSortBy, setSorter, setStartingDirectoryMustExist, 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, getId, hashCode, isLenientProperties, isSynchronous, setCamelContext, setEndpointUri, setEndpointUriIfNotSpecified, setExchangePattern, setSynchronous, toString

Methods inherited from class org.apache.camel.impl.ServiceSupport

addChildService, doResume, doShutdown, doSuspend, getStatus, getVersion, isRunAllowed, isStarted, isStarting, isStopped, isStopping, isSuspended, isSuspending, removeChildService, resume, shutdown, start, start, stop, suspend

Methods inherited from class java.lang.Object

clone, finalize, getClass, notify, notifyAll, wait, wait, wait

Methods inherited from interface org.apache.camel.Endpoint

configureProperties, createExchange, createExchange, createExchange, createPollingConsumer, getCamelContext, getEndpointKey, getEndpointUri, isLenientProperties, setCamelContext

Methods inherited from interface org.apache.camel.Service

start, stop

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>