Class DataProcessEngine
- java.lang.Object
-
- com.inductiveautomation.gateway.tags.history.processing.DataProcessEngine
-
public class DataProcessEngine extends java.lang.Object
The DataProcessEngine simply loads all of the values from a DataProvider, passes them through a processor, and writes them to a DataHandler.
TODO This could probably be accomplished more directly with a simple Util class.
-
-
Constructor Summary
Constructors Constructor Description DataProcessEngine()
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description protected org.apache.log4j.Logger
getLogger()
protected void
handleProcessed(RawTagValue value)
protected void
handleProcessed(java.util.List<RawTagValue> values)
void
processData()
void
setContinueOnError(boolean value)
If true, the engine will log errors and continue on whenever a problem occurs.void
setDataHandler(DataHandler handler)
void
setDataProcessor(DataProcessor processor)
void
setDataProvider(DataProvider loader)
-
-
-
Method Detail
-
getLogger
protected org.apache.log4j.Logger getLogger()
-
setDataProvider
public void setDataProvider(DataProvider loader)
-
setDataProcessor
public void setDataProcessor(DataProcessor processor)
-
setDataHandler
public void setDataHandler(DataHandler handler)
-
setContinueOnError
public void setContinueOnError(boolean value)
If true, the engine will log errors and continue on whenever a problem occurs. Otherwise, the error will be re-thrown, and processing will stop.
-
processData
public void processData() throws java.lang.Exception
- Throws:
java.lang.Exception
-
handleProcessed
protected void handleProcessed(java.util.List<RawTagValue> values) throws java.lang.Exception
- Throws:
java.lang.Exception
-
handleProcessed
protected void handleProcessed(RawTagValue value) throws java.lang.Exception
- Throws:
java.lang.Exception
-
-