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 and Description
static short	IDENTIFIER

Constructor Summary

Constructors

Constructor and Description
SaslMessageToken() Constructor used for reflection only.
SaslMessageToken(byte[] token) Constructor used to send request.

Method Summary

Modifier and Type	Method and Description
org.jboss.netty.buffer.ChannelBuffer	buffer() encode the current SaslToken Message into a channel buffer SaslTokenMessageRequest is encoded as: identifier ….
int	encodeLength()
byte[]	getSaslToken() Read accessor for SASL token
static SaslMessageToken	read(byte[] serial)
void	setSaslToken(byte[] token) Write accessor for SASL token

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Detail

IDENTIFIER

public static final short IDENTIFIER

See Also:

Constant Field Values

Constructor Detail

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 Detail

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:

encodeLength in interface INettySerializable

buffer

public org.jboss.netty.buffer.ChannelBuffer buffer()
                                            throws IOException

encode the current SaslToken Message into a channel buffer SaslTokenMessageRequest is encoded as: identifier …. short(2) payload length …. int payload …. byte[]

Specified by:

buffer in interface INettySerializable

Throws:

IOException

read

public static SaslMessageToken read(byte[] serial)