OHazelcastPlugin (OrientDB 2.2.1-SNAPSHOT API)

java.lang.Object
- com.orientechnologies.orient.server.plugin.OServerPluginAbstract
- - com.orientechnologies.orient.server.distributed.impl.ODistributedAbstractPlugin
  - - com.orientechnologies.orient.server.hazelcast.OHazelcastPlugin

All Implemented Interfaces:

com.hazelcast.core.EntryListener<String,Object>, com.hazelcast.core.MembershipListener, com.hazelcast.map.listener.EntryAddedListener<String,Object>, com.hazelcast.map.listener.EntryEvictedListener<String,Object>, com.hazelcast.map.listener.EntryRemovedListener<String,Object>, com.hazelcast.map.listener.EntryUpdatedListener<String,Object>, com.hazelcast.map.listener.MapClearedListener, com.hazelcast.map.listener.MapEvictedListener, com.hazelcast.map.listener.MapListener, OService, OCommandOutputListener, ODatabaseLifecycleListener, ODistributedServerManager, OServerPlugin, EventListener
```
public class OHazelcastPlugin
extends ODistributedAbstractPlugin
implements com.hazelcast.core.MembershipListener, com.hazelcast.core.EntryListener<String,Object>
```
Hazelcast implementation for clustering.

Author:

Luca Garulli (l.garulli--at--orientechnologies.com)

Nested Class Summary
- Nested classes/interfaces inherited from interface com.orientechnologies.orient.server.distributed.ODistributedServerManager
  ODistributedServerManager.DB_STATUS, ODistributedServerManager.NODE_STATUS
- Nested classes/interfaces inherited from interface com.orientechnologies.orient.core.db.ODatabaseLifecycleListener
  ODatabaseLifecycleListener.PRIORITY

Field Summary

Fields
Modifier and Type	Field and Description
`static String`	`CONFIG_DATABASE_PREFIX`
`protected static String`	`CONFIG_DBSTATUS_PREFIX`
`protected static String`	`CONFIG_NODE_PREFIX`
`protected static String`	`CONFIG_REGISTEREDNODES`
`protected OHazelcastDistributedMap`	`configurationMap`
`protected String`	`hazelcastConfigFile`
`protected com.hazelcast.core.HazelcastInstance`	`hazelcastInstance`
`protected String`	`membershipListenerMapRegistration`
`protected String`	`membershipListenerRegistration`

Fields inherited from class com.orientechnologies.orient.server.distributed.impl.ODistributedAbstractPlugin
activeNodes, activeNodesNamesByMemberId, clusterAssignmentStrategy, defaultDatabaseConfigFile, DEPLOY_DB_MAX_RETRIES, enabled, lastClusterChangeOn, lastLSNWriting, listeners, localMessageIdCounter, messageService, NODE_NAME_ENV, nodeId, nodeName, nodeUuid, PAR_DEF_DISTRIB_DB_CONFIG, publishLocalNodeConfigurationTask, registeredNodeById, registeredNodeByName, remoteServers, REPLICATOR_USER, serverInstance, startedOn, status, storages, taskFactory

Fields inherited from interface com.orientechnologies.orient.server.distributed.ODistributedServerManager
FILE_DISTRIBUTED_DB_CONFIG

Constructor Summary

Constructors
Constructor and Description

OHazelcastPlugin()

Constructors
Constructor and Description
`OHazelcastPlugin()`

Method Summary

