Class LargeFsConsumer
- java.lang.Object
- 
- All Implemented Interfaces:
- AdaptrisComponent,- AdaptrisMessageConsumer,- AdaptrisMessageWorker,- ComponentLifecycle,- ComponentLifecycleExtension,- MessageEventGenerator,- StateManagedComponent
 
 @ComponentProfile(summary="Pickup messages from the filesystem with large message support", tag="consumer,fs,filesystem", metadata={"originalname","fsFileSize","lastmodified","fsConsumeDir","_interlokMessageConsumedFrom","fsParentDir"}, recommended=NullConnection.class) public class LargeFsConsumer extends FsConsumerFile system implementation of AdaptrisMessageConsumerwith large message support.- If a filebased url is used. e.g. file:///c:/path/to/my/directory or file:////path/to/my/directory then the patch is considered to be fully qualified
- If just a path is returned, then it is considered to be relative to the current working directory. e.g. if /opt/fred is used, and the adapter is installed to /opt/adapter, then the fully qualified name is /opt/adapter/opt/fred.
 On windows based platforms, you should always use a file based url. Additionally the behaviour of this consumer is subtly different from the standard FsConsumer:- Encoding is supported if you use a FileBackedMimeEncoder.
- The default AdaptrisMessageFactory implementation is FileBackedMessageFactory
- If, at runtime, the MessageFactory implementation is not FileBackedMessageFactory, then behaviour changes to be identical to
 to the existing FsConsumerand uses the configured FsWorker
 In the adapter configuration file this class is aliased as large-fs-consumer which is the preferred alternative to the fully qualified classname when building your configuration. 
- 
- 
Nested Class Summary- 
Nested classes/interfaces inherited from class com.adaptris.core.AdaptrisPollingConsumerAdaptrisPollingConsumer.LockOperator
 
- 
 - 
Field Summary- 
Fields inherited from class com.adaptris.core.fs.FsConsumerImplfileFilter, fsWorker
 - 
Fields inherited from class com.adaptris.core.AdaptrisMessageWorkerImplog
 
- 
 - 
Constructor SummaryConstructors Constructor Description LargeFsConsumer()
 - 
Method SummaryAll Methods Instance Methods Concrete Methods Modifier and Type Method Description voidclose()Closes the component.voidinit()Initialises the component.protected intprocessFile(java.io.File originalFile)Attempt to process this file which might be a directory.voidstart()Starts the component.voidstop()Stop the component- 
Methods inherited from class com.adaptris.core.fs.FsConsumergetResetWipFiles, getWipSuffix, renameFile, resetWipFiles, setResetWipFiles, setWipSuffix
 - 
Methods inherited from class com.adaptris.core.fs.FsConsumerImpladdStandardMetadata, baseDirUrl, checkModified, consumeLocationKey, createAdaptrisMessage, filterExpression, getBaseDirectoryUrl, getCreateDirs, getFileFilterImp, getFileSorter, getFilterExpression, getLogAllExceptions, getQuietInterval, isFileAccessible, logAllExceptions, prepareConsumer, processMessages, setBaseDirectoryUrl, setCreateDirs, setFileFilterImp, setFileSorter, setFilterExpression, setLogAllExceptions, setQuietInterval, shouldCreateDirs, verifyDirectory, withBaseDirectoryUrl, withFilterExpression
 - 
Methods inherited from class com.adaptris.core.AdaptrisPollingConsumercontinueProcessingMessages, getMaxMessagesPerPoll, getPoller, getReacquireLockBetweenMessages, prepare, releaseLock, setMaxMessagesPerPoll, setPoller, setReacquireLockBetweenMessages
 - 
Methods inherited from class com.adaptris.core.AdaptrisMessageConsumerImpchangeState, newThreadName, registerAdaptrisMessageListener, renameThread, requestClose, requestInit, requestStart, requestStop, retrieveAdaptrisMessageListener, retrieveComponentState
 - 
Methods inherited from class com.adaptris.core.AdaptrisMessageWorkerImpcreateName, createQualifier, decode, encode, getEncoder, getIsTrackingEndpoint, getMessageFactory, getUniqueId, handleConnectionException, isTrackingEndpoint, registerConnection, registerEncoderMessageFactory, retrieveConnection, setEncoder, setIsTrackingEndpoint, setMessageFactory, setUniqueId, withMessageFactory, withUniqueID
 - 
Methods inherited from class java.lang.Objectclone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
 - 
Methods inherited from interface com.adaptris.core.AdaptrisComponentgetUniqueId
 - 
Methods inherited from interface com.adaptris.core.AdaptrisMessageWorkerdecode, encode, getEncoder, getMessageFactory, handleConnectionException, registerConnection, retrieveConnection, setEncoder, setMessageFactory
 - 
Methods inherited from interface com.adaptris.core.MessageEventGeneratorcreateName, createQualifier, isTrackingEndpoint
 
- 
 
- 
- 
- 
Method Detail- 
initpublic void init() throws CoreExceptionDescription copied from interface:ComponentLifecycleInitialises the component.Component initialisation includes config verification, creation of connections etc. - Specified by:
- initin interface- ComponentLifecycle
- Overrides:
- initin class- FsConsumer
- Throws:
- CoreException- wrapping any underlying- Exceptions
- See Also:
- ComponentLifecycle.init()
 
 - 
startpublic void start() throws CoreExceptionDescription copied from interface:ComponentLifecycleStarts the component.Once a component is started it should be ready to process messages. In the case of AdaptrisMessageConsumer, calling start will begin message delivery.- Specified by:
- startin interface- ComponentLifecycle
- Overrides:
- startin class- AdaptrisPollingConsumer
- Throws:
- CoreException- wrapping any underlying- Exceptions
- See Also:
- ComponentLifecycle.start()
 
 - 
stoppublic void stop() Description copied from interface:ComponentLifecycleStop the componentA stopped component is not expected to be ready to process messages. In the case of AdaptrisMessageConsumer, calling stop will pause message delivery. Throwing aRuntimeExceptionmay cause unintended consequences- Specified by:
- stopin interface- ComponentLifecycle
- Overrides:
- stopin class- AdaptrisPollingConsumer
- See Also:
- ComponentLifecycle.stop()
 
 - 
closepublic void close() Description copied from interface:ComponentLifecycleCloses the component.A closed component should release any connections it uses, etc. and clean up completely. Throwing a RuntimeExceptionmay cause unintended consequences- Specified by:
- closein interface- ComponentLifecycle
- Overrides:
- closein class- AdaptrisPollingConsumer
- See Also:
- ComponentLifecycle.close()
 
 - 
processFileprotected int processFile(java.io.File originalFile) throws CoreExceptionDescription copied from class:FsConsumerImplAttempt to process this file which might be a directory.- Overrides:
- processFilein class- FsConsumer
- Parameters:
- originalFile- the File
- Returns:
- the number of files processed.
- Throws:
- CoreException- wrapping any other Exception.
 
 
- 
 
-