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, userEventTriggered
handlerAdded, handlerRemoved, isSharable
public DataModuleHandler(DataModuleOptions options, MessageChannel messageChannel, DataModel dataModel)
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
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
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
protected void handleReadFailure(ASDUHeader originalHeader, InformationObjectAddress address, Throwable t)
protected void handleReadCommandComplete(ASDUHeader originalHeader, InformationObjectAddress address, Value<?> result)