org.apache.polygene.entitystore.mongodb

Class MongoDBEntityStoreMixin

java.lang.Object

org.apache.polygene.entitystore.mongodb.MongoDBEntityStoreMixin

All Implemented Interfaces:

ServiceActivation, MongoDBAccessors, MapEntityStore

public class MongoDBEntityStoreMixin
extends Object
implements ServiceActivation, MapEntityStore, MongoDBAccessors

MongoDB 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

Field Summary

Fields

Modifier and Type	Field and Description
static String	IDENTITY_COLUMN
static String	STATE_COLUMN

Constructor Summary

Constructors

Constructor and Description
MongoDBEntityStoreMixin()

Method Summary

Modifier and Type	Method and Description
void	activateService() Called after ServiceComposite Activation.
void	applyChanges(MapEntityStore.MapChanges changes)
String	collectionUsed()
com.mongodb.client.MongoDatabase	dbInstanceUsed()
Stream<Reader>	entityStates()
Reader	get(EntityReference entityReference)
com.mongodb.MongoClient	mongoInstanceUsed()
void	passivateService() Called before ServiceComposite Passivation.

Methods inherited from class java.lang.Object

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

Field Detail

IDENTITY_COLUMN

public static final String IDENTITY_COLUMN

See Also:

Constant Field Values

STATE_COLUMN

public static final String STATE_COLUMN

See Also:

Constant Field Values

Constructor Detail

MongoDBEntityStoreMixin

public MongoDBEntityStoreMixin()

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

mongoInstanceUsed

public com.mongodb.MongoClient mongoInstanceUsed()

Specified by:

mongoInstanceUsed in interface MongoDBAccessors

dbInstanceUsed

public com.mongodb.client.MongoDatabase dbInstanceUsed()

Specified by:

dbInstanceUsed in interface MongoDBAccessors

collectionUsed

public String collectionUsed()

Specified by:

collectionUsed in interface MongoDBAccessors

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 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