public class DataModuleHandler extends AbstractModuleHandler implements DataModuleContext
AbstractModuleHandler.CloseOnFailureCallback, AbstractModuleHandler.DefaultMirrorCommand<T extends MirrorableMessage<T>>, AbstractModuleHandler.MirrorCommandImpl<T>
Constructor and Description |
---|
DataModuleHandler(DataHandler dataHandler,
DataModuleOptions options) |
channelReadComplete, channelRegistered, channelUnregistered, channelWritabilityChanged, exceptionCaught, userEventTriggered
handlerAdded, handlerRemoved, isSharable
public DataModuleHandler(DataHandler dataHandler, DataModuleOptions options)
public void channelActive(io.netty.channel.ChannelHandlerContext ctx) throws Exception
channelActive
in interface io.netty.channel.ChannelInboundHandler
channelActive
in class io.netty.channel.ChannelInboundHandlerAdapter
Exception
protected ASDUHeader makeHeader(Cause cause, ASDUAddress address)
public void startInterrogation(ASDUAddress address, short qualifierOfInterrogation)
startInterrogation
in interface DataModuleContext
public void requestStartData()
requestStartData
in interface DataModuleContext
public void channelRead(io.netty.channel.ChannelHandlerContext ctx, Object msg) throws Exception
channelRead
in interface io.netty.channel.ChannelInboundHandler
channelRead
in class io.netty.channel.ChannelInboundHandlerAdapter
Exception
public void channelInactive(io.netty.channel.ChannelHandlerContext ctx) throws Exception
channelInactive
in interface io.netty.channel.ChannelInboundHandler
channelInactive
in class io.netty.channel.ChannelInboundHandlerAdapter
Exception
protected void handleDisconnected()
protected void handleStarted()
protected void handleDataMessage(SinglePointInformationTimeSingle msg)
protected boolean ignoreMessage(SinglePointInformationTimeSingle msg)
protected void handleDataMessage(SinglePointInformationSequence msg)
protected void handleDataMessage(SinglePointInformationSingle msg)
protected void handleDataMessage(DoublePointInformationSequence msg)
protected void handleDataMessage(DoublePointInformationSingle msg)
protected void handleDataMessage(DoublePointInformationTimeSingle msg)
protected void handleDataMessage(MeasuredValueShortFloatingPointTimeSingle msg)
protected void handleDataMessage(MeasuredValueShortFloatingPointSingle msg)
protected void handleDataMessage(MeasuredValueShortFloatingPointSequence msg)
protected void handleDataMessage(MeasuredValueScaledSequence msg)
protected void handleDataMessage(MeasuredValueScaledSingle msg)
protected void handleDataMessage(MeasuredValueScaledTimeSingle msg)