public class DataModuleMessageSource extends Object implements MessageSource
Modifier and Type | Class and Description |
---|---|
static class |
DataModuleMessageSource.InterrogationException |
NOTIFY_TOKEN
Constructor and Description |
---|
DataModuleMessageSource(DataModuleOptions options,
ScheduledExecutorService executor,
ChannelWriter writer,
DataModel model,
long backgroundScanPeriod) |
Modifier and Type | Method and Description |
---|---|
void |
completeInterrogation(org.eclipse.neoscada.protocol.iec60870.server.data.DataModuleMessageSource.InterrogationRequest request) |
Object |
poll()
Poll the next message from the message source
|
void |
sendBooleanValue(ASDUHeader header,
InformationObjectAddress address,
Value<Boolean> value) |
void |
sendBooleanValues(ASDUHeader header,
InformationObjectAddress startAddress,
List<Value<Boolean>> values) |
void |
sendBooleanValues(ASDUHeader header,
List<InformationEntry<Boolean>> values) |
void |
sendFloatValue(ASDUHeader header,
InformationObjectAddress address,
Value<Float> value) |
void |
sendFloatValues(ASDUHeader header,
InformationObjectAddress startAddress,
List<Value<Float>> values) |
void |
sendFloatValues(ASDUHeader header,
List<InformationEntry<Float>> values) |
void |
startInterrogation(InterrogationCommand msg)
Start the process of interrogation
|
public DataModuleMessageSource(DataModuleOptions options, ScheduledExecutorService executor, ChannelWriter writer, DataModel model, long backgroundScanPeriod)
public Object poll()
MessageSource
poll
in interface MessageSource
null
if there currently
is no messagepublic void sendBooleanValue(ASDUHeader header, InformationObjectAddress address, Value<Boolean> value)
public void sendBooleanValues(ASDUHeader header, InformationObjectAddress startAddress, List<Value<Boolean>> values)
public void sendBooleanValues(ASDUHeader header, List<InformationEntry<Boolean>> values)
public void sendFloatValue(ASDUHeader header, InformationObjectAddress address, Value<Float> value)
public void sendFloatValues(ASDUHeader header, InformationObjectAddress startAddress, List<Value<Float>> values)
public void sendFloatValues(ASDUHeader header, List<InformationEntry<Float>> values)
public void startInterrogation(InterrogationCommand msg)
asduAddress
- causeOfTransmission
- qualifierOfInterrogation
- public void completeInterrogation(org.eclipse.neoscada.protocol.iec60870.server.data.DataModuleMessageSource.InterrogationRequest request)