java.lang.Object
- org.cyclos.impl.AbstractServerComponent
- - org.cyclos.impl.AbstractGlobalServerComponent
  - - org.cyclos.impl.BaseGlobalHandlerImpl
    - - org.cyclos.impl.utils.cluster.AbstractClusterHandlerImpl
      - org.cyclos.impl.utils.cluster.HazelcastClusterHandlerImpl

All Implemented Interfaces:

CustomBean, ClusterHandler
```
public class HazelcastClusterHandlerImpl
extends AbstractClusterHandlerImpl
```
A ClusterHandler using Hazelcast

Nested Class Summary
- Nested classes/interfaces inherited from class org.cyclos.impl.utils.cluster.AbstractClusterHandlerImpl
  AbstractClusterHandlerImpl.FinishedExecutionsHandlerImpl
- Nested classes/interfaces inherited from interface org.cyclos.impl.utils.cluster.ClusterHandler
  ClusterHandler.FinishedExecutionsHandler

Field Summary
- Fields inherited from class org.cyclos.impl.utils.cluster.AbstractClusterHandlerImpl
  applicationContext, backgroundTaskHandler, beanHandler, cyclosProperties, databaseManager, dbLockHandler, IGNORE_DB_LOCK_PROPERTY, ignoreDbLock, invokerHandler, lockHandler, nativeQueryHandler, pollingTaskHandler, rawEntityManagerHandler, systemMonitorService
- Fields inherited from class org.cyclos.impl.AbstractServerComponent
  accountHandler, configurationHandler, dataTranslationHandler, notificationHandler, profileFieldHandler, transactionHandler, translationHandler

Constructor Summary

Constructors
Constructor Description

HazelcastClusterHandlerImpl()

Method Summary

All Methods Instance Methods Concrete Methods
Modifier and Type	Method	Description
`protected <K,V> ReplicatedStorage<K,V>`	`createReplicatedStorage(ReplicatedStorageType type)`
`protected <K extends Serializable,V extends Serializable> SharedStorage<K,V>`	`createSharedStorage(SharedStorageType<K,V> type)`	Actually creates a new shared storage.
`void`	`destroy()`
`protected void`	`doRemoveFinishedBackgroundTaskExecutions(List<Long> ids)`
`void`	`finishBackgroundTaskExecution(BackgroundTaskExecutionContext task)`	Masks as finished the given task execution
`Map<String,Integer>`	`getBackgroundTaskExecutions()`	Returns a map from background task name to the number of executions it has.
`protected BlockingQueue<BackgroundTaskExecutionContext>`	`getBackgroundTaskQueue()`
`protected int`	`getBackgroundTaskThreads()`
`ClusterHandler.FinishedExecutionsHandler`	`getFinishedBackgroundTaskExecutions()`	Returns a handler with the already finished executions at the moment of the invocation.
`String`	`getHostId()`	Returns the current host identifier
`MemberRunningTaskDescriptor`	`getMemberRunningTask(String taskName)`	Returns information with the member running the given polling task or null if the task is not being executed.
`List<ServerData>`	`getMembersData()`	Returns information about each cluster member. In case `ClusterHandler.isCluster()` returns false then the list will contain a single element with the information of the local host.
`Map<String,MemberRunningTaskDescriptor>`	`getRunningPollingTasks()`	Returns a map from polling task name to a descriptor with information about the member that is executing it.
`void`	`initialize()`
`protected CacheHandlerImplementor`	`instantiateCacheHandler()`
`protected PollingTaskHandlerImplementor`	`instantiatePollingTaskHandler()`
`protected PushNotificationHandler`	`instantiatePushNotificationHandler()`
`boolean`	`isAlive()`	Returns whether the cluster (or local instance) is still alive
`boolean`	`isCausedByShutdown(Throwable e)`	Returns whether the given exception was caused by a server shutdown.
`boolean`	`isCluster()`	Returns whether we're actually running in a cluster or as a single node installation
`protected void`	`runBackgroundTask(BackgroundTaskExecutionContext task)`
`boolean`	`runInitialization(ApplicationInitializationListener listener)`	Attempts to execute the given `ApplicationInitializationListener.onApplicationInitialization()`.
`boolean`	`runUpgradeInitialization(ApplicationUpgradeInitializationListener listener)`	Attempts to execute the given `ApplicationUpgradeInitializationListener.onApplicationUpgradeInitialization()`.
`protected boolean`	`shouldEnsureDatabaseIsNotLocked()`
`protected boolean`	`shouldUnlockDatabase()`
`void`	`shutdown()`

