Package com.rabbitmq.stream.oauth2

Class TokenCredentialsManager

java.lang.Object

com.rabbitmq.stream.oauth2.TokenCredentialsManager

All Implemented Interfaces:

CredentialsManager

public final class TokenCredentialsManager
extends Object
implements CredentialsManager

Credentials manager implementation that requests and refreshes tokens.

It also keeps track of registration and update them with refreshed tokens when appropriate.

Nested Class Summary

Nested classes/interfaces inherited from interface com.rabbitmq.stream.oauth2.CredentialsManager

CredentialsManager.AuthenticationCallback, CredentialsManager.NoOpCredentialsManager, CredentialsManager.NoOpRegistration, CredentialsManager.Registration

Field Summary

Fields

Modifier and Type	Field	Description
static final Function<Instant,Duration>	DEFAULT_REFRESH_DELAY_STRATEGY

Fields inherited from interface com.rabbitmq.stream.oauth2.CredentialsManager

NO_OP

Constructor Summary

Constructors

Constructor	Description
TokenCredentialsManager(TokenRequester requester, ScheduledExecutorService scheduledExecutorService, Function<Instant,Duration> refreshDelayStrategy)

Method Summary

Modifier and Type	Method	Description
static Function<Instant,Duration>	ratioRefreshDelayStrategy(float ratio)
CredentialsManager.Registration	register(String name, CredentialsManager.AuthenticationCallback updateCallback)	Register a component for authentication.

Methods inherited from class java.lang.Object

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

Field Details

DEFAULT_REFRESH_DELAY_STRATEGY

public static final Function<Instant,Duration> DEFAULT_REFRESH_DELAY_STRATEGY

Constructor Details

TokenCredentialsManager

public TokenCredentialsManager(TokenRequester requester,
 ScheduledExecutorService scheduledExecutorService,
 Function<Instant,Duration> refreshDelayStrategy)

Method Details

register

public CredentialsManager.Registration register(String name,
 CredentialsManager.AuthenticationCallback updateCallback)

Description copied from interface: CredentialsManager

Register a component for authentication.

Specified by:

register in interface CredentialsManager

Parameters:

name - component name (must be unique)

updateCallback - callback to update the component authentication

Returns:

the registration (must be closed when no longer necessary)

ratioRefreshDelayStrategy

public static Function<Instant,Duration> ratioRefreshDelayStrategy(float ratio)