All Methods Instance Methods Concrete Methods
Modifier and Type	Method and Description
`void`	`config(OServer iServer, OServerParameterConfiguration[] iParams)` Configures the handler.
`protected com.hazelcast.core.HazelcastInstance`	`configureHazelcast()`
`Throwable`	`convertException(Throwable original)`
`void`	`entryAdded(com.hazelcast.core.EntryEvent<String,Object> iEvent)`
`void`	`entryEvicted(com.hazelcast.core.EntryEvent<String,Object> iEvent)`
`void`	`entryRemoved(com.hazelcast.core.EntryEvent<String,Object> iEvent)`
`void`	`entryUpdated(com.hazelcast.core.EntryEvent<String,Object> iEvent)`
`ConcurrentMap<String,Object>`	`getConfigurationMap()`
`ODistributedServerManager.DB_STATUS`	`getDatabaseStatus(String iNode, String iDatabaseName)`
`com.hazelcast.core.HazelcastInstance`	`getHazelcastInstance()`
`protected ODistributedConfiguration`	`getLastDatabaseConfiguration(String databaseName)`
`Lock`	`getLock(String iName)` Gets a distributed lock
`ODocument`	`getNodeConfigurationByUuid(String iNodeId)`
`protected void`	`installNewDatabasesFromCluster(boolean iStartup)`
`protected ODocument`	`loadDatabaseConfiguration(String iDatabaseName, File file, boolean saveCfgToDisk)`
`protected void`	`loadLocalDatabases()` Initializes all the available server's databases as distributed.
`void`	`mapCleared(com.hazelcast.core.MapEvent event)`
`void`	`mapEvicted(com.hazelcast.core.MapEvent iEvent)`
`void`	`memberAdded(com.hazelcast.core.MembershipEvent iEvent)`
`void`	`memberAttributeChanged(com.hazelcast.core.MemberAttributeEvent memberAttributeEvent)`
`void`	`memberRemoved(com.hazelcast.core.MembershipEvent iEvent)` Removes the node map entry.
`void`	`onCreate(ODatabaseInternal iDatabase)`
`void`	`onDrop(ODatabaseInternal iDatabase)`
`protected void`	`publishLocalNodeConfiguration()`
`void`	`setDatabaseStatus(String iNode, String iDatabaseName, ODistributedServerManager.DB_STATUS iStatus)`
`void`	`shutdown()`
`void`	`startup()`
`void`	`updateCachedDatabaseConfiguration(String iDatabaseName, ODocument cfg, boolean iSaveToDisk, boolean iDeployToCluster)`

Methods inherited from class com.orientechnologies.orient.server.distributed.impl.ODistributedAbstractPlugin
assignNodeName, backupCurrentDatabase, checkNodeStatus, closeRemoteServer, dumpServersStatus, electCurrentNodeAsNewCoordinator, electCurrentNodeAsNewCoordinator, executeInDistributedDatabaseLock, executeOnLocalNode, getAvailableNodeNames, getAvailableNodes, getAvailableNodes, getClusterConfiguration, getCoordinatorServer, getDatabaseConfiguration, getDistributedConfigFile, getLastClusterChangeOn, getLocalNodeConfiguration, getLocalNodeId, getLocalNodeName, getManagedDatabases, getMessageService, getName, getNextMessageIdCounter, getNodeIdByName, getNodeName, getNodeNameById, getNodeStatus, getPriority, getRemoteServer, getServerInstance, getStats, getStorage, getTaskFactory, installClustersOfClass, installDatabase, installDatabaseFromNetwork, installDatabaseOnLocalNode, installDbClustersLocalStrategy, isEnabled, isNodeAvailable, isNodeAvailable, isNodeOnline, isOffline, isRelatedToLocalServer, onClose, onCreateClass, onDatabaseEvent, onDatabaseEvent, onDropClass, onLocalNodeConfigurationRequest, onMessage, onOpen, propagateSchemaChanges, reassignClustersOwnership, rebalanceClusterOwnership, registerLifecycleListener, requestDatabaseDelta, requestDatabaseFullSync, requestFullDatabase, restartNode, sendRequest, sendShutdown, setDefaultDatabaseConfigFile, setNodeStatus, stopNode, toString, unregisterLifecycleListener, updateCachedDatabaseConfiguration, updateLastClusterChange, waitUntilNodeOnline, waitUntilNodeOnline, writeDatabaseChunk

Methods inherited from class com.orientechnologies.orient.server.plugin.OServerPluginAbstract
getContent, onAfterClientRequest, onBeforeClientRequest, onClientConnection, onClientDisconnection, onClientError

Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait

Field Detail

CONFIG_DATABASE_PREFIX

