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, java.lang.Runnable

public class IPDRFileTransport
extends IPDRTransport

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

Field Summary

Fields

Modifier and Type	Field and Description
protected java.io.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 and Description
IPDRFileTransport(LoggerIfc logger, ConfigIfc config, java.io.File scratchDir)

Method Summary

Methods

Modifier and Type	Method and 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

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

m_inputDir

protected java.io.File m_inputDir

Constructor Detail

IPDRFileTransport

public IPDRFileTransport(LoggerIfc logger,
                 ConfigIfc config,
                 java.io.File scratchDir)
                  throws java.lang.Exception

Throws:

java.lang.Exception

Method Detail

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 java.lang.Exception

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

Specified by:

initStreamSource in class IPDRTransport

Throws:

java.lang.Exception