Class InfinispanSingleUseObjectProvider
- java.lang.Object
-
- org.keycloak.models.sessions.infinispan.InfinispanSingleUseObjectProvider
-
- All Implemented Interfaces:
SingleUseObjectProvider
,Provider
public class InfinispanSingleUseObjectProvider extends Object implements SingleUseObjectProvider
TODO: Check if Boolean can be used as single-use cache argument instead of SingleUseObjectValueEntity. With respect to other single-use cache usecases like "Revoke Refresh Token" . Also with respect to the usage of streams iterating over "actionTokens" cache (check there are no ClassCastExceptions when casting values directly to SingleUseObjectValueEntity)- Author:
- Marek Posolda
-
-
Field Summary
Fields Modifier and Type Field Description static org.jboss.logging.Logger
logger
-
Fields inherited from interface org.keycloak.models.SingleUseObjectProvider
REVOKED_KEY
-
-
Constructor Summary
Constructors Constructor Description InfinispanSingleUseObjectProvider(KeycloakSession session, Supplier<org.infinispan.commons.api.BasicCache<String,SingleUseObjectValueEntity>> singleUseObjectCache)
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description void
close()
boolean
contains(String key)
Checks if there is a record in the store for the given key.Map<String,String>
get(String key)
Gets data associated with the given key.void
put(String key, long lifespanSeconds, Map<String,String> notes)
Stores the given data and guarantees that data should be available in the store for at least the time specified by {@param lifespanSeconds} parameterboolean
putIfAbsent(String key, long lifespanInSeconds)
Will try to put the key into the cache.Map<String,String>
remove(String key)
This method returns data just if removal was successful.boolean
replace(String key, Map<String,String> notes)
Replaces data associated with the given key in the store if the store contains the key.
-
-
-
Constructor Detail
-
InfinispanSingleUseObjectProvider
public InfinispanSingleUseObjectProvider(KeycloakSession session, Supplier<org.infinispan.commons.api.BasicCache<String,SingleUseObjectValueEntity>> singleUseObjectCache)
-
-
Method Detail
-
put
public void put(String key, long lifespanSeconds, Map<String,String> notes)
Description copied from interface:SingleUseObjectProvider
Stores the given data and guarantees that data should be available in the store for at least the time specified by {@param lifespanSeconds} parameter- Specified by:
put
in interfaceSingleUseObjectProvider
-
get
public Map<String,String> get(String key)
Description copied from interface:SingleUseObjectProvider
Gets data associated with the given key.- Specified by:
get
in interfaceSingleUseObjectProvider
- Parameters:
key
- String- Returns:
- Map
Data associated with the given key or null
if there is no associated data.
-
remove
public Map<String,String> remove(String key)
Description copied from interface:SingleUseObjectProvider
This method returns data just if removal was successful. Implementation should guarantee that "remove" is single-use. So if 2 threads (even on different cluster nodes or on different cross-dc nodes) calls "remove(123)" concurrently, then just one of them is allowed to succeed and return data back. It can't happen that both will succeed.- Specified by:
remove
in interfaceSingleUseObjectProvider
- Returns:
- context data associated to the key. It returns
null
if there are no context data available.
-
replace
public boolean replace(String key, Map<String,String> notes)
Description copied from interface:SingleUseObjectProvider
Replaces data associated with the given key in the store if the store contains the key.- Specified by:
replace
in interfaceSingleUseObjectProvider
- Parameters:
key
- Stringnotes
- MapNew data to be stored - Returns:
true
if the store contains the key and data was replaced, otherwisefalse
.
-
putIfAbsent
public boolean putIfAbsent(String key, long lifespanInSeconds)
Description copied from interface:SingleUseObjectProvider
Will try to put the key into the cache. It will succeed just if key is not already there.- Specified by:
putIfAbsent
in interfaceSingleUseObjectProvider
lifespanInSeconds
- Minimum lifespan for which successfully added key will be kept in the cache.- Returns:
- true if the key was successfully put into the cache. This means that same key wasn't in the cache before
-
contains
public boolean contains(String key)
Description copied from interface:SingleUseObjectProvider
Checks if there is a record in the store for the given key.- Specified by:
contains
in interfaceSingleUseObjectProvider
- Parameters:
key
- String- Returns:
true
if the record is present in the store,false
otherwise.
-
-