org.eclipse.scada.protocol.iec60870.server.data

Class DataModuleMessageSource

java.lang.Object

org.eclipse.scada.protocol.iec60870.server.data.DataModuleMessageSource

All Implemented Interfaces:

MessageSource

public class DataModuleMessageSource
extends Object
implements MessageSource

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	DataModuleMessageSource.InterrogationException

Field Summary

Fields inherited from interface org.eclipse.scada.protocol.iec60870.apci.MessageSource

NOTIFY_TOKEN

Constructor Summary

Constructors

Constructor and Description
DataModuleMessageSource(DataModuleOptions options, ScheduledExecutorService executor, ChannelWriter writer, DataModel model, long backgroundScanPeriod)

Method Summary

Methods

Modifier and Type	Method and Description
void	completeInterrogation(org.eclipse.scada.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	sendFloatValue(ASDUHeader header, InformationObjectAddress address, Value<Float> value)
void	startInterrogation(InterrogationCommand msg) Start the process of interrogation

Methods inherited from class java.lang.Object

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

Constructor Detail

DataModuleMessageSource

public DataModuleMessageSource(DataModuleOptions options,
                       ScheduledExecutorService executor,
                       ChannelWriter writer,
                       DataModel model,
                       long backgroundScanPeriod)

Method Detail

poll

public Object poll()

Description copied from interface: MessageSource

Poll the next message from the message source

Specified by:

poll in interface MessageSource

Returns:

the next message to send, or null if there currently is no message

sendBooleanValue

public void sendBooleanValue(ASDUHeader header,
                    InformationObjectAddress address,
                    Value<Boolean> value)

sendFloatValue

public void sendFloatValue(ASDUHeader header,
                  InformationObjectAddress address,
                  Value<Float> value)

startInterrogation

public void startInterrogation(InterrogationCommand msg)

Start the process of interrogation

Parameters:

asduAddress -

causeOfTransmission -

qualifierOfInterrogation -

completeInterrogation

public void completeInterrogation(org.eclipse.scada.protocol.iec60870.server.data.DataModuleMessageSource.InterrogationRequest request)