com.devexperts.qd.util

Class DataProcessor

java.lang.Object

com.devexperts.qd.util.RecordProcessor

com.devexperts.qd.util.DataProcessor

Deprecated.

Use RecordProcessor.

public abstract class DataProcessor
extends RecordProcessor

This class is base class for listening QD for data availability and rescheduling its processing using Executor.

Constructor Summary

Constructors

Modifier	Constructor and Description
protected	DataProcessor(Executor executor) Deprecated. Constructs new data processor for the specified executor.

Method Summary

Modifier and Type	Method and Description
protected void	process(RecordSource source) Deprecated. Method for processing incoming records.
protected abstract void	processData(RecordSource source) Deprecated. Method for processing incoming data from QD.
void	startProcessing(DataProvider provider) Deprecated. Starts processing for the specified DataProvider.

Methods inherited from class com.devexperts.qd.util.RecordProcessor

hasMoreToProcess, signalNoMoreToProcess, startProcessing, stopProcessing

Methods inherited from class java.lang.Object

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

Constructor Detail

DataProcessor

protected DataProcessor(Executor executor)

Deprecated.

Constructs new data processor for the specified executor.

Throws:

NullPointerException - if executor is null.

Method Detail

processData

protected abstract void processData(RecordSource source)

Deprecated.

Method for processing incoming data from QD. When data is received, DataProcessor calls this method in Executor thread.

process

protected final void process(RecordSource source)

Deprecated.

Description copied from class: RecordProcessor

Method for processing incoming records. When record is received, RecordProcessor calls this method in Executor thread.

Specified by:

process in class RecordProcessor

startProcessing

public void startProcessing(DataProvider provider)

Deprecated.

Starts processing for the specified DataProvider. This method may be called at most once after construction.

Throws:

NullPointerException - if provider is null.

IllegalStateException - if called multiple times. It is checked weakly to ensure fail-fast error detection behaviour. There is no strict thread-safe guarantee for this exception to be thrown if this method is called concurrently from multiple threads.