Package org.apache.storm.messaging.netty
Class SaslMessageToken
java.lang.Object
org.apache.storm.messaging.netty.SaslMessageToken
- All Implemented Interfaces:
 INettySerializable
Send and receive SASL tokens.
- 
Field Summary
Fields - 
Constructor Summary
ConstructorsConstructorDescriptionConstructor used for reflection only.SaslMessageToken(byte[] token) Constructor used to send request. - 
Method Summary
Modifier and TypeMethodDescriptionintbyte[]Read accessor for SASL token.static SaslMessageTokenread(byte[] serial) voidsetSaslToken(byte[] token) Write accessor for SASL token.voidwrite(org.apache.storm.shade.io.netty.buffer.ByteBuf dest) encode the current SaslToken Message into a ByteBuf. 
- 
Field Details
- 
IDENTIFIER
public static final short IDENTIFIER- See Also:
 
 
 - 
 - 
Constructor Details
- 
SaslMessageToken
public SaslMessageToken()Constructor used for reflection only. - 
SaslMessageToken
public SaslMessageToken(byte[] token) Constructor used to send request.- Parameters:
 token- the SASL token, generated by a SaslClient or SaslServer.
 
 - 
 - 
Method Details
- 
read
 - 
getSaslToken
public byte[] getSaslToken()Read accessor for SASL token.- Returns:
 - saslToken SASL token
 
 - 
setSaslToken
public void setSaslToken(byte[] token) Write accessor for SASL token.- Parameters:
 token- SASL token
 - 
encodeLength
public int encodeLength()- Specified by:
 encodeLengthin interfaceINettySerializable
 - 
write
public void write(org.apache.storm.shade.io.netty.buffer.ByteBuf dest) encode the current SaslToken Message into a ByteBuf.SaslTokenMessageRequest is encoded as: identifier .... short(2) payload length .... int payload .... byte[]
- Specified by:
 writein interfaceINettySerializable- Parameters:
 dest- The ByteBuf to serialize to
 
 -