org.eclipse.neoscada.protocol.iec60870.client.data

Class DataModuleHandler

java.lang.Object

io.netty.channel.ChannelHandlerAdapter

io.netty.channel.ChannelInboundHandlerAdapter

org.eclipse.neoscada.protocol.iec60870.io.AbstractModuleHandler

org.eclipse.neoscada.protocol.iec60870.client.data.DataModuleHandler

All Implemented Interfaces:

io.netty.channel.ChannelHandler, io.netty.channel.ChannelInboundHandler, DataModuleContext

public class DataModuleHandler
extends AbstractModuleHandler
implements DataModuleContext

Nested Class Summary

Nested classes/interfaces inherited from class org.eclipse.neoscada.protocol.iec60870.io.AbstractModuleHandler

AbstractModuleHandler.CloseOnFailureCallback, AbstractModuleHandler.DefaultMirrorCommand<T extends MirrorableMessage<T>>, AbstractModuleHandler.MirrorCommandImpl<T>

Nested classes/interfaces inherited from interface io.netty.channel.ChannelHandler

io.netty.channel.ChannelHandler.Sharable

Constructor Summary

Constructors

Constructor and Description
DataModuleHandler(DataHandler dataHandler, DataModuleOptions options)

Method Summary

Modifier and Type	Method and Description
void	channelActive(io.netty.channel.ChannelHandlerContext ctx)
void	channelInactive(io.netty.channel.ChannelHandlerContext ctx)
void	channelRead(io.netty.channel.ChannelHandlerContext ctx, Object msg)
protected void	handleDataMessage(DoublePointInformationSequence msg)
protected void	handleDataMessage(DoublePointInformationSingle msg)
protected void	handleDataMessage(DoublePointInformationTimeSingle msg)
protected void	handleDataMessage(MeasuredValueScaledSequence msg)
protected void	handleDataMessage(MeasuredValueScaledSingle msg)
protected void	handleDataMessage(MeasuredValueScaledTimeSingle msg)
protected void	handleDataMessage(MeasuredValueShortFloatingPointSequence msg)
protected void	handleDataMessage(MeasuredValueShortFloatingPointSingle msg)
protected void	handleDataMessage(MeasuredValueShortFloatingPointTimeSingle msg)
protected void	handleDataMessage(SinglePointInformationSequence msg)
protected void	handleDataMessage(SinglePointInformationSingle msg)
protected void	handleDataMessage(SinglePointInformationTimeSingle msg)
protected void	handleDisconnected()
protected void	handleStarted()
protected boolean	ignoreMessage(AbstractMessage msg)
protected ASDUHeader	makeHeader(Cause cause, ASDUAddress address)
void	requestStartData()
void	startInterrogation(ASDUAddress address, short qualifierOfInterrogation)

Methods inherited from class io.netty.channel.ChannelInboundHandlerAdapter

channelReadComplete, channelRegistered, channelUnregistered, channelWritabilityChanged, exceptionCaught, userEventTriggered

Methods inherited from class io.netty.channel.ChannelHandlerAdapter

handlerAdded, handlerRemoved, isSharable

Methods inherited from class java.lang.Object

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

Methods inherited from interface io.netty.channel.ChannelHandler

handlerAdded, handlerRemoved

Constructor Detail

DataModuleHandler

public DataModuleHandler(DataHandler dataHandler,
                         DataModuleOptions options)

Method Detail

channelActive

public void channelActive(io.netty.channel.ChannelHandlerContext ctx)
                   throws Exception

Specified by:

channelActive in interface io.netty.channel.ChannelInboundHandler

Overrides:

channelActive in class io.netty.channel.ChannelInboundHandlerAdapter

Throws:

Exception

makeHeader

protected ASDUHeader makeHeader(Cause cause,
                                ASDUAddress address)

startInterrogation

public void startInterrogation(ASDUAddress address,
                               short qualifierOfInterrogation)

Specified by:

startInterrogation in interface DataModuleContext

requestStartData

public void requestStartData()

Specified by:

requestStartData in interface DataModuleContext

channelRead

public void channelRead(io.netty.channel.ChannelHandlerContext ctx,
                        Object msg)
                 throws Exception

Specified by:

channelRead in interface io.netty.channel.ChannelInboundHandler

Overrides:

channelRead in class io.netty.channel.ChannelInboundHandlerAdapter

Throws:

Exception

channelInactive

public void channelInactive(io.netty.channel.ChannelHandlerContext ctx)
                     throws Exception

Specified by:

channelInactive in interface io.netty.channel.ChannelInboundHandler

Overrides:

channelInactive in class io.netty.channel.ChannelInboundHandlerAdapter

Throws:

Exception

handleDisconnected

protected void handleDisconnected()

handleStarted

protected void handleStarted()

ignoreMessage

protected boolean ignoreMessage(AbstractMessage msg)

handleDataMessage

protected void handleDataMessage(SinglePointInformationTimeSingle msg)

handleDataMessage

protected void handleDataMessage(SinglePointInformationSequence msg)

handleDataMessage

protected void handleDataMessage(SinglePointInformationSingle msg)

handleDataMessage

protected void handleDataMessage(DoublePointInformationSequence msg)

handleDataMessage

protected void handleDataMessage(DoublePointInformationSingle msg)

handleDataMessage

protected void handleDataMessage(DoublePointInformationTimeSingle msg)

handleDataMessage

protected void handleDataMessage(MeasuredValueShortFloatingPointTimeSingle msg)

handleDataMessage

protected void handleDataMessage(MeasuredValueShortFloatingPointSingle msg)

handleDataMessage

protected void handleDataMessage(MeasuredValueShortFloatingPointSequence msg)

handleDataMessage

protected void handleDataMessage(MeasuredValueScaledSequence msg)

handleDataMessage

protected void handleDataMessage(MeasuredValueScaledSingle msg)

handleDataMessage

protected void handleDataMessage(MeasuredValueScaledTimeSingle msg)