org.qi4j.entitystore.redis
Class RedisMapEntityStoreMixin

java.lang.Object
  extended by org.qi4j.entitystore.redis.RedisMapEntityStoreMixin
All Implemented Interfaces:
ServiceActivation, RedisAccessors, MapEntityStore

public class RedisMapEntityStoreMixin
extends java.lang.Object
implements ServiceActivation, RedisAccessors, MapEntityStore

Redis implementation of MapEntityStore.


Nested Class Summary
 
Nested classes/interfaces inherited from interface org.qi4j.api.service.ServiceActivation
ServiceActivation.ServiceActivator
 
Nested classes/interfaces inherited from interface org.qi4j.spi.entitystore.helpers.MapEntityStore
MapEntityStore.JSONKeys, MapEntityStore.MapChanger, MapEntityStore.MapChanges
 
Constructor Summary
RedisMapEntityStoreMixin()
           
 
Method Summary
 void activateService()
          Called after ServiceComposite Activation.
 void applyChanges(MapEntityStore.MapChanges changes)
           
 Input<java.io.Reader,java.io.IOException> entityStates()
           
 java.io.Reader get(EntityReference entityReference)
           
 redis.clients.jedis.JedisPool jedisPool()
           
 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

RedisMapEntityStoreMixin

public RedisMapEntityStoreMixin()
Method Detail

activateService

public void activateService()
                     throws java.lang.Exception
Description copied from interface: ServiceActivation
Called after ServiceComposite Activation.

Specified by:
activateService in interface ServiceActivation
Throws:
java.lang.Exception

passivateService

public void passivateService()
                      throws java.lang.Exception
Description copied from interface: ServiceActivation
Called before ServiceComposite Passivation.

Specified by:
passivateService in interface ServiceActivation
Throws:
java.lang.Exception

jedisPool

public redis.clients.jedis.JedisPool jedisPool()
Specified by:
jedisPool in interface RedisAccessors

get

public java.io.Reader get(EntityReference entityReference)
                   throws EntityStoreException
Specified by:
get in interface MapEntityStore
Returns:
Entity state Reader
Throws:
EntityStoreException

applyChanges

public void applyChanges(MapEntityStore.MapChanges changes)
                  throws java.io.IOException
Specified by:
applyChanges in interface MapEntityStore
Throws:
java.io.IOException

entityStates

public Input<java.io.Reader,java.io.IOException> entityStates()
Specified by:
entityStates in interface MapEntityStore
Returns:
All entities state Readers