public class KerberosSaslClientHandler
extends org.apache.storm.shade.io.netty.channel.ChannelInboundHandlerAdapter
| Constructor and Description |
|---|
KerberosSaslClientHandler(ISaslClient client,
Map<String,Object> topoConf,
String jaasSection,
String host) |
| Modifier and Type | Method and Description |
|---|---|
void |
channelActive(org.apache.storm.shade.io.netty.channel.ChannelHandlerContext ctx) |
void |
channelRead(org.apache.storm.shade.io.netty.channel.ChannelHandlerContext ctx,
Object message) |
void |
channelRegistered(org.apache.storm.shade.io.netty.channel.ChannelHandlerContext ctx) |
void |
channelUnregistered(org.apache.storm.shade.io.netty.channel.ChannelHandlerContext ctx) |
void |
exceptionCaught(org.apache.storm.shade.io.netty.channel.ChannelHandlerContext ctx,
Throwable cause) |
channelInactive, channelReadComplete, channelWritabilityChanged, userEventTriggeredensureNotSharable, handlerAdded, handlerRemoved, isSharablepublic KerberosSaslClientHandler(ISaslClient client, Map<String,Object> topoConf, String jaasSection, String host) throws IOException
IOExceptionpublic void channelActive(org.apache.storm.shade.io.netty.channel.ChannelHandlerContext ctx)
channelActive in interface org.apache.storm.shade.io.netty.channel.ChannelInboundHandlerchannelActive in class org.apache.storm.shade.io.netty.channel.ChannelInboundHandlerAdapterpublic void channelRead(org.apache.storm.shade.io.netty.channel.ChannelHandlerContext ctx,
Object message)
throws Exception
channelRead in interface org.apache.storm.shade.io.netty.channel.ChannelInboundHandlerchannelRead in class org.apache.storm.shade.io.netty.channel.ChannelInboundHandlerAdapterExceptionpublic void channelRegistered(org.apache.storm.shade.io.netty.channel.ChannelHandlerContext ctx)
throws Exception
channelRegistered in interface org.apache.storm.shade.io.netty.channel.ChannelInboundHandlerchannelRegistered in class org.apache.storm.shade.io.netty.channel.ChannelInboundHandlerAdapterExceptionpublic void channelUnregistered(org.apache.storm.shade.io.netty.channel.ChannelHandlerContext ctx)
throws Exception
channelUnregistered in interface org.apache.storm.shade.io.netty.channel.ChannelInboundHandlerchannelUnregistered in class org.apache.storm.shade.io.netty.channel.ChannelInboundHandlerAdapterExceptionpublic void exceptionCaught(org.apache.storm.shade.io.netty.channel.ChannelHandlerContext ctx,
Throwable cause)
throws Exception
exceptionCaught in interface org.apache.storm.shade.io.netty.channel.ChannelHandlerexceptionCaught in interface org.apache.storm.shade.io.netty.channel.ChannelInboundHandlerexceptionCaught in class org.apache.storm.shade.io.netty.channel.ChannelInboundHandlerAdapterExceptionCopyright © 2021 The Apache Software Foundation. All rights reserved.