public class ThriftNettyClientCodec
extends org.apache.storm.shade.io.netty.channel.ChannelInitializer<org.apache.storm.shade.io.netty.channel.Channel>
Modifier and Type | Class and Description |
---|---|
static class |
ThriftNettyClientCodec.AuthMethod |
Modifier and Type | Field and Description |
---|---|
static String |
KERBEROS_HANDLER |
static String |
SASL_HANDLER |
Constructor and Description |
---|
ThriftNettyClientCodec(PacemakerClient pacemakerClient,
Map<String,Object> topoConf,
ThriftNettyClientCodec.AuthMethod authMethod,
String host,
int thriftMessageMaxSizeBytes) |
Modifier and Type | Method and Description |
---|---|
protected void |
initChannel(org.apache.storm.shade.io.netty.channel.Channel ch) |
channelRegistered, exceptionCaught, handlerAdded
channelActive, channelInactive, channelRead, channelReadComplete, channelUnregistered, channelWritabilityChanged, userEventTriggered
ensureNotSharable, handlerRemoved, isSharable
public static final String SASL_HANDLER
public static final String KERBEROS_HANDLER
public ThriftNettyClientCodec(PacemakerClient pacemakerClient, Map<String,Object> topoConf, ThriftNettyClientCodec.AuthMethod authMethod, String host, int thriftMessageMaxSizeBytes)
Copyright © 2022 The Apache Software Foundation. All rights reserved.