@InterfaceAudience.Private public class SaslClientHandler extends ChannelDuplexHandler
Modifier and Type | Class and Description |
---|---|
static interface |
SaslClientHandler.SaslExceptionHandler
Handler for exceptions during Sasl connection
|
static interface |
SaslClientHandler.SaslSuccessfulConnectHandler
Handler for successful connects
|
Modifier and Type | Field and Description |
---|---|
static Log |
LOG |
Constructor and Description |
---|
SaslClientHandler(UserGroupInformation ticket,
AuthMethod method,
<any> token,
java.lang.String serverPrincipal,
boolean fallbackAllowed,
java.lang.String rpcProtection,
SaslClientHandler.SaslExceptionHandler exceptionHandler,
SaslClientHandler.SaslSuccessfulConnectHandler successfulConnectHandler)
Constructor
|
Modifier and Type | Method and Description |
---|---|
void |
channelRead(ChannelHandlerContext ctx,
java.lang.Object msg) |
void |
channelUnregistered(ChannelHandlerContext ctx) |
protected javax.security.sasl.SaslClient |
createDigestSaslClient(java.lang.String[] mechanismNames,
java.lang.String saslDefaultRealm,
javax.security.auth.callback.CallbackHandler saslClientCallbackHandler)
Create a Digest Sasl client
|
protected javax.security.sasl.SaslClient |
createKerberosSaslClient(java.lang.String[] mechanismNames,
java.lang.String userFirstPart,
java.lang.String userSecondPart)
Create Kerberos client
|
void |
exceptionCaught(ChannelHandlerContext ctx,
java.lang.Throwable cause) |
void |
handlerAdded(ChannelHandlerContext ctx) |
void |
write(ChannelHandlerContext ctx,
java.lang.Object msg,
ChannelPromise promise) |
public SaslClientHandler(UserGroupInformation ticket, AuthMethod method, <any> token, java.lang.String serverPrincipal, boolean fallbackAllowed, java.lang.String rpcProtection, SaslClientHandler.SaslExceptionHandler exceptionHandler, SaslClientHandler.SaslSuccessfulConnectHandler successfulConnectHandler) throws java.io.IOException
ticket
- the ugimethod
- auth methodtoken
- for SaslserverPrincipal
- Server's Kerberos principal namefallbackAllowed
- True if server may also fall back to less secure connectionrpcProtection
- Quality of protection. Integrity or privacyexceptionHandler
- handler for exceptionssuccessfulConnectHandler
- handler for succesful connectsjava.io.IOException
- if handler could not be createdprotected javax.security.sasl.SaslClient createDigestSaslClient(java.lang.String[] mechanismNames, java.lang.String saslDefaultRealm, javax.security.auth.callback.CallbackHandler saslClientCallbackHandler) throws java.io.IOException
mechanismNames
- names of mechanismssaslDefaultRealm
- default realm for saslsaslClientCallbackHandler
- handler for the clientjava.io.IOException
- if creation went wrongprotected javax.security.sasl.SaslClient createKerberosSaslClient(java.lang.String[] mechanismNames, java.lang.String userFirstPart, java.lang.String userSecondPart) throws java.io.IOException
mechanismNames
- names of mechanismsuserFirstPart
- first part of usernameuserSecondPart
- second part of usernamejava.io.IOException
- if failspublic void channelUnregistered(ChannelHandlerContext ctx) throws java.lang.Exception
java.lang.Exception
public void handlerAdded(ChannelHandlerContext ctx) throws java.lang.Exception
java.lang.Exception
public void channelRead(ChannelHandlerContext ctx, java.lang.Object msg) throws java.lang.Exception
java.lang.Exception
public void exceptionCaught(ChannelHandlerContext ctx, java.lang.Throwable cause) throws java.lang.Exception
java.lang.Exception
public void write(ChannelHandlerContext ctx, java.lang.Object msg, ChannelPromise promise) throws java.lang.Exception
java.lang.Exception