org.apache.polygene.entitystore.hazelcast

Class HazelcastEntityStoreMixin

java.lang.Object

org.apache.polygene.entitystore.hazelcast.HazelcastEntityStoreMixin

All Implemented Interfaces:

ServiceActivation, HazelcastAccessors, MapEntityStore

public class HazelcastEntityStoreMixin
extends Object
implements ServiceActivation, HazelcastAccessors, MapEntityStore

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

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 ref)
com.hazelcast.core.HazelcastInstance	hazelcastInstanceUsed()
com.hazelcast.core.IMap	hazelcastMapUsed()
void	passivateService() Called before ServiceComposite Passivation.

Methods inherited from class java.lang.Object

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

Constructor Detail

HazelcastEntityStoreMixin

public HazelcastEntityStoreMixin()

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

hazelcastInstanceUsed

public com.hazelcast.core.HazelcastInstance hazelcastInstanceUsed()

Specified by:

hazelcastInstanceUsed in interface HazelcastAccessors

hazelcastMapUsed

public com.hazelcast.core.IMap hazelcastMapUsed()

Specified by:

hazelcastMapUsed in interface HazelcastAccessors

get

public Reader get(EntityReference ref)
           throws EntityStoreException

Specified by:

get in interface MapEntityStore

Parameters:

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

Returns:

Entity state Reader

Throws:

EntityStoreException

applyChanges

public void applyChanges(MapEntityStore.MapChanges changes)
                  throws Exception

Specified by:

applyChanges in interface MapEntityStore

Throws:

Exception

entityStates

public Stream<Reader> entityStates()

Specified by:

entityStates in interface MapEntityStore

Returns:

All entities state Readers, must be closed