Package org.apache.storm.messaging.netty
Class SaslMessageToken
- java.lang.Object
-
- org.apache.storm.messaging.netty.SaslMessageToken
-
- All Implemented Interfaces:
INettySerializable
public class SaslMessageToken extends Object implements INettySerializable
Send and receive SASL tokens.
-
-
Field Summary
Fields Modifier and Type Field Description static shortIDENTIFIER
-
Constructor Summary
Constructors Constructor Description SaslMessageToken()Constructor used for reflection only.SaslMessageToken(byte[] token)Constructor used to send request.
-
Method Summary
All Methods Static Methods Instance Methods Concrete Methods Modifier and Type Method Description intencodeLength()byte[]getSaslToken()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 Detail
-
IDENTIFIER
public static final short IDENTIFIER
- See Also:
- Constant Field Values
-
-
Method Detail
-
read
public static SaslMessageToken read(byte[] serial)
-
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
-
-