Package com.rabbitmq.client.impl

Class DefaultCredentialsRefreshService.CredentialsProviderState

java.lang.Object

com.rabbitmq.client.impl.DefaultCredentialsRefreshService.CredentialsProviderState

Enclosing class:

DefaultCredentialsRefreshService

static class DefaultCredentialsRefreshService.CredentialsProviderState
extends Object

State and refresh behavior for a CredentialsProvider and its registered entities.

Field Summary

Fields

Modifier and Type	Field	Description
private final CredentialsProvider	credentialsProvider
private final AtomicReference<ScheduledFuture<?>>	refreshTask
private final AtomicBoolean	refreshTaskSet
private final Map<String,DefaultCredentialsRefreshService.Registration>	registrations

Constructor Summary

Constructors

Constructor	Description
CredentialsProviderState(CredentialsProvider credentialsProvider)

Method Summary

Modifier and Type	Method	Description
(package private) void	add(DefaultCredentialsRefreshService.Registration registration)
(package private) void	maybeSetRefreshTask(Supplier<ScheduledFuture<?>> scheduledFutureSupplier)
(package private) void	refresh()
(package private) void	unregister(String registrationId)

Methods inherited from class java.lang.Object

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

Field Details

credentialsProvider

private final CredentialsProvider credentialsProvider

registrations

private final Map<String,DefaultCredentialsRefreshService.Registration> registrations

refreshTask

private final AtomicReference<ScheduledFuture<?>> refreshTask

refreshTaskSet

private final AtomicBoolean refreshTaskSet

Constructor Details

CredentialsProviderState

CredentialsProviderState(CredentialsProvider credentialsProvider)

Method Details

add

void add(DefaultCredentialsRefreshService.Registration registration)

maybeSetRefreshTask

void maybeSetRefreshTask(Supplier<ScheduledFuture<?>> scheduledFutureSupplier)

refresh

void refresh()

unregister

void unregister(String registrationId)