org.apache.polygene.entitystore.riak

Class RiakEntityStoreMixin

java.lang.Object

org.apache.polygene.entitystore.riak.RiakEntityStoreMixin

All Implemented Interfaces:

ServiceActivation, RiakAccessors, MapEntityStore

public class RiakEntityStoreMixin
extends Object
implements ServiceActivation, MapEntityStore, RiakAccessors

Riak Protobuf implementation of MapEntityStore.

Nested Class Summary

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

ServiceActivation.ServiceActivator

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

MapEntityStore.MapChange, MapEntityStore.MapChanger, MapEntityStore.MapChanges

Constructor Summary

Constructors

Constructor and Description
RiakEntityStoreMixin()

Method Summary

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()

Methods inherited from class java.lang.Object

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

Constructor Detail

RiakEntityStoreMixin

public RiakEntityStoreMixin()

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

riakClient

public com.basho.riak.client.api.RiakClient riakClient()

Specified by:

riakClient in interface RiakAccessors

riakNamespace

public com.basho.riak.client.core.query.Namespace riakNamespace()

Specified by:

riakNamespace in interface RiakAccessors

get

public Reader get(EntityReference entityReference)

Specified by:

get in interface MapEntityStore

Parameters:

entityReference - The reference to the entity that we want to get.

Returns:

Entity state Reader

applyChanges

public void applyChanges(MapEntityStore.MapChanges changes)

Specified by:

applyChanges in interface MapEntityStore

entityStates

public Stream<Reader> entityStates()

Specified by:

entityStates in interface MapEntityStore

Returns:

All entities state Readers, must be closed