Package org.keycloak.models.sessions.infinispan

Class InfinispanKeycloakTransaction

java.lang.Object

org.keycloak.models.sessions.infinispan.InfinispanKeycloakTransaction

All Implemented Interfaces:

NonBlockingTransaction

public class InfinispanKeycloakTransaction
extends Object
implements NonBlockingTransaction

Author:

Stian Thorgersen

Constructor Summary

Constructors

Constructor	Description
InfinispanKeycloakTransaction()

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.
<K, V> V	get(org.infinispan.commons.api.BasicCache<K,V> cache, K key)
<K, V> void	put(org.infinispan.commons.api.BasicCache<K,V> cache, K key, V value, long lifespan, TimeUnit lifespanUnit)
<K, V> void	remove(org.infinispan.commons.api.BasicCache<K,V> cache, K key)
<K, V> void	replace(org.infinispan.Cache<K,V> cache, K key, V value, long lifespan, TimeUnit lifespanUnit)

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

Constructor Details

InfinispanKeycloakTransaction

public InfinispanKeycloakTransaction()

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.

put

public <K,
V> void put(org.infinispan.commons.api.BasicCache<K,V> cache,
 K key,
 V value,
 long lifespan,
 TimeUnit lifespanUnit)

replace

public <K,
V> void replace(org.infinispan.Cache<K,V> cache,
 K key,
 V value,
 long lifespan,
 TimeUnit lifespanUnit)

remove

public <K,
V> void remove(org.infinispan.commons.api.BasicCache<K,V> cache,
 K key)

get

public <K,
V> V get(org.infinispan.commons.api.BasicCache<K,V> cache,
 K key)