com.nt.udc.ei.node.xml

Class XMLFileTransport

java.lang.Object

com.nt.udc.ndk.node.EITransport

com.nt.udc.ei.node.xml.XMLTransport

com.nt.udc.ei.node.xml.XMLFileTransport

All Implemented Interfaces:

DataProviderIfc, DCTransport, FileDataProviderIfc, java.lang.Runnable

public class XMLFileTransport
extends XMLTransport

This class is used to collect XML 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.xml.XMLTransport

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

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
XMLFileTransport(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.xml.XMLTransport

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

XMLFileTransport

public XMLFileTransport(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 XMLTransport

Throws:

java.lang.Exception