Methods inherited from class org.cyclos.impl.utils.cluster.AbstractClusterHandlerImpl
awakePollingTasks, createLocalStorage, getBackgroundTasksQueueSize, getCacheHandler, getLocalStorage, getPollingTaskHandler, getPushNotificationHandler, getRemainingBackgroundTaskCapacity, getReplicatedStorage, getSharedStorage, lockDatabase, runBackgroundTasks

Methods inherited from class org.cyclos.impl.AbstractGlobalServerComponent
getBaseEntityManagerHandler, getEntityManager

Methods inherited from class org.cyclos.impl.AbstractServerComponent
dataTranslationProxy, dataTranslationProxy, delete, detach, doDataTranslationProxy, find, flush, from, getApplicationContext, getFormatter, getFormatter, getFormatter, getLogger, getRemoteAddress, getSessionData, mailContentBuilder, message, message, persist, processBatch, processBatch, refresh, remove, selectFrom, subQuery, update

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

- Constructor Detail
  - HazelcastClusterHandlerImpl
```
public HazelcastClusterHandlerImpl()
```
- Method Detail
  - destroy
```
@PreDestroy
public void destroy()
```
  - finishBackgroundTaskExecution
```
public void finishBackgroundTaskExecution(BackgroundTaskExecutionContext task)
```
    Description copied from interface: ClusterHandler
    
    Masks as finished the given task execution
  - getBackgroundTaskExecutions
```
public Map<String,Integer> getBackgroundTaskExecutions()
```
    Description copied from interface: ClusterHandler
    
    Returns a map from background task name to the number of executions it has. A task no contained in the map means it's not running at the moment of the invocation.
  - getFinishedBackgroundTaskExecutions
```
public ClusterHandler.FinishedExecutionsHandler getFinishedBackgroundTaskExecutions()
```
    Description copied from interface: ClusterHandler
    
    Returns a handler with the already finished executions at the moment of the invocation.
  - getHostId
```
public String getHostId()
```
    Description copied from interface: ClusterHandler
    
    Returns the current host identifier
  - getMemberRunningTask
```
public MemberRunningTaskDescriptor getMemberRunningTask(String taskName)
```
    Description copied from interface: ClusterHandler
    
    Returns information with the member running the given polling task or null if the task is not being executed.
  - getMembersData
```
public List<ServerData> getMembersData()
```
    Description copied from interface: ClusterHandler
    
    Returns information about each cluster member.
    In case ClusterHandler.isCluster() returns false then the list will contain a single element with the information of the local host.
  - getRunningPollingTasks
```
public Map<String,MemberRunningTaskDescriptor> getRunningPollingTasks()
```
    Description copied from interface: ClusterHandler
    
    Returns a map from polling task name to a descriptor with information about the member that is executing it. A task no contained in the map means it's not running at the moment of the invocation.
  - initialize
```
@PostConstruct
public void initialize()
```
    Overrides:
    
    initialize in class AbstractClusterHandlerImpl
  - isAlive
```
public boolean isAlive()
```
    Description copied from interface: ClusterHandler
    
    Returns whether the cluster (or local instance) is still alive
  - isCausedByShutdown
```
public boolean isCausedByShutdown(Throwable e)
```
    Description copied from interface: ClusterHandler
    
    Returns whether the given exception was caused by a server shutdown. For example, InterruptedExceptions are considered to be caused by a shutdown.
    
    Specified by:
    
    isCausedByShutdown in interface ClusterHandler
    
    Overrides:
    
    isCausedByShutdown in class AbstractClusterHandlerImpl
  - isCluster
```
public boolean isCluster()
```
    Description copied from interface: ClusterHandler
    
    Returns whether we're actually running in a cluster or as a single node installation
  - runInitialization
```
public boolean runInitialization(ApplicationInitializationListener listener)
```
    Description copied from interface: ClusterHandler
    
    Attempts to execute the given ApplicationInitializationListener.onApplicationInitialization(). In some cases (for example, the initialization was already executed), it might do nothing, and just return false
    
    Specified by:
    
    runInitialization in interface ClusterHandler
    
    Overrides:
    
    runInitialization in class AbstractClusterHandlerImpl
  - runUpgradeInitialization
```
public boolean runUpgradeInitialization(ApplicationUpgradeInitializationListener listener)
```
    Description copied from interface: ClusterHandler
    
    Attempts to execute the given ApplicationUpgradeInitializationListener.onApplicationUpgradeInitialization(). In some cases (for example, the initialization was already executed), it might do nothing, and just return false
    
    Specified by:
    
    runUpgradeInitialization in interface ClusterHandler
    
    Overrides:
    
    runUpgradeInitialization in class AbstractClusterHandlerImpl
  - shutdown
