public class KnownFieldLengthFileProcessor extends GenericFlatFileProcessor
actfile, br, debug, fileName, FILENAME_NAR_ID, INPUT_BACKUP_DIR, inputStream, lineOfText, m_bCRLFTerminatorEnabled, m_bCRTerminatorEnabled, m_bLFTerminatorEnabled, numBytes, PROCESSED_FILE_PREFIX, PROCESSED_FILE_SUFFIX, rawHeader, recoveryFile, scratchFile, UNICODE_TRANSFORMATION_FORMATDEFAULT_POLLING_INTERVAL, DELETE_LOCAL_FILES, deleteLocalFiles, fileLevelTransaction, fileSeqCheck, fsChecked, ioLock, isOrdered, itsFileSuffix, localDir, logger, mtChecked, MULTI_THREADED, ORDER_REQUIRED, POLLING_INTERVAL, scratchDir, useSynchronizedDirectorydataReceiver, fdChecked, filedataReceiver, fileduplicateCheck, fileToProcess, inputCount, lockFile, movedFile, node, pollingInterval, processing, processingData, running| Constructor and Description |
|---|
KnownFieldLengthFileProcessor(EINode node,
java.io.File localdir,
java.lang.String suffix,
SMGLock lock)
Constructor used when the files are pushed to a local directory by
an outside source.
|
KnownFieldLengthFileProcessor(EINode node,
SynchronizedDirectory sd,
java.lang.String suffix,
SMGLock lock)
Constructor used when using FTP to retrieve the files that need to
be processed.
|
| Modifier and Type | Method and Description |
|---|---|
protected void |
processTheRecord(java.lang.String rawRecord)
This processes the raw undelimited record based on the known field length
specified in the configuration file.
|
protected void |
setRecordType()
This sets up the record type which in turn controls how each of the flat file
records are processed.
|
getHeader, initLineTerminators, processFiles, processFilesOrdered, processScratchFile, setRecordType, skipAhead, skipHeaderdeleteLocalFiles, getActFilter, getBulkData, getData, getInputBackupDir, getLength, isDataAvailable, isHealthy, isLessThan, moveCurrentFileToBackUp, readLength, run, setActFilter, setDubCheckObj, setDupCheckFlag, setSeqCheckFlag, setSeqCheckObj, shutdown, sortFiles, writeLength, writeLengthgetCurrArchFile, getData, getDataReceiver, getDubCheckObj, getDupCheckFlag, getFileBulkData, getFileData, getFileDataReceiver, getFileList, getMovedFileStatus, getNode, getPollingInterval, getProcessedArchFile, handleRejectOfFile, incrementIn, incrementIn, isEndOfFile, isFileDataAvailable, isProcessing, isProcessingData, isStartOfFile, openInputFile, rejectFile, removeProcessedFile, setCountsSuspect, setDataReceiver, setFileDataReceiver, setFileToProcess, setMovedFileStatus, setNode, setPollingInterval, setProcessedArchFile, setProcessing, signalBatchCompletion, validOIMinorTypepublic KnownFieldLengthFileProcessor(EINode node, java.io.File localdir, java.lang.String suffix, SMGLock lock) throws NodeStartException
node - The EI node which is using this object.localdir - The local directory where the input files can
be found.suffix - The file suffix used to identify the files to be
processed (null indicates all files in
directory are to be processed).lock - Used to properly shutdown the EI and all its threads.NodeStartException - Used to signal the EI Node that there
was a problem starting the transport.public KnownFieldLengthFileProcessor(EINode node, SynchronizedDirectory sd, java.lang.String suffix, SMGLock lock) throws NodeStartException
node - The EI node which is using this object.sd - The representation of the local directory where
the input files can be found.suffix - The file suffix used to identify the files to be
processed (null indicates all files in
directory are to be processed).lock - Used to properly shutdown the EI and all its threads.NodeStartException - Used to signal the EI Node that there
was a problem starting the transport.protected void setRecordType()
protected void processTheRecord(java.lang.String rawRecord)
processTheRecord in class GenericFlatFileProcessor