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 java.lang.Object

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

Field Summary

Fields

Modifier and Type	Field	Description
private CredentialsProvider	credentialsProvider
private java.util.concurrent.atomic.AtomicReference<java.util.concurrent.ScheduledFuture<?>>	refreshTask
private java.util.concurrent.atomic.AtomicBoolean	refreshTaskSet
private java.util.Map<java.lang.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(java.util.function.Supplier<java.util.concurrent.ScheduledFuture<?>> scheduledFutureSupplier)
(package private) void	refresh()
(package private) void	unregister(java.lang.String registrationId)

Methods inherited from class java.lang.Object

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

Field Detail

credentialsProvider

private final CredentialsProvider credentialsProvider

registrations

private final java.util.Map<java.lang.String,DefaultCredentialsRefreshService.Registration> registrations

refreshTask

private final java.util.concurrent.atomic.AtomicReference<java.util.concurrent.ScheduledFuture<?>> refreshTask

refreshTaskSet

private final java.util.concurrent.atomic.AtomicBoolean refreshTaskSet

Constructor Detail

CredentialsProviderState

CredentialsProviderState(CredentialsProvider credentialsProvider)

Method Detail

add

void add(DefaultCredentialsRefreshService.Registration registration)

maybeSetRefreshTask

void maybeSetRefreshTask(java.util.function.Supplier<java.util.concurrent.ScheduledFuture<?>> scheduledFutureSupplier)

refresh

void refresh()

unregister

void unregister(java.lang.String registrationId)