Package org.keycloak.models.sessions.infinispan.remote.transaction

Class RemoteChangeLogTransaction<K,V,T extends Updater<K,V>,R extends ConditionalRemover<K,V>>

java.lang.Object

org.keycloak.models.sessions.infinispan.remote.transaction.RemoteChangeLogTransaction<K,V,T,R>

Type Parameters:

K - The type of the Infinispan cache key.

V - The type of the Infinispan cache value.

T - The type of the Updater implementation.

All Implemented Interfaces:

NonBlockingTransaction

Direct Known Subclasses:

AuthenticationSessionChangeLogTransaction, ClientSessionChangeLogTransaction, LoginFailureChangeLogTransaction, UserSessionChangeLogTransaction

public class RemoteChangeLogTransaction<K,V,T extends Updater<K,V>,R extends ConditionalRemover<K,V>>
extends Object
implements NonBlockingTransaction

A KeycloakTransaction implementation that keeps track of changes made to entities stored in a Infinispan cache.

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static interface	RemoteChangeLogTransaction.SharedState<K,V>

Method Summary

Modifier and Type	Method	Description
void	asyncCommit(org.infinispan.commons.util.concurrent.AggregateCompletionStage<Void> stage, Consumer<DatabaseUpdate> databaseUpdates)	Asynchronously commits the transaction.
void	asyncRollback(org.infinispan.commons.util.concurrent.AggregateCompletionStage<Void> stage)	Asynchronously rollbacks the transaction.
T	create(K key, V entity)	Tracks a new value to be created in the Infinispan cache.
T	get(K key)	Fetches the value associated to the key.
CompletionStage<T>	getAsync(K key)	Nonblocking alternative of get(Object)
org.infinispan.client.hotrod.RemoteCache<K,V>	getCache()
protected Map<K,T>	getCachedEntities()
void	remove(K key)	Removes the key from the RemoteCache.
T	wrap(Map.Entry<K,org.infinispan.client.hotrod.MetadataValue<V>> entry)
T	wrap(K key, V value, long version)

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.keycloak.models.sessions.infinispan.transaction.NonBlockingTransaction

lockDatabaseEntities, supportsLockingDatabaseEntities

Method Details

asyncCommit

public void asyncCommit(org.infinispan.commons.util.concurrent.AggregateCompletionStage<Void> stage,
 Consumer<DatabaseUpdate> databaseUpdates)

Description copied from interface: NonBlockingTransaction

Asynchronously commits the transaction.

The implementation should not block the thread and add any (or none) CompletionStage into the stage.

Any blocking operation should be consumed by the databaseUpdates. It will be executed at a later instant.

Specified by:

asyncCommit in interface NonBlockingTransaction

Parameters:

stage - The AggregateCompletionStage to collect the CompletionStage.

databaseUpdates - The Consumer to use for blocking/database updates.

asyncRollback

public void asyncRollback(org.infinispan.commons.util.concurrent.AggregateCompletionStage<Void> stage)

Description copied from interface: NonBlockingTransaction

Asynchronously rollbacks the transaction.

The implementation should not block the thread and add any (or none) CompletionStage into the stage.

Specified by:

asyncRollback in interface NonBlockingTransaction

Parameters:

stage - The AggregateCompletionStage to collect the CompletionStage.

getCache

public org.infinispan.client.hotrod.RemoteCache<K,V> getCache()

Returns:

The RemoteCache tracked by the transaction.

get

public T get(K key)

Fetches the value associated to the key.

It fetches the value from the RemoteCache if a copy does not exist in the transaction.

Parameters:

key - The Infinispan cache key to fetch.

Returns:

The Updater to track further changes of the Infinispan cache value.

getAsync

public CompletionStage<T> getAsync(K key)

Nonblocking alternative of get(Object)

Parameters:

key - The Infinispan cache key to fetch.

Returns:

The Updater to track further changes of the Infinispan cache value.

create

public T create(K key,
 V entity)

Tracks a new value to be created in the Infinispan cache.

Parameters:

key - The Infinispan cache key to be associated to the value.

entity - The Infinispan cache value.

Returns:

The Updater to track further changes of the Infinispan cache value.

remove

public void remove(K key)

Removes the key from the RemoteCache.

Parameters:

key - The Infinispan cache key to remove.

wrap

public T wrap(Map.Entry<K,org.infinispan.client.hotrod.MetadataValue<V>> entry)

wrap

public T wrap(K key,
 V value,
 long version)

getCachedEntities

protected Map<K,T> getCachedEntities()