com.nt.udc.node.util

Class StreamSourceFileMgr

java.lang.Object

com.nt.udc.node.util.StreamSourceFileMgr

All Implemented Interfaces:

IStreamSource

public class StreamSourceFileMgr
extends java.lang.Object
implements IStreamSource

This class is used for retrieving data from files specified by a filter, that reside in an input directory.

Since:

JDK1.1.7

Field Summary

Fields

Modifier and Type	Field and Description
protected CManagedFile	m_crtFile This member represents the file currently being processed.
protected static int	m_debugLevel
protected CFileMgr	m_fileMgr This member is used to manage files to be processed
protected LoggerIfc	m_iLogger This member is used for reporting errors and warnings.
protected COSARReporter	m_reporter This member is used to send reports to.

Constructor Summary

Constructors

Constructor and Description
StreamSourceFileMgr(java.lang.String inputDir, java.lang.String scratchDir, java.io.FilenameFilter filter, LoggerIfc iLogger)

Method Summary

Modifier and Type	Method and Description
protected boolean	checkDir(java.lang.String dir)
boolean	cleanupCrtFile()
COSARReporter	COSARReporter()
protected void	debug(java.lang.String fName, java.lang.String msg)
boolean	end() Function called to end reading.
static int	getDebugLevel()
java.io.File	getRecoveryFile()
java.lang.String	getSourceName()
boolean	hasMoreData()
protected boolean	initFileMgr(java.lang.String inputDir, java.lang.String scratchDir, java.io.FilenameFilter filter) This function initializes the file manager.
boolean	initialize() This function is used to initialize the data source.
java.io.InputStream	nextStream()
static void	setDebugLevel(int debugLevel)
void	setDeleteProcessedFiles(boolean doDelete)
void	setDoneFilePrefix(java.lang.String prefix)
void	setDoneFileSuffix(java.lang.String suffix)
void	setReporter(COSARReporter reporter)
boolean	start() Function called to start reading
boolean	terminate() This function is used to terminate the data source.

Methods inherited from class java.lang.Object

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

Field Detail

m_debugLevel

protected static int m_debugLevel

m_iLogger

protected LoggerIfc m_iLogger

This member is used for reporting errors and warnings.

m_fileMgr

protected CFileMgr m_fileMgr

This member is used to manage files to be processed

m_crtFile

protected CManagedFile m_crtFile

This member represents the file currently being processed.

m_reporter

protected COSARReporter m_reporter

This member is used to send reports to.

Constructor Detail

StreamSourceFileMgr

public StreamSourceFileMgr(java.lang.String inputDir,
                           java.lang.String scratchDir,
                           java.io.FilenameFilter filter,
                           LoggerIfc iLogger)
                    throws java.lang.Exception

Parameters:

inputDir - - directory to monitor for input files

scratchDir - - scratch directory

filter - - identifies files to return

iLogger - - object to handle errors and warnings

Throws:

java.lang.Exception

Method Detail

getDebugLevel

public static int getDebugLevel()

COSARReporter

public COSARReporter COSARReporter()

setDebugLevel

public static void setDebugLevel(int debugLevel)

setReporter

public void setReporter(COSARReporter reporter)

setDoneFilePrefix

public void setDoneFilePrefix(java.lang.String prefix)

setDoneFileSuffix

public void setDoneFileSuffix(java.lang.String suffix)

setDeleteProcessedFiles

public void setDeleteProcessedFiles(boolean doDelete)

getSourceName

public java.lang.String getSourceName()

Specified by:

getSourceName in interface IStreamSource

Returns:

The current filename

hasMoreData

public boolean hasMoreData()

Specified by:

hasMoreData in interface IStreamSource

Returns:

true if there are more any files to process.

nextStream

public java.io.InputStream nextStream()

Specified by:

nextStream in interface IStreamSource

getRecoveryFile

public java.io.File getRecoveryFile()

Specified by:

getRecoveryFile in interface IStreamSource

initialize

public boolean initialize()

This function is used to initialize the data source.

Specified by:

initialize in interface IStreamSource

terminate

public boolean terminate()

This function is used to terminate the data source.

Specified by:

terminate in interface IStreamSource

start

public boolean start()

Function called to start reading

Specified by:

start in interface IStreamSource

Returns:

true if successful, false otherwise

end

public boolean end()

Function called to end reading. cleanupCrtFile (which generates the "done"-file) is called only if the current file has been processed completely.

Specified by:

end in interface IStreamSource

Returns:

true if successful, false otherwise

cleanupCrtFile

public boolean cleanupCrtFile()

Returns:

true if successful, false otherwise

initFileMgr

protected boolean initFileMgr(java.lang.String inputDir,
                              java.lang.String scratchDir,
                              java.io.FilenameFilter filter)

This function initializes the file manager. To be overridden if necessary.

Returns:

true if successful, false otherwise

checkDir

protected boolean checkDir(java.lang.String dir)

debug

protected void debug(java.lang.String fName,
                     java.lang.String msg)