io.confluent.kafka.clients.plugins.auth.jwt

Class AsyncHttpsJwks

java.lang.Object

org.jose4j.jwk.HttpsJwks

io.confluent.kafka.clients.plugins.auth.jwt.AsyncHttpsJwks

All Implemented Interfaces:

Closeable, AutoCloseable

public final class AsyncHttpsJwks
extends org.jose4j.jwk.HttpsJwks
implements Closeable

Extends HttpsJwks with an asynchronous refresh implementation.

Field Summary

Fields

Modifier and Type	Field and Description
static long	DEFAULT_REFRESH_INTERVAL_MS

Constructor Summary

Constructors

Constructor and Description
AsyncHttpsJwks(org.jose4j.http.SimpleGet httpGet, String location, boolean unsafeAllowed, long refreshIntervalMs)
AsyncHttpsJwks(String location)
AsyncHttpsJwks(String location, boolean unsafeAllowed, long refreshIntervalMs)
AsyncHttpsJwks(URI location) Create a new HttpsJwks that can be used to retrieve JWKs from the given location asynchronously.

Method Summary

Modifier and Type	Method and Description
void	close()
List<org.jose4j.jwk.JsonWebKey>	getJsonWebKeys()
boolean	isRunning()
void	refresh()

Methods inherited from class org.jose4j.jwk.HttpsJwks

getLocation, setDefaultCacheDuration, setRefreshReprieveThreshold, setRetainCacheOnErrorDuration, setSimpleHttpGet

Methods inherited from class java.lang.Object

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

Field Detail

DEFAULT_REFRESH_INTERVAL_MS

public static final long DEFAULT_REFRESH_INTERVAL_MS

See Also:

Constant Field Values

Constructor Detail

AsyncHttpsJwks

public AsyncHttpsJwks(URI location)

Create a new HttpsJwks that can be used to retrieve JWKs from the given location asynchronously.

Parameters:

location - the HTTPS URI of the JSON Web Key Set

AsyncHttpsJwks

public AsyncHttpsJwks(String location)

AsyncHttpsJwks

public AsyncHttpsJwks(String location,
                      boolean unsafeAllowed,
                      long refreshIntervalMs)

AsyncHttpsJwks

public AsyncHttpsJwks(org.jose4j.http.SimpleGet httpGet,
                      String location,
                      boolean unsafeAllowed,
                      long refreshIntervalMs)

Method Detail

refresh

public void refresh()

Overrides:

refresh in class org.jose4j.jwk.HttpsJwks

getJsonWebKeys

public List<org.jose4j.jwk.JsonWebKey> getJsonWebKeys()

Overrides:

getJsonWebKeys in class org.jose4j.jwk.HttpsJwks

isRunning

public boolean isRunning()

close

public void close()

Specified by:

close in interface Closeable

Specified by:

close in interface AutoCloseable