public static final String CONFIG_DATABASE_PREFIX

See Also:: Constant Field Values

CONFIG_NODE_PREFIX

protected static final String CONFIG_NODE_PREFIX

See Also:: Constant Field Values

CONFIG_DBSTATUS_PREFIX

protected static final String CONFIG_DBSTATUS_PREFIX

See Also:: Constant Field Values

CONFIG_REGISTEREDNODES

protected static final String CONFIG_REGISTEREDNODES

See Also:: Constant Field Values

hazelcastConfigFile
```
protected String hazelcastConfigFile
```

membershipListenerRegistration

protected String membershipListenerRegistration

membershipListenerMapRegistration

protected String membershipListenerMapRegistration

hazelcastInstance

protected volatile com.hazelcast.core.HazelcastInstance hazelcastInstance

configurationMap

protected OHazelcastDistributedMap configurationMap

Constructor Detail
- OHazelcastPlugin
```
public OHazelcastPlugin()
```

Method Detail

config
```
public void config(OServer iServer,
                   OServerParameterConfiguration[] iParams)
```
Description copied from interface: OServerPlugin

Configures the handler. Called at startup.

Specified by:

config in interface OServerPlugin

Overrides:

config in class ODistributedAbstractPlugin

startup
```
public void startup()
```
Specified by:

startup in interface OService

Overrides:

startup in class ODistributedAbstractPlugin

publishLocalNodeConfiguration

protected void publishLocalNodeConfiguration()

convertException
```
public Throwable convertException(Throwable original)
```
Specified by:

convertException in interface ODistributedServerManager

shutdown
```
public void shutdown()
```
Specified by:

shutdown in interface OService

Overrides:

shutdown in class ODistributedAbstractPlugin

getHazelcastInstance

public com.hazelcast.core.HazelcastInstance getHazelcastInstance()

configureHazelcast

protected com.hazelcast.core.HazelcastInstance configureHazelcast()
                                                           throws FileNotFoundException

Throws:: FileNotFoundException

loadDatabaseConfiguration

protected ODocument loadDatabaseConfiguration(String iDatabaseName,
                                              File file,
                                              boolean saveCfgToDisk)

Overrides:: loadDatabaseConfiguration in class ODistributedAbstractPlugin

loadLocalDatabases
```
protected void loadLocalDatabases()
```
Initializes all the available server's databases as distributed.

getConfigurationMap
```
public ConcurrentMap<String,Object> getConfigurationMap()
```
Specified by:

getConfigurationMap in interface ODistributedServerManager

getLastDatabaseConfiguration
```
protected ODistributedConfiguration getLastDatabaseConfiguration(String databaseName)
```
Specified by:

getLastDatabaseConfiguration in class ODistributedAbstractPlugin

getLock
```
public Lock getLock(String iName)
```
Description copied from interface: ODistributedServerManager

Gets a distributed lock

Specified by:

getLock in interface ODistributedServerManager

Parameters:

iName - name of the lock

Returns:

memberAttributeChanged
```
public void memberAttributeChanged(com.hazelcast.core.MemberAttributeEvent memberAttributeEvent)
```
Specified by:

memberAttributeChanged in interface com.hazelcast.core.MembershipListener

updateCachedDatabaseConfiguration

public void updateCachedDatabaseConfiguration(String iDatabaseName,
                                              ODocument cfg,
                                              boolean iSaveToDisk,
                                              boolean iDeployToCluster)

Specified by:: updateCachedDatabaseConfiguration in interface ODistributedServerManager

entryAdded
```
public void entryAdded(com.hazelcast.core.EntryEvent<String,Object> iEvent)
```
Specified by:

entryAdded in interface com.hazelcast.map.listener.EntryAddedListener<String,Object>

entryUpdated
```
public void entryUpdated(com.hazelcast.core.EntryEvent<String,Object> iEvent)
```
Specified by:

entryUpdated in interface com.hazelcast.map.listener.EntryUpdatedListener<String,Object>

