public class ActiveMQChannelHandler
extends io.netty.channel.ChannelDuplexHandler
Modifier | Constructor and Description |
---|---|
protected |
ActiveMQChannelHandler(io.netty.channel.group.ChannelGroup group,
BufferHandler handler,
BaseConnectionLifeCycleListener<?> listener,
Executor listenerExecutor) |
Modifier and Type | Method and Description |
---|---|
void |
channelActive(io.netty.channel.ChannelHandlerContext ctx) |
protected static Object |
channelId(io.netty.channel.Channel channel) |
void |
channelInactive(io.netty.channel.ChannelHandlerContext ctx) |
void |
channelRead(io.netty.channel.ChannelHandlerContext ctx,
Object msg) |
void |
channelWritabilityChanged(io.netty.channel.ChannelHandlerContext ctx) |
void |
exceptionCaught(io.netty.channel.ChannelHandlerContext ctx,
Throwable cause) |
bind, close, connect, deregister, disconnect, flush, read, write
channelReadComplete, channelRegistered, channelUnregistered, userEventTriggered
ensureNotSharable, handlerAdded, handlerRemoved, isSharable
protected ActiveMQChannelHandler(io.netty.channel.group.ChannelGroup group, BufferHandler handler, BaseConnectionLifeCycleListener<?> listener, Executor listenerExecutor)
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 channelWritabilityChanged(io.netty.channel.ChannelHandlerContext ctx) throws Exception
channelWritabilityChanged
in interface io.netty.channel.ChannelInboundHandler
channelWritabilityChanged
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
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 exceptionCaught(io.netty.channel.ChannelHandlerContext ctx, Throwable cause) throws Exception
exceptionCaught
in interface io.netty.channel.ChannelHandler
exceptionCaught
in interface io.netty.channel.ChannelInboundHandler
exceptionCaught
in class io.netty.channel.ChannelInboundHandlerAdapter
Exception
protected static Object channelId(io.netty.channel.Channel channel)
Copyright © 2019 JBoss by Red Hat. All rights reserved.