org.apache.polygene.spi.entitystore.helpers

Class JSONMapEntityStoreMixin

java.lang.Object

org.apache.polygene.spi.entitystore.helpers.JSONMapEntityStoreMixin

All Implemented Interfaces:

EntityStore, EntityStoreSPI, JSONMapEntityStoreActivation, StateStore

public class JSONMapEntityStoreMixin
extends Object
implements EntityStore, EntityStoreSPI, StateStore, JSONMapEntityStoreActivation

Implementation of EntityStore that works with an implementation of MapEntityStore.

Implement MapEntityStore and add as mixin to the service using this mixin.

See MemoryMapEntityStoreMixin for reference.

EntityStores based on this mixin gets support for the Migration and Cache extensions.

MapEntityStore implementations will get their values as JSON.

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	JSONMapEntityStoreMixin.CacheState

Nested classes/interfaces inherited from interface org.apache.polygene.spi.entitystore.helpers.JSONMapEntityStoreActivation

JSONMapEntityStoreActivation.Activator

Field Summary

Fields

Modifier and Type	Field and Description
protected String	uuid

Constructor Summary

Constructors

Constructor and Description
JSONMapEntityStoreMixin()

Method Summary

Modifier and Type	Method and Description
StateCommitter	applyChanges(EntityStoreUnitOfWork uow, Iterable<EntityState> entityStates)
EntityState	entityStateOf(EntityStoreUnitOfWork uow, ModuleDescriptor module, EntityReference reference)
Stream<EntityState>	entityStates(ModuleDescriptor module) Stream of all entity states, must be closed.
javax.json.JsonObject	jsonStateOf(String id)
EntityState	newEntityState(EntityStoreUnitOfWork uow, EntityReference reference, EntityDescriptor entityDescriptor)
EntityStoreUnitOfWork	newUnitOfWork(ModuleDescriptor module, Usecase usecase, Instant currentTime)
protected Identity	newUnitOfWorkId()
protected JSONEntityState	readEntityState(ModuleDescriptor module, Reader entityState)
void	setUpJSONMapES()
void	tearDownJSONMapES()
String	versionOf(EntityStoreUnitOfWork uow, EntityReference reference)
protected void	writeEntityState(JSONEntityState state, Writer writer, String version, Instant lastModified)

Methods inherited from class java.lang.Object

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

Field Detail

uuid

protected String uuid

Constructor Detail

JSONMapEntityStoreMixin

public JSONMapEntityStoreMixin()

Method Detail

setUpJSONMapES

public void setUpJSONMapES()
                    throws Exception

Specified by:

setUpJSONMapES in interface JSONMapEntityStoreActivation

Throws:

Exception

tearDownJSONMapES

public void tearDownJSONMapES()
                       throws Exception

Specified by:

tearDownJSONMapES in interface JSONMapEntityStoreActivation

Throws:

Exception

newUnitOfWork

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

Specified by:

newUnitOfWork in interface EntityStore

newEntityState

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

Specified by:

newEntityState in interface EntityStoreSPI

entityStateOf

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

Specified by:

entityStateOf in interface EntityStoreSPI

versionOf

public String versionOf(EntityStoreUnitOfWork uow,
                        EntityReference reference)

Specified by:

versionOf in interface EntityStoreSPI

applyChanges

public StateCommitter applyChanges(EntityStoreUnitOfWork uow,
                                   Iterable<EntityState> entityStates)
                            throws EntityStoreException

Specified by:

applyChanges in interface EntityStoreSPI

Throws:

EntityStoreException

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

newUnitOfWorkId

protected Identity newUnitOfWorkId()

writeEntityState

protected void writeEntityState(JSONEntityState state,
                                Writer writer,
                                String version,
                                Instant lastModified)
                         throws EntityStoreException

Throws:

EntityStoreException

readEntityState

protected JSONEntityState readEntityState(ModuleDescriptor module,
                                          Reader entityState)
                                   throws EntityStoreException

Throws:

EntityStoreException

jsonStateOf

public javax.json.JsonObject jsonStateOf(String id)

Specified by:

jsonStateOf in interface StateStore