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

Class SingleUseObjectTransaction

java.lang.Object

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

All Implemented Interfaces:

NonBlockingTransaction

public class SingleUseObjectTransaction
extends Object

Syntactic sugar for RemoteInfinispanKeycloakTransaction<String, SingleUseObjectValueEntity, ConditionalRemover<String, SingleUseObjectValueEntity>>

Constructor Summary

Constructors

Constructor	Description
SingleUseObjectTransaction(org.infinispan.client.hotrod.RemoteCache<String,SingleUseObjectValueEntity> cache)

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.
SingleUseObjectValueEntity	get(String key)
org.infinispan.client.hotrod.RemoteCache<String,SingleUseObjectValueEntity>	getCache()
void	put(String key, SingleUseObjectValueEntity value, long lifespan, TimeUnit timeUnit)
void	remove(String key)
void	replace(String key, SingleUseObjectValueEntity value, int lifespan, TimeUnit timeUnit)

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

SingleUseObjectTransaction

public SingleUseObjectTransaction(org.infinispan.client.hotrod.RemoteCache<String,SingleUseObjectValueEntity> cache)

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 void put(String key,
 SingleUseObjectValueEntity value,
 long lifespan,
 TimeUnit timeUnit)

replace

public void replace(String key,
 SingleUseObjectValueEntity value,
 int lifespan,
 TimeUnit timeUnit)

remove

public void remove(String key)

get

public SingleUseObjectValueEntity get(String key)

getCache

public org.infinispan.client.hotrod.RemoteCache<String,SingleUseObjectValueEntity> getCache()