org.apache.polygene.entitystore.cassandra

Class CassandraEntityStoreMixin

java.lang.Object

org.apache.polygene.entitystore.cassandra.CassandraEntityStoreMixin

All Implemented Interfaces:

ServiceActivation, EntityStore, EntityStoreSPI

public class CassandraEntityStoreMixin
extends Object
implements EntityStore, EntityStoreSPI, ServiceActivation

MongoDB implementation of MapEntityStore.

Nested Class Summary

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

ServiceActivation.ServiceActivator

Constructor Summary

Constructors

Constructor and Description
CassandraEntityStoreMixin()

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)
void	passivateService() Called before ServiceComposite Passivation.
String	versionOf(EntityStoreUnitOfWork unitOfWork, EntityReference reference)

Methods inherited from class java.lang.Object

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

Constructor Detail

CassandraEntityStoreMixin

public CassandraEntityStoreMixin()

Method Detail

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

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

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