public class RiakProtobufMapEntityStoreMixin extends Object
ServiceActivation.ServiceActivator
MapEntityStore.MapChanger, MapEntityStore.MapChanges
Modifier and Type | Field and Description |
---|---|
protected String |
bucketKey |
protected static int |
DEFAULT_MAX_CONNECTIONS |
protected static org.slf4j.Logger |
LOGGER |
protected com.basho.riak.client.IRiakClient |
riakClient |
Constructor and Description |
---|
RiakProtobufMapEntityStoreMixin() |
Modifier and Type | Method and Description |
---|---|
void |
activateService()
Called after ServiceComposite Activation.
|
void |
applyChanges(MapEntityStore.MapChanges changes) |
String |
bucket() |
Input<Reader,IOException> |
entityStates() |
Reader |
get(EntityReference entityReference) |
void |
passivateService()
Called before ServiceComposite Passivation.
|
com.basho.riak.client.IRiakClient |
riakClient() |
protected static final org.slf4j.Logger LOGGER
protected static final int DEFAULT_MAX_CONNECTIONS
protected com.basho.riak.client.IRiakClient riakClient
protected String bucketKey
public void activateService() throws Exception
ServiceActivation
Exception
public void passivateService() throws Exception
ServiceActivation
passivateService
in interface ServiceActivation
Exception
public com.basho.riak.client.IRiakClient riakClient()
riakClient
in interface RiakAccessors
public String bucket()
bucket
in interface RiakAccessors
public Reader get(EntityReference entityReference) throws EntityStoreException
get
in interface MapEntityStore
entityReference
- The reference to the entity that we want to get.EntityStoreException
public void applyChanges(MapEntityStore.MapChanges changes) throws IOException
applyChanges
in interface MapEntityStore
IOException
public Input<Reader,IOException> entityStates()
entityStates
in interface MapEntityStore