Field Detail

• LOGGER

  protected static final org.slf4j.Logger LOGGER

• DEFAULT_MAX_CONNECTIONS

  protected static final int DEFAULT_MAX_CONNECTIONS

  See Also:

  Constant Field Values

• riakClient

  protected com.basho.riak.client.IRiakClient riakClient

• bucketKey

  protected String bucketKey

Constructor Detail

• RiakHttpMapEntityStoreMixin

  public RiakHttpMapEntityStoreMixin()

Method Detail

• activateService

  public void activateService()
                       throws Exception

  Description copied from interface: ServiceActivation
  Called after ServiceComposite Activation.

  Throws:

  Exception

• passivateService

  public void passivateService()
                        throws Exception

  Description copied from interface: ServiceActivation
  Called before ServiceComposite Passivation.

  Specified by:

  passivateService in interface ServiceActivation

  Throws:

  Exception

• riakClient

  public com.basho.riak.client.IRiakClient riakClient()

  Specified by:

  riakClient in interface RiakAccessors

• bucket

  public String bucket()

  Specified by:

  bucket in interface RiakAccessors

• get

  public Reader get(EntityReference entityReference)
             throws EntityStoreException

  Specified by:

  get in interface MapEntityStore

  Parameters:

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

  Returns:

  Entity state Reader

  Throws:

  EntityStoreException

• applyChanges

  public void applyChanges(MapEntityStore.MapChanges changes)
                    throws IOException

  Specified by:

  applyChanges in interface MapEntityStore

  Throws:

  IOException

• entityStates

  public Input<Reader,IOException> entityStates()

  Specified by:

  entityStates in interface MapEntityStore

  Returns:

  All entities state Readers