public class SoapXmlEITransport extends EITransport
Modifier and Type | Field and Description |
---|---|
protected int |
delay |
protected boolean |
running |
protected SoapMessageHandler[] |
soapMsgHandlers |
dataReceiver, fdChecked, filedataReceiver, fileduplicateCheck, fileToProcess, inputCount, lockFile, movedFile, node, pollingInterval, processing, processingData
Constructor and Description |
---|
SoapXmlEITransport(EINode node,
SoapMessageHandler[] handlers,
int delay) |
Modifier and Type | Method and Description |
---|---|
DCFieldContainer[] |
getBulkData()
This method is used by the DataReceiver to fetch a set of
DCFieldContainer objects.
|
DCFieldContainer |
getData()
This method is used by the DataReceiver to fetch a single
|
boolean |
isDataAvailable()
This method is used by the DataReceiver to ask this provider if
data is available.
|
void |
run()
This method is used to control processing for fetching data from
the EI's source.
|
void |
shutdown()
This method is used to provide a means of shutting down the transport
in an orderly fashion.
|
getDataReceiver, getDubCheckObj, getDupCheckFlag, getFileBulkData, getFileData, getFileDataReceiver, getMovedFileStatus, getNode, getPollingInterval, handleRejectOfFile, incrementIn, incrementIn, isEndOfFile, isFileDataAvailable, isHealthy, isProcessing, isProcessingData, isStartOfFile, openInputFile, rejectFile, setCountsSuspect, setDataReceiver, setFileDataReceiver, setFileToProcess, setMovedFileStatus, setNode, setPollingInterval, setProcessing
protected SoapMessageHandler[] soapMsgHandlers
protected int delay
protected boolean running
public SoapXmlEITransport(EINode node, SoapMessageHandler[] handlers, int delay) throws NodeStartException
NodeStartException
public boolean isDataAvailable()
isDataAvailable
in interface DataProviderIfc
isDataAvailable
in class EITransport
true
, if data is availablepublic DCFieldContainer getData()
EITransport
getData
in interface DataProviderIfc
getData
in class EITransport
public DCFieldContainer[] getBulkData()
EITransport
getBulkData
in interface DataProviderIfc
getBulkData
in class EITransport
public void run()
EITransport
run
in interface java.lang.Runnable
run
in class EITransport
public void shutdown()
EITransport
shutdown
in interface DCTransport
shutdown
in class EITransport