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 Summary
Nested classes/interfaces inherited from interface org.apache.storm.shade.io.netty.channel.ChannelHandler
org.apache.storm.shade.io.netty.channel.ChannelHandler.Sharable
-
Field Summary
-
Constructor Summary
ConstructorDescriptionThriftNettyClientCodec
(PacemakerClient pacemakerClient, Map<String, Object> topoConf, ThriftNettyClientCodec.AuthMethod authMethod, String host, int thriftMessageMaxSizeBytes) -
Method Summary
Modifier and TypeMethodDescriptionprotected void
initChannel
(org.apache.storm.shade.io.netty.channel.Channel ch) Methods inherited from class org.apache.storm.shade.io.netty.channel.ChannelInitializer
channelRegistered, exceptionCaught, handlerAdded, handlerRemoved
Methods inherited from class org.apache.storm.shade.io.netty.channel.ChannelInboundHandlerAdapter
channelActive, channelInactive, channelRead, channelReadComplete, channelUnregistered, channelWritabilityChanged, userEventTriggered
Methods inherited from class org.apache.storm.shade.io.netty.channel.ChannelHandlerAdapter
ensureNotSharable, isSharable
-
Field Details
-
SASL_HANDLER
- See Also:
-
KERBEROS_HANDLER
- See Also:
-
-
Constructor Details
-
ThriftNettyClientCodec
public ThriftNettyClientCodec(PacemakerClient pacemakerClient, Map<String, Object> topoConf, ThriftNettyClientCodec.AuthMethod authMethod, String host, int thriftMessageMaxSizeBytes)
-
-
Method Details
-
initChannel
- Specified by:
initChannel
in classorg.apache.storm.shade.io.netty.channel.ChannelInitializer<org.apache.storm.shade.io.netty.channel.Channel>
- Throws:
Exception
-