public class ThriftNettyServerCodec
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 |
ThriftNettyServerCodec.AuthMethod |
| Modifier and Type | Field and Description |
|---|---|
static String |
KERBEROS_HANDLER |
static String |
SASL_HANDLER |
| Constructor and Description |
|---|
ThriftNettyServerCodec(IServer server,
Map<String,Object> topoConf,
ThriftNettyServerCodec.AuthMethod authMethod,
int thriftMessageMaxSizeBytes) |
| Modifier and Type | Method and Description |
|---|---|
protected void |
initChannel(org.apache.storm.shade.io.netty.channel.Channel ch) |
channelRegistered, exceptionCaught, handlerAddedchannelActive, channelInactive, channelRead, channelReadComplete, channelUnregistered, channelWritabilityChanged, userEventTriggeredensureNotSharable, handlerRemoved, isSharablepublic static final String SASL_HANDLER
public static final String KERBEROS_HANDLER
public ThriftNettyServerCodec(IServer server, Map<String,Object> topoConf, ThriftNettyServerCodec.AuthMethod authMethod, int thriftMessageMaxSizeBytes)
Copyright © 2021 The Apache Software Foundation. All rights reserved.