public class MessageChannel
extends io.netty.channel.ChannelDuplexHandler
Constructor and Description |
---|
MessageChannel(ProtocolOptions options,
MessageManager manager) |
Modifier and Type | Method and Description |
---|---|
void |
addSource(MessageSource messageSource) |
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 |
handleAck(io.netty.channel.ChannelHandlerContext ctx,
int receiveSequenceNumber) |
protected void |
handleInformationTransfer(InformationTransfer msg) |
protected void |
handleTimeout1() |
protected void |
handleTimeout2() |
protected void |
handleTimeout3() |
void |
write(io.netty.channel.ChannelHandlerContext ctx,
Object msg,
io.netty.channel.ChannelPromise promise) |
bind, close, connect, deregister, disconnect, flush, read
channelReadComplete, channelRegistered, channelUnregistered, channelWritabilityChanged, exceptionCaught, userEventTriggered
handlerAdded, handlerRemoved, isSharable
public MessageChannel(ProtocolOptions options, MessageManager manager)
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
protected void handleTimeout1()
protected void handleTimeout2()
protected void handleTimeout3()
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 handleInformationTransfer(InformationTransfer msg)
protected void handleAck(io.netty.channel.ChannelHandlerContext ctx, int receiveSequenceNumber)
public void write(io.netty.channel.ChannelHandlerContext ctx, Object msg, io.netty.channel.ChannelPromise promise) throws Exception
write
in interface io.netty.channel.ChannelOutboundHandler
write
in class io.netty.channel.ChannelDuplexHandler
Exception
public void addSource(MessageSource messageSource)