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 aCredentialsProvider
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
All Methods Instance Methods Concrete Methods 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)
-
-
-
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)
-
-