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

Modifier and Type	Class and Description
static class	ThriftNettyClientCodec.AuthMethod

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

Fields

Modifier and Type	Field and Description
static String	KERBEROS_HANDLER
static String	SASL_HANDLER

Constructor Summary

Constructors

Constructor and Description
ThriftNettyClientCodec(PacemakerClient pacemaker_client, Map<String,Object> topoConf, ThriftNettyClientCodec.AuthMethod authMethod, String host, int thriftMessageMaxSizeBytes)

Method Summary

Modifier and Type	Method and Description
protected 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

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, handlerRemoved, isSharable

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Methods inherited from interface org.apache.storm.shade.io.netty.channel.ChannelHandler

handlerRemoved

Field Detail

SASL_HANDLER

public static final String SASL_HANDLER

See Also:

Constant Field Values

KERBEROS_HANDLER

public static final String KERBEROS_HANDLER

See Also:

Constant Field Values

Constructor Detail

ThriftNettyClientCodec

public ThriftNettyClientCodec(PacemakerClient pacemaker_client,
                              Map<String,Object> topoConf,
                              ThriftNettyClientCodec.AuthMethod authMethod,
                              String host,
                              int thriftMessageMaxSizeBytes)

Method Detail

initChannel

protected void initChannel(org.apache.storm.shade.io.netty.channel.Channel ch)
                    throws Exception

Specified by:

initChannel in class org.apache.storm.shade.io.netty.channel.ChannelInitializer<org.apache.storm.shade.io.netty.channel.Channel>

Throws:

Exception