com.nt.udc.ei.node.nar

Class NAREIFileProcessor

java.lang.Object

com.nt.udc.ndk.node.EITransport

com.nt.udc.ei.transport.FileEITransport

com.nt.udc.ei.node.nar.NAREIFileProcessor

All Implemented Interfaces:

DataProviderIfc, DCTransport, FileDataProviderIfc, java.lang.Runnable

public class NAREIFileProcessor
extends FileEITransport

This class represents the Transport used by the NAR EI Node. The parent class FileEITransport handles the management of the input files, we just need to be able to read the contents of the file.

Field Summary

Fields

Modifier and Type	Field and Description
protected static java.lang.String	FILENAME_NAR_ID

Fields inherited from class com.nt.udc.ei.transport.FileEITransport

DEFAULT_POLLING_INTERVAL, DELETE_LOCAL_FILES, deleteLocalFiles, fileLevelTransaction, fileSeqCheck, fsChecked, ioLock, isOrdered, itsFileSuffix, localDir, logger, mtChecked, MULTI_THREADED, ORDER_REQUIRED, POLLING_INTERVAL, scratchDir, useSynchronizedDirectory

Fields inherited from class com.nt.udc.ndk.node.EITransport

dataReceiver, fdChecked, filedataReceiver, fileduplicateCheck, fileToProcess, inputCount, lockFile, movedFile, node, pollingInterval, processing, processingData, running

Constructor Summary

Constructors

Constructor and Description
NAREIFileProcessor(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.
NAREIFileProcessor(EINode node, SynchronizedDirectory sd, java.lang.String suffix, SMGLock lock) Constructor used when using FTP to retrieve the files that need to be processed.

Method Summary

Methods

Modifier and Type	Method and Description
protected void	processFiles(java.util.Vector filesToProcess) Here's where we actually parse the files and extract the data of interest.
protected void	processFilesOrdered(java.io.File currFile)

Methods inherited from class com.nt.udc.ei.transport.FileEITransport

deleteLocalFiles, getActFilter, getBulkData, getData, getLength, isDataAvailable, isHealthy, isLessThan, readLength, run, setActFilter, setDubCheckObj, setDupCheckFlag, setSeqCheckFlag, setSeqCheckObj, shutdown, sortFiles, writeLength, writeLength

Methods inherited from class com.nt.udc.ndk.node.EITransport

getDataReceiver, getDubCheckObj, getDupCheckFlag, getFileBulkData, getFileData, getFileDataReceiver, getMovedFileStatus, getNode, getPollingInterval, handleRejectOfFile, incrementIn, incrementIn, isEndOfFile, isFileDataAvailable, isProcessing, isProcessingData, isStartOfFile, openInputFile, rejectFile, setCountsSuspect, setDataReceiver, setFileDataReceiver, setFileToProcess, setMovedFileStatus, setNode, setPollingInterval, setProcessing

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Detail

FILENAME_NAR_ID

protected static final java.lang.String FILENAME_NAR_ID

See Also:

Constant Field Values

Constructor Detail

NAREIFileProcessor

public NAREIFileProcessor(EINode node,
                  java.io.File localdir,
                  java.lang.String suffix,
                  SMGLock lock)
                   throws NodeStartException

Constructor used when the files are pushed to a local directory by an outside source.

Parameters:

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 that need to be processed (can be null if you want to process all files in the directory).

lock - Used to properly shutdown the EI and all its threads.

Throws:

NodeStartException - Used to signal the EI Node that there was a problem getting things going.

NAREIFileProcessor

public NAREIFileProcessor(EINode node,
                  SynchronizedDirectory sd,
                  java.lang.String suffix,
                  SMGLock lock)
                   throws NodeStartException

Constructor used when using FTP to retrieve the files that need to be processed.

Parameters:

node - The EI node which is using this object.

sd - The representation of the local directory where the target files can be found.

suffix - The file suffix used to identify the files that need to be processed (can be null if you want to process all files in the directory).

lock - Used to properly shutdown the EI and all its threads.

Throws:

NodeStartException - Used to signal the EI Node that there was a problem getting things going.

Method Detail

processFiles

protected void processFiles(java.util.Vector filesToProcess)

Here's where we actually parse the files and extract the data of interest.

Specified by:

processFiles in class FileEITransport

Parameters:

filesToProcess - List of filenames that need to be processed

processFilesOrdered

protected void processFilesOrdered(java.io.File currFile)