Package com.here.platform.data.client.service.stream.kafka.sasl

Class JWTSaslClient

java.lang.Object

com.here.platform.data.client.service.stream.kafka.sasl.JWTSaslClient

All Implemented Interfaces:

SaslClient

public class JWTSaslClient
extends Object
implements SaslClient

An instance of this class is created by JAAS via reflexion

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static class	JWTSaslClient.JWTClientSaslFactory

Field Summary

Fields

Modifier and Type	Field	Description
static final String	JWT_TOKEN_SYSTEM_PROPERTY
static final String	SASL_MECHANISM_JWT

Constructor Summary

Constructors

Constructor	Description
JWTSaslClient(String token)

Method Summary

Modifier and Type	Method	Description
void	dispose()
byte[]	evaluateChallenge(byte[] challenge)
String	getMechanismName()
Object	getNegotiatedProperty(String propName)
boolean	hasInitialResponse()
boolean	isComplete()
void	setComplete(boolean complete)
byte[]	unwrap(byte[] incoming, int offset, int len)
byte[]	wrap(byte[] outgoing, int offset, int len)

Methods inherited from class java.lang.Object

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

Field Details

JWT_TOKEN_SYSTEM_PROPERTY

public static final String JWT_TOKEN_SYSTEM_PROPERTY

See Also:

• Constant Field Values

SASL_MECHANISM_JWT

public static final String SASL_MECHANISM_JWT

See Also:

• Constant Field Values

Constructor Details

JWTSaslClient

public JWTSaslClient(String token)

Method Details

getMechanismName

public String getMechanismName()

Specified by:

getMechanismName in interface SaslClient

hasInitialResponse

public boolean hasInitialResponse()

Specified by:

hasInitialResponse in interface SaslClient

evaluateChallenge

public byte[] evaluateChallenge(byte[] challenge)
                         throws SaslException

Specified by:

evaluateChallenge in interface SaslClient

Throws:

SaslException

isComplete

public boolean isComplete()

Specified by:

isComplete in interface SaslClient

setComplete

public void setComplete(boolean complete)

unwrap

public byte[] unwrap(byte[] incoming,
 int offset,
 int len)
              throws SaslException

Specified by:

unwrap in interface SaslClient

Throws:

SaslException

wrap

public byte[] wrap(byte[] outgoing,
 int offset,
 int len)
            throws SaslException

Specified by:

wrap in interface SaslClient

Throws:

SaslException

getNegotiatedProperty

public Object getNegotiatedProperty(String propName)

Specified by:

getNegotiatedProperty in interface SaslClient

dispose

public void dispose()
             throws SaslException

Specified by:

dispose in interface SaslClient

Throws:

SaslException