Package org.apache.storm.pacemaker.codec
Class ThriftNettyClientCodec
java.lang.Object
org.apache.storm.shade.io.netty.channel.ChannelHandlerAdapter
org.apache.storm.shade.io.netty.channel.ChannelInboundHandlerAdapter
org.apache.storm.shade.io.netty.channel.ChannelInitializer<org.apache.storm.shade.io.netty.channel.Channel>
org.apache.storm.pacemaker.codec.ThriftNettyClientCodec
- All Implemented Interfaces:
- org.apache.storm.shade.io.netty.channel.ChannelHandler,- org.apache.storm.shade.io.netty.channel.ChannelInboundHandler
public class ThriftNettyClientCodec
extends org.apache.storm.shade.io.netty.channel.ChannelInitializer<org.apache.storm.shade.io.netty.channel.Channel>
- 
Nested Class SummaryNested ClassesNested classes/interfaces inherited from interface org.apache.storm.shade.io.netty.channel.ChannelHandlerorg.apache.storm.shade.io.netty.channel.ChannelHandler.Sharable
- 
Field SummaryFields
- 
Constructor SummaryConstructorsConstructorDescriptionThriftNettyClientCodec(PacemakerClient pacemakerClient, Map<String, Object> topoConf, ThriftNettyClientCodec.AuthMethod authMethod, String host, int thriftMessageMaxSizeBytes) 
- 
Method SummaryModifier and TypeMethodDescriptionprotected voidinitChannel(org.apache.storm.shade.io.netty.channel.Channel ch) Methods inherited from class org.apache.storm.shade.io.netty.channel.ChannelInitializerchannelRegistered, exceptionCaught, handlerAdded, handlerRemovedMethods inherited from class org.apache.storm.shade.io.netty.channel.ChannelInboundHandlerAdapterchannelActive, channelInactive, channelRead, channelReadComplete, channelUnregistered, channelWritabilityChanged, userEventTriggeredMethods inherited from class org.apache.storm.shade.io.netty.channel.ChannelHandlerAdapterensureNotSharable, isSharable
- 
Field Details- 
SASL_HANDLER- See Also:
 
- 
KERBEROS_HANDLER- See Also:
 
 
- 
- 
Constructor Details- 
ThriftNettyClientCodecpublic ThriftNettyClientCodec(PacemakerClient pacemakerClient, Map<String, Object> topoConf, ThriftNettyClientCodec.AuthMethod authMethod, String host, int thriftMessageMaxSizeBytes) 
 
- 
- 
Method Details- 
initChannel- Specified by:
- initChannelin class- org.apache.storm.shade.io.netty.channel.ChannelInitializer<org.apache.storm.shade.io.netty.channel.Channel>
- Throws:
- Exception
 
 
-