entryRemoved
```
public void entryRemoved(com.hazelcast.core.EntryEvent<String,Object> iEvent)
```
Specified by:

entryRemoved in interface com.hazelcast.map.listener.EntryRemovedListener<String,Object>

entryEvicted
```
public void entryEvicted(com.hazelcast.core.EntryEvent<String,Object> iEvent)
```
Specified by:

entryEvicted in interface com.hazelcast.map.listener.EntryEvictedListener<String,Object>

mapEvicted
```
public void mapEvicted(com.hazelcast.core.MapEvent iEvent)
```
Specified by:

mapEvicted in interface com.hazelcast.map.listener.MapEvictedListener

mapCleared
```
public void mapCleared(com.hazelcast.core.MapEvent event)
```
Specified by:

mapCleared in interface com.hazelcast.map.listener.MapClearedListener

memberRemoved
```
public void memberRemoved(com.hazelcast.core.MembershipEvent iEvent)
```
Removes the node map entry.

Specified by:

memberRemoved in interface com.hazelcast.core.MembershipListener

memberAdded
```
public void memberAdded(com.hazelcast.core.MembershipEvent iEvent)
```
Specified by:

memberAdded in interface com.hazelcast.core.MembershipListener

onCreate
```
public void onCreate(ODatabaseInternal iDatabase)
```
Specified by:

onCreate in interface ODatabaseLifecycleListener

onDrop
```
public void onDrop(ODatabaseInternal iDatabase)
```
Specified by:

onDrop in interface ODatabaseLifecycleListener

Overrides:

onDrop in class ODistributedAbstractPlugin

getNodeConfigurationByUuid
```
public ODocument getNodeConfigurationByUuid(String iNodeId)
```
Specified by:

getNodeConfigurationByUuid in interface ODistributedServerManager

getDatabaseStatus

public ODistributedServerManager.DB_STATUS getDatabaseStatus(String iNode,
                                                             String iDatabaseName)

Specified by:: getDatabaseStatus in interface ODistributedServerManager

setDatabaseStatus

public void setDatabaseStatus(String iNode,
                              String iDatabaseName,
                              ODistributedServerManager.DB_STATUS iStatus)

Specified by:: setDatabaseStatus in interface ODistributedServerManager

installNewDatabasesFromCluster

protected void installNewDatabasesFromCluster(boolean iStartup)

Class OHazelcastPlugin

Nested Class Summary

Nested classes/interfaces inherited from interface com.orientechnologies.orient.server.distributed.ODistributedServerManager

Nested classes/interfaces inherited from interface com.orientechnologies.orient.core.db.ODatabaseLifecycleListener

Field Summary

Fields inherited from class com.orientechnologies.orient.server.distributed.impl.ODistributedAbstractPlugin

Fields inherited from interface com.orientechnologies.orient.server.distributed.ODistributedServerManager

Constructor Summary

Method Summary

Methods inherited from class com.orientechnologies.orient.server.distributed.impl.ODistributedAbstractPlugin

Methods inherited from class com.orientechnologies.orient.server.plugin.OServerPluginAbstract

Methods inherited from class java.lang.Object

Field Detail

CONFIG_DATABASE_PREFIX

CONFIG_NODE_PREFIX

CONFIG_DBSTATUS_PREFIX

CONFIG_REGISTEREDNODES

hazelcastConfigFile

membershipListenerRegistration

membershipListenerMapRegistration

hazelcastInstance

configurationMap

Constructor Detail

OHazelcastPlugin

Method Detail

config

startup

publishLocalNodeConfiguration

convertException

shutdown

getHazelcastInstance

configureHazelcast

loadDatabaseConfiguration

loadLocalDatabases

getConfigurationMap

getLastDatabaseConfiguration

getLock

memberAttributeChanged

updateCachedDatabaseConfiguration

entryAdded

entryUpdated

entryRemoved

entryEvicted

mapEvicted

mapCleared

memberRemoved

memberAdded

onCreate

onDrop

getNodeConfigurationByUuid

getDatabaseStatus

setDatabaseStatus

installNewDatabasesFromCluster