```
@PreDestroy
public void shutdown()
```
    Overrides:
    
    shutdown in class AbstractClusterHandlerImpl
  - createReplicatedStorage
```
protected <K,V> ReplicatedStorage<K,V> createReplicatedStorage(ReplicatedStorageType type)
```
    Overrides:
    
    createReplicatedStorage in class AbstractClusterHandlerImpl
  - createSharedStorage
```
protected <K extends Serializable,V extends Serializable> SharedStorage<K,V> createSharedStorage(SharedStorageType<K,V> type)
```
    Description copied from class: AbstractClusterHandlerImpl
    
    Actually creates a new shared storage. The resulting value will be cached for the given name.
    
    Overrides:
    
    createSharedStorage in class AbstractClusterHandlerImpl
  - doRemoveFinishedBackgroundTaskExecutions
```
protected void doRemoveFinishedBackgroundTaskExecutions(List<Long> ids)
```
    Specified by:
    
    doRemoveFinishedBackgroundTaskExecutions in class AbstractClusterHandlerImpl
  - getBackgroundTaskQueue
```
protected BlockingQueue<BackgroundTaskExecutionContext> getBackgroundTaskQueue()
```
    Specified by:
    
    getBackgroundTaskQueue in class AbstractClusterHandlerImpl
  - getBackgroundTaskThreads
```
protected int getBackgroundTaskThreads()
```
    Specified by:
    
    getBackgroundTaskThreads in class AbstractClusterHandlerImpl
  - instantiateCacheHandler
```
protected CacheHandlerImplementor instantiateCacheHandler()
```
    Specified by:
    
    instantiateCacheHandler in class AbstractClusterHandlerImpl
  - instantiatePollingTaskHandler
```
protected PollingTaskHandlerImplementor instantiatePollingTaskHandler()
```
    Specified by:
    
    instantiatePollingTaskHandler in class AbstractClusterHandlerImpl
  - instantiatePushNotificationHandler
```
protected PushNotificationHandler instantiatePushNotificationHandler()
```
    Specified by:
    
    instantiatePushNotificationHandler in class AbstractClusterHandlerImpl
  - runBackgroundTask
```
protected void runBackgroundTask(BackgroundTaskExecutionContext task)
```
    Overrides:
    
    runBackgroundTask in class AbstractClusterHandlerImpl
  - shouldEnsureDatabaseIsNotLocked
```
protected boolean shouldEnsureDatabaseIsNotLocked()
```
    Specified by:
    
    shouldEnsureDatabaseIsNotLocked in class AbstractClusterHandlerImpl
  - shouldUnlockDatabase
```
protected boolean shouldUnlockDatabase()
```
    Specified by:
    
    shouldUnlockDatabase in class AbstractClusterHandlerImpl

Class HazelcastClusterHandlerImpl

Nested Class Summary

Nested classes/interfaces inherited from class org.cyclos.impl.utils.cluster.AbstractClusterHandlerImpl

Nested classes/interfaces inherited from interface org.cyclos.impl.utils.cluster.ClusterHandler

Field Summary

Fields inherited from class org.cyclos.impl.utils.cluster.AbstractClusterHandlerImpl

Fields inherited from class org.cyclos.impl.AbstractServerComponent

Constructor Summary

Method Summary

Methods inherited from class org.cyclos.impl.utils.cluster.AbstractClusterHandlerImpl

Methods inherited from class org.cyclos.impl.AbstractGlobalServerComponent

Methods inherited from class org.cyclos.impl.AbstractServerComponent

Methods inherited from class java.lang.Object

Constructor Detail

HazelcastClusterHandlerImpl

Method Detail

destroy

finishBackgroundTaskExecution

getBackgroundTaskExecutions

getFinishedBackgroundTaskExecutions

getHostId

getMemberRunningTask

getMembersData

getRunningPollingTasks

initialize

isAlive

isCausedByShutdown

isCluster

runInitialization

runUpgradeInitialization

shutdown

createReplicatedStorage

createSharedStorage

doRemoveFinishedBackgroundTaskExecutions

getBackgroundTaskQueue

getBackgroundTaskThreads

instantiateCacheHandler

instantiatePollingTaskHandler

instantiatePushNotificationHandler

runBackgroundTask

shouldEnsureDatabaseIsNotLocked

shouldUnlockDatabase