Package com.nt.udc.ei.node.ipdr

Class IPDRFileTransport

java.lang.Object

com.nt.udc.ndk.node.EITransport

com.nt.udc.ei.node.ipdr.IPDRTransport

com.nt.udc.ei.node.ipdr.IPDRFileTransport

All Implemented Interfaces:

DataProviderIfc, DCTransport, FileDataProviderIfc, Runnable

public class IPDRFileTransport
extends IPDRTransport

This class is used to collect IPDR data from flat files.

Field Summary

Fields

Modifier and Type	Field	Description
protected File	m_inputDir

Fields inherited from class com.nt.udc.ei.node.ipdr.IPDRTransport

m_config, m_debugLevel, m_iFilenameFilter, m_iLogger, m_iStreamSource, m_processor, m_reporter, m_scratchDir, SECS2MSECS

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	Description
IPDRFileTransport(LoggerIfc logger, ConfigIfc config, File scratchDir)

Method Summary

Modifier and Type	Method	Description
protected void	initStreamSource()	This function checks the configuration parameters and initializes the data source.
boolean	isHealthy()	This function checks if the transport is functional.

Methods inherited from class com.nt.udc.ei.node.ipdr.IPDRTransport

getBulkData, getData, initFilenameFilter, initialize, isDataAvailable, run, setProcessor, shutdown

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

getCurrArchFile, getData, getDataReceiver, getDubCheckObj, getDupCheckFlag, getFileBulkData, getFileData, getFileDataReceiver, getFileList, getMovedFileStatus, getNode, getPollingInterval, getProcessedArchFile, handleRejectOfFile, incrementIn, incrementIn, isEndOfFile, isFileDataAvailable, isProcessing, isProcessingData, isStartOfFile, moveCurrentFileToBackUp, openInputFile, rejectFile, removeProcessedFile, setCountsSuspect, setDataReceiver, setFileDataReceiver, setFileToProcess, setMovedFileStatus, setNode, setPollingInterval, setProcessedArchFile, setProcessing, signalBatchCompletion, validOIMinorType

Methods inherited from class java.lang.Object

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

Field Details

m_inputDir

protected File m_inputDir

Constructor Details

IPDRFileTransport

public IPDRFileTransport(LoggerIfc logger,
 ConfigIfc config,
 File scratchDir)
                  throws Exception

Throws:

Exception

Method Details

isHealthy

public boolean isHealthy()

This function checks if the transport is functional. In our case it means checking if the input directory is valid.

Specified by:

isHealthy in interface DCTransport

Overrides:

isHealthy in class EITransport

Returns:

true if the transport is healthy, false otherwise

initStreamSource

protected void initStreamSource()
                         throws Exception

This function checks the configuration parameters and initializes the data source.

Specified by:

initStreamSource in class IPDRTransport

Throws:

Exception