public class RiakEntityStoreMixin extends Object implements ServiceActivation, MapEntityStore, RiakAccessors
ServiceActivation.ServiceActivator
MapEntityStore.MapChange, MapEntityStore.MapChanger, MapEntityStore.MapChanges
Constructor and Description |
---|
RiakEntityStoreMixin() |
Modifier and Type | Method and Description |
---|---|
void |
activateService()
Called after ServiceComposite Activation.
|
void |
applyChanges(MapEntityStore.MapChanges changes) |
Stream<Reader> |
entityStates() |
Reader |
get(EntityReference entityReference) |
void |
passivateService()
Called before ServiceComposite Passivation.
|
com.basho.riak.client.api.RiakClient |
riakClient() |
com.basho.riak.client.core.query.Namespace |
riakNamespace() |
public 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 passivatepublic com.basho.riak.client.api.RiakClient riakClient()
riakClient
in interface RiakAccessors
public com.basho.riak.client.core.query.Namespace riakNamespace()
riakNamespace
in interface RiakAccessors
public Reader get(EntityReference entityReference)
get
in interface MapEntityStore
entityReference
- The reference to the entity that we want to get.public void applyChanges(MapEntityStore.MapChanges changes)
applyChanges
in interface MapEntityStore
public Stream<Reader> entityStates()
entityStates
in interface MapEntityStore