public class DataModuleHandler extends AbstractModuleHandler
AbstractModuleHandler.CloseOnFailureCallback, AbstractModuleHandler.DefaultMirrorCommand<T extends MirrorableMessage<T>>, AbstractModuleHandler.MirrorCommandImpl<T>| Constructor and Description |
|---|
DataModuleHandler(DataModuleOptions options,
MessageChannel messageChannel,
DataModel dataModel) |
| 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 |
handleReadCommandComplete(ASDUHeader originalHeader,
InformationObjectAddress address,
Value<?> result) |
protected void |
handleReadFailure(ASDUHeader originalHeader,
InformationObjectAddress address,
Throwable t) |
channelReadComplete, channelRegistered, channelUnregistered, channelWritabilityChanged, exceptionCaught, userEventTriggeredhandlerAdded, handlerRemoved, isSharablepublic DataModuleHandler(DataModuleOptions options, MessageChannel messageChannel, DataModel dataModel)
public void channelActive(io.netty.channel.ChannelHandlerContext ctx)
throws Exception
channelActive in interface io.netty.channel.ChannelInboundHandlerchannelActive in class io.netty.channel.ChannelInboundHandlerAdapterExceptionpublic void channelInactive(io.netty.channel.ChannelHandlerContext ctx)
throws Exception
channelInactive in interface io.netty.channel.ChannelInboundHandlerchannelInactive in class io.netty.channel.ChannelInboundHandlerAdapterExceptionpublic void channelRead(io.netty.channel.ChannelHandlerContext ctx,
Object msg)
throws Exception
channelRead in interface io.netty.channel.ChannelInboundHandlerchannelRead in class io.netty.channel.ChannelInboundHandlerAdapterExceptionprotected void handleReadFailure(ASDUHeader originalHeader, InformationObjectAddress address, Throwable t)
protected void handleReadCommandComplete(ASDUHeader originalHeader, InformationObjectAddress address, Value<?> result)
Copyright © 2017 Eclipse NeoSCADA Project. All rights reserved.