io.sarl.sre.janus.network.services
Class HazelcastSpaceRepository
All Superinterfaces:
SpaceListener, java.util.EventListener
class HazelcastSpaceRepository
extends LocalSpaceRepository
Implementation of a space repository that is connected to remote SRE with Hazelcast framework.
Maven Group Identifier:
io.sarl.sre.janus
Maven Artifact Identifier:
janus.network
Since:
0.12
Property Summary
Modifier and type Property and description
com.hazelcast.core.HazelcastInstance hazelcastInstance
Inherited: lock, sharedStructure, spaces
Field Summary
Modifier and type Field and description
public static val java.lang.String HAZELCAST_SPACE_ID_MAP_NAME
Inherited: logger
Constructor Summary
Action Summary
Modifier and type Action and description
protected java.util.logging.Logger createLogger(LoggingService)
protected S createSpaceFirstInstance(Class<T>,SpaceID,Object)
protected void destroyThreadUnsafe
protected S ensureLocalSpaceDefinition(SpaceID,Object)
Add the existing, but not yet known, spaces into this repository.
com.hazelcast.core.HazelcastInstance getHazelcastInstance
protected void removeLocalSpaceDefinition(SpaceID,boolean)
protected void removeLocalSpaceDefinitions
Remove all the local/remote spaces.
Property Details
hazelcastInstance
val hazelcastInstance : com.hazelcast.core.HazelcastInstance

This property is an alias for the action: getHazelcastInstance

Field Details
HAZELCAST_SPACE_ID_MAP_NAME
public static val HAZELCAST_SPACE_ID_MAP_NAME : java.lang.String = "io.sarl.network.distributedSpaceIDMapName"
Constructor Details
new(Injector,ExecutorService,LoggingService,SreConfig,SreSpaceSpecificationFactory,ContextService,Provider<T>,HazelcastInstance,[Map<K,V>],[IMap<K,V>])
new(Injector,ExecutorService,LoggingService,SreConfig,SreSpaceSpecificationFactory,ContextService,Provider<T>,HazelcastInstance,[Map<K,V>],[IMap<K,V>])
Action Details
createLogger(LoggingService)
protected def createLogger(LoggingService) : java.util.logging.Logger
createSpaceFirstInstance(Class<T>,SpaceID,Object)
protected def createSpaceFirstInstance(Class<T>,SpaceID,Object) : S

with S extends Space

destroyThreadUnsafe
protected def destroyThreadUnsafe
ensureLocalSpaceDefinition(SpaceID,Object)
protected def ensureLocalSpaceDefinition(SpaceID,Object) : S

with S extends Space

Add the existing, but not yet known, spaces into this repository.
Parameters:
id - identifier of the space
initializationParameters - parameters for initialization.
getHazelcastInstance
def getHazelcastInstance : com.hazelcast.core.HazelcastInstance
removeLocalSpaceDefinition(SpaceID,boolean)
protected def removeLocalSpaceDefinition(SpaceID,boolean)
removeLocalSpaceDefinitions
protected def removeLocalSpaceDefinitions
Remove all the local/remote spaces.