Package org.keycloak.models.map.storage.hotRod

Class SingleUseObjectHotRodMapStorage

java.lang.Object

org.keycloak.models.map.storage.hotRod.HotRodMapStorage<String,HotRodSingleUseObjectEntity,HotRodSingleUseObjectEntityDelegate,SingleUseObjectValueModel>

org.keycloak.models.map.storage.hotRod.SingleUseObjectHotRodMapStorage

All Implemented Interfaces:

ConcurrentHashMapCrudOperations<HotRodSingleUseObjectEntityDelegate,SingleUseObjectValueModel>, MapStorage<HotRodSingleUseObjectEntityDelegate,SingleUseObjectValueModel>

public class SingleUseObjectHotRodMapStorage
extends HotRodMapStorage<String,HotRodSingleUseObjectEntity,HotRodSingleUseObjectEntityDelegate,SingleUseObjectValueModel>

Author:

Martin Kanis

Field Summary

Fields inherited from class org.keycloak.models.map.storage.hotRod.HotRodMapStorage

isExpirableEntity

Constructor Summary

Constructors

Constructor	Description
SingleUseObjectHotRodMapStorage(org.infinispan.client.hotrod.RemoteCache<String,HotRodSingleUseObjectEntity> remoteCache, StringKeyConverter<String> keyConverter, HotRodEntityDescriptor<HotRodSingleUseObjectEntity,HotRodSingleUseObjectEntityDelegate> storedEntityDescriptor, DeepCloner cloner, AllAreasHotRodTransactionsWrapper txWrapper)

Method Summary

Modifier and Type	Method	Description
HotRodSingleUseObjectEntityDelegate	create(HotRodSingleUseObjectEntityDelegate value)	Creates an object in the store.
protected MapKeycloakTransaction<HotRodSingleUseObjectEntityDelegate,SingleUseObjectValueModel>	createTransactionInternal(KeycloakSession session)
Stream<HotRodSingleUseObjectEntityDelegate>	read(QueryParameters<SingleUseObjectValueModel> queryParameters)	Returns stream of objects satisfying given criteria from the storage.

Methods inherited from class org.keycloak.models.map.storage.hotRod.HotRodMapStorage

createCriteriaBuilder, createTransaction, delete, delete, exists, getCount, read, update

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.map.storage.chm.ConcurrentHashMapCrudOperations

determineKeyFromValue, exists

Constructor Detail

SingleUseObjectHotRodMapStorage

public SingleUseObjectHotRodMapStorage(org.infinispan.client.hotrod.RemoteCache<String,HotRodSingleUseObjectEntity> remoteCache,
                                       StringKeyConverter<String> keyConverter,
                                       HotRodEntityDescriptor<HotRodSingleUseObjectEntity,HotRodSingleUseObjectEntityDelegate> storedEntityDescriptor,
                                       DeepCloner cloner,
                                       AllAreasHotRodTransactionsWrapper txWrapper)

Method Detail

createTransactionInternal

protected MapKeycloakTransaction<HotRodSingleUseObjectEntityDelegate,SingleUseObjectValueModel> createTransactionInternal(KeycloakSession session)

Overrides:

createTransactionInternal in class HotRodMapStorage<String,HotRodSingleUseObjectEntity,HotRodSingleUseObjectEntityDelegate,SingleUseObjectValueModel>

create

public HotRodSingleUseObjectEntityDelegate create(HotRodSingleUseObjectEntityDelegate value)

Description copied from interface: ConcurrentHashMapCrudOperations

Creates an object in the store. ID of the value may be prescribed in id of the value. If the id is null or its format is not matching the store internal format for ID, then the value's ID will be generated and returned in the id of the return value.

Specified by:

create in interface ConcurrentHashMapCrudOperations<HotRodSingleUseObjectEntityDelegate,SingleUseObjectValueModel>

Overrides:

create in class HotRodMapStorage<String,HotRodSingleUseObjectEntity,HotRodSingleUseObjectEntityDelegate,SingleUseObjectValueModel>

Parameters:

value - Entity to create in the store

Returns:

Entity representing the value in the store. It may or may not be the same instance as value

See Also:

AbstractEntity.getId()

read

public Stream<HotRodSingleUseObjectEntityDelegate> read(QueryParameters<SingleUseObjectValueModel> queryParameters)

Description copied from interface: ConcurrentHashMapCrudOperations

Returns stream of objects satisfying given criteria from the storage. The criteria are specified in the given criteria builder based on model properties. If V implements ExpirableEntity this method should not return entities that are expired. See ExpirableEntity JavaDoc for more details.

Specified by:

read in interface ConcurrentHashMapCrudOperations<HotRodSingleUseObjectEntityDelegate,SingleUseObjectValueModel>

Overrides:

read in class HotRodMapStorage<String,HotRodSingleUseObjectEntity,HotRodSingleUseObjectEntityDelegate,SingleUseObjectValueModel>

Parameters:

queryParameters - parameters for the query like firstResult, maxResult, requested ordering, etc.

Returns:

Stream of objects. Never returns null.