Package org.cyclos.impl.utils.cluster

Class NoClusterHandlerImpl

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

All Implemented Interfaces:

CustomBean, ClusterHandler

public class NoClusterHandlerImpl
extends AbstractClusterHandlerImpl

A ClusterHandler for standalone instances (no cluster)

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

Modifier and Type	Field	Description
protected ConversionHandler	conversionHandler

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
NoClusterHandlerImpl()

Method Summary

Modifier and Type	Method	Description
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	isCluster()	Returns whether we're actually running in a cluster or as a single node installation
boolean	lockDatabase()	Checks that there is no other Cyclos instance using the database and afterwards, locks the database.
protected void	runBackgroundTask(BackgroundTaskExecutionContext task)
protected boolean	shouldEnsureDatabaseIsNotLocked()
protected boolean	shouldUnlockDatabase()
void	shutdown()

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

awakePollingTasks, createLocalStorage, createReplicatedStorage, createSharedStorage, getBackgroundTasksQueueSize, getCacheHandler, getLocalStorage, getPollingTaskHandler, getPushNotificationHandler, getRemainingBackgroundTaskCapacity, getReplicatedStorage, getSharedStorage, isCausedByShutdown, runBackgroundTasks, runInitialization, runUpgradeInitialization

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

Field Detail

conversionHandler

@Autowired
@Lazy
protected ConversionHandler conversionHandler

Constructor Detail

NoClusterHandlerImpl

public NoClusterHandlerImpl()

Method Detail

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

isCluster

public boolean isCluster()

Description copied from interface: ClusterHandler

Returns whether we're actually running in a cluster or as a single node installation

lockDatabase

public boolean lockDatabase()

Description copied from interface: ClusterHandler

Checks that there is no other Cyclos instance using the database and afterwards, locks the database. Returns whether the database was actually locked.

Specified by:

lockDatabase in interface ClusterHandler

Overrides:

lockDatabase in class AbstractClusterHandlerImpl

shutdown

@PreDestroy
public void shutdown()

Overrides:

shutdown 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