org.apache.polygene.entitystore.preferences

Class PreferencesEntityStoreMixin

java.lang.Object

org.apache.polygene.entitystore.preferences.PreferencesEntityStoreMixin

All Implemented Interfaces:

ServiceActivation, EntityStore, EntityStoreSPI

public class PreferencesEntityStoreMixin
extends Object
implements ServiceActivation, EntityStore, EntityStoreSPI

Implementation of EntityStore that is backed by the Preferences API.

@see Preferences

Associations are stored as the reference of the referenced Entity, ManyAssociations are stored as multi-line strings (one reference per line), and NamedAssociations are stored as multi-line strings (one name on a line, reference on the next line).

Nested ValuesComposites, Collections and Maps are stored using available StateSerialization service.

Nested Class Summary

Nested classes/interfaces inherited from interface org.apache.polygene.api.service.ServiceActivation

ServiceActivation.ServiceActivator

Field Summary

Fields

Modifier and Type	Field and Description
ScheduledThreadPoolExecutor	reloadExecutor

Constructor Summary

Constructors

Constructor and Description
PreferencesEntityStoreMixin()

Method Summary

Modifier and Type	Method and Description
void	activateService() Called after ServiceComposite Activation.
StateCommitter	applyChanges(EntityStoreUnitOfWork unitofwork, Iterable<EntityState> state)
EntityState	entityStateOf(EntityStoreUnitOfWork unitOfWork, ModuleDescriptor module, EntityReference reference)
Stream<EntityState>	entityStates(ModuleDescriptor module) Stream of all entity states, must be closed.
EntityState	newEntityState(EntityStoreUnitOfWork unitOfWork, EntityReference reference, EntityDescriptor entityDescriptor)
EntityStoreUnitOfWork	newUnitOfWork(ModuleDescriptor module, Usecase usecase, Instant currentTime)
protected Identity	newUnitOfWorkId()
void	passivateService() Called before ServiceComposite Passivation.
String	versionOf(EntityStoreUnitOfWork unitOfWork, EntityReference reference)
protected void	writeEntityState(DefaultEntityState state, Preferences entityPrefs, Identity identity, Instant lastModified)

Methods inherited from class java.lang.Object

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

Field Detail

reloadExecutor

public ScheduledThreadPoolExecutor reloadExecutor

Constructor Detail

PreferencesEntityStoreMixin

public PreferencesEntityStoreMixin()

Method Detail

activateService

public void activateService()
                     throws Exception

Description copied from interface: ServiceActivation

Called after ServiceComposite Activation.

Specified by:

activateService in interface ServiceActivation

Throws:

Exception - if unable to activate

passivateService

public void passivateService()
                      throws Exception

Description copied from interface: ServiceActivation

Called before ServiceComposite Passivation.

Specified by:

passivateService in interface ServiceActivation

Throws:

Exception - if unable to passivate

newUnitOfWork

public EntityStoreUnitOfWork newUnitOfWork(ModuleDescriptor module,
                                           Usecase usecase,
                                           Instant currentTime)

Specified by:

newUnitOfWork in interface EntityStore

entityStates

public Stream<EntityState> entityStates(ModuleDescriptor module)

Description copied from interface: EntityStore

Stream of all entity states, must be closed.

Specified by:

entityStates in interface EntityStore

Parameters:

module - Module

Returns:

Stream of all entity states, must be closed

newEntityState

public EntityState newEntityState(EntityStoreUnitOfWork unitOfWork,
                                  EntityReference reference,
                                  EntityDescriptor entityDescriptor)

Specified by:

newEntityState in interface EntityStoreSPI

entityStateOf

public EntityState entityStateOf(EntityStoreUnitOfWork unitOfWork,
                                 ModuleDescriptor module,
                                 EntityReference reference)

Specified by:

entityStateOf in interface EntityStoreSPI

versionOf

public String versionOf(EntityStoreUnitOfWork unitOfWork,
                        EntityReference reference)

Specified by:

versionOf in interface EntityStoreSPI

applyChanges

public StateCommitter applyChanges(EntityStoreUnitOfWork unitofwork,
                                   Iterable<EntityState> state)

Specified by:

applyChanges in interface EntityStoreSPI

writeEntityState

protected void writeEntityState(DefaultEntityState state,
                                Preferences entityPrefs,
                                Identity identity,
                                Instant lastModified)
                         throws EntityStoreException

Throws:

EntityStoreException

newUnitOfWorkId

protected Identity newUnitOfWorkId()