public class CassandraEntityStoreMixin extends Object implements EntityStore, EntityStoreSPI, ServiceActivation
ServiceActivation.ServiceActivator
Constructor and Description |
---|
CassandraEntityStoreMixin() |
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) |
public EntityState newEntityState(EntityStoreUnitOfWork unitOfWork, EntityReference reference, EntityDescriptor entityDescriptor)
newEntityState
in interface EntityStoreSPI
public EntityState entityStateOf(EntityStoreUnitOfWork unitOfWork, ModuleDescriptor module, EntityReference reference)
entityStateOf
in interface EntityStoreSPI
public String versionOf(EntityStoreUnitOfWork unitOfWork, EntityReference reference)
versionOf
in interface EntityStoreSPI
public StateCommitter applyChanges(EntityStoreUnitOfWork unitOfWork, Iterable<EntityState> state)
applyChanges
in interface EntityStoreSPI
public EntityStoreUnitOfWork newUnitOfWork(ModuleDescriptor module, Usecase usecase, Instant currentTime)
newUnitOfWork
in interface EntityStore
public Stream<EntityState> entityStates(ModuleDescriptor module)
EntityStore
entityStates
in interface EntityStore
module
- Modulepublic void activateService() throws Exception
ServiceActivation
activateService
in interface ServiceActivation
Exception
- if unable to activatepublic void passivateService() throws Exception
ServiceActivation
passivateService
in interface ServiceActivation
Exception
- if unable to passivate