public class DataProcessor extends Object implements DataHandler
Constructor and Description |
---|
DataProcessor(Executor executor,
DataListener listener) |
Modifier and Type | Method and Description |
---|---|
void |
activated(DataModuleContext dataModuleContext,
io.netty.channel.ChannelHandlerContext ctx) |
void |
disconnected() |
protected void |
fireEntry(ASDUAddress asduAddress,
InformationObjectAddress address,
Value<?> value) |
void |
process(DoublePointInformationSequence msg) |
void |
process(DoublePointInformationSingle msg) |
void |
process(DoublePointInformationTimeSingle msg) |
void |
process(MeasuredValueScaledSequence msg) |
void |
process(MeasuredValueScaledSingle msg) |
void |
process(MeasuredValueScaledTimeSingle msg) |
void |
process(MeasuredValueShortFloatingPointSequence msg) |
void |
process(MeasuredValueShortFloatingPointSingle msg) |
void |
process(MeasuredValueShortFloatingPointTimeSingle msg) |
void |
process(SinglePointInformationSequence msg) |
void |
process(SinglePointInformationSingle msg) |
void |
process(SinglePointInformationTimeSingle msg) |
void |
started() |
public DataProcessor(Executor executor, DataListener listener)
public void activated(DataModuleContext dataModuleContext, io.netty.channel.ChannelHandlerContext ctx)
activated
in interface DataHandler
public void started()
started
in interface DataHandler
public void disconnected()
disconnected
in interface DataHandler
protected void fireEntry(ASDUAddress asduAddress, InformationObjectAddress address, Value<?> value)
public void process(SinglePointInformationTimeSingle msg)
process
in interface DataHandler
public void process(SinglePointInformationSingle msg)
process
in interface DataHandler
public void process(SinglePointInformationSequence msg)
process
in interface DataHandler
public void process(DoublePointInformationTimeSingle msg)
process
in interface DataHandler
public void process(DoublePointInformationSingle msg)
process
in interface DataHandler
public void process(DoublePointInformationSequence msg)
process
in interface DataHandler
public void process(MeasuredValueShortFloatingPointTimeSingle msg)
process
in interface DataHandler
public void process(MeasuredValueShortFloatingPointSingle msg)
process
in interface DataHandler
public void process(MeasuredValueShortFloatingPointSequence msg)
process
in interface DataHandler
public void process(MeasuredValueScaledTimeSingle msg)
process
in interface DataHandler
public void process(MeasuredValueScaledSingle msg)
process
in interface DataHandler
public void process(MeasuredValueScaledSequence msg)
process
in interface DataHandler