public class MongoMapEntityStoreMixin extends Object implements ServiceActivation, MapEntityStore, MongoAccessors
ServiceActivation.ServiceActivator
MapEntityStore.MapChanger, MapEntityStore.MapChanges
Modifier and Type | Field and Description |
---|---|
static String |
IDENTITY_COLUMN |
static String |
STATE_COLUMN |
Constructor and Description |
---|
MongoMapEntityStoreMixin() |
Modifier and Type | Method and Description |
---|---|
void |
activateService()
Called after ServiceComposite Activation.
|
void |
applyChanges(MapEntityStore.MapChanges changes) |
String |
collectionUsed() |
com.mongodb.DB |
dbInstanceUsed() |
Input<Reader,IOException> |
entityStates() |
Reader |
get(EntityReference entityReference) |
com.mongodb.MongoClient |
mongoInstanceUsed() |
void |
passivateService()
Called before ServiceComposite Passivation.
|
public static final String IDENTITY_COLUMN
public static final String STATE_COLUMN
public void activateService() throws Exception
ServiceActivation
activateService
in interface ServiceActivation
Exception
public void passivateService() throws Exception
ServiceActivation
passivateService
in interface ServiceActivation
Exception
public com.mongodb.MongoClient mongoInstanceUsed()
mongoInstanceUsed
in interface MongoAccessors
public com.mongodb.DB dbInstanceUsed()
dbInstanceUsed
in interface MongoAccessors
public String collectionUsed()
collectionUsed
in interface MongoAccessors
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