Package org.flowable.eventregistry.impl

Class EventManagementServiceImpl

java.lang.Object

org.flowable.common.engine.impl.service.CommonServiceImpl<C>

org.flowable.common.engine.impl.service.CommonEngineServiceImpl<EventRegistryEngineConfiguration>

org.flowable.eventregistry.impl.EventManagementServiceImpl

All Implemented Interfaces:

EventManagementService

public class EventManagementServiceImpl
extends CommonEngineServiceImpl<EventRegistryEngineConfiguration>
implements EventManagementService

Author:

Tijs Rademakers

Field Summary

Fields inherited from class org.flowable.common.engine.impl.service.CommonEngineServiceImpl

commandExecutor

Fields inherited from class org.flowable.common.engine.impl.service.CommonServiceImpl

configuration

Constructor Summary

Constructors

Constructor	Description
EventManagementServiceImpl(EventRegistryEngineConfiguration engineConfiguration)

Method Summary

Modifier and Type	Method	Description
void	executeEventRegistryChangeDetection()	Programmatically execute the house keeping functionality: any new channel definitions deployed on other engine nodes (using the same datasource) will be deployed.
LockManager	getLockManager(String lockName)	Acquire a lock manager for the requested lock.
Map<String,Long>	getTableCounts()	Returns a map containing {tableName, rowCount} values.
Collection<String>	getTableNames()	Returns all relational database tables of the engine.

Methods inherited from class org.flowable.common.engine.impl.service.CommonEngineServiceImpl

getCommandExecutor, setCommandExecutor

Methods inherited from class org.flowable.common.engine.impl.service.CommonServiceImpl

getConfiguration

Methods inherited from class java.lang.Object

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

Constructor Details

EventManagementServiceImpl

public EventManagementServiceImpl(EventRegistryEngineConfiguration engineConfiguration)

Method Details

getTableCounts

public Map<String,Long> getTableCounts()

Description copied from interface: EventManagementService

Returns a map containing {tableName, rowCount} values.

Specified by:

getTableCounts in interface EventManagementService

getTableNames

public Collection<String> getTableNames()

Description copied from interface: EventManagementService

Returns all relational database tables of the engine.

Specified by:

getTableNames in interface EventManagementService

executeEventRegistryChangeDetection

public void executeEventRegistryChangeDetection()

Description copied from interface: EventManagementService

Programmatically execute the house keeping functionality: any new channel definitions deployed on other engine nodes (using the same datasource) will be deployed. Any removed channel definitions on other engine nodes will be removed.

Specified by:

executeEventRegistryChangeDetection in interface EventManagementService

getLockManager

public LockManager getLockManager(String lockName)

Description copied from interface: EventManagementService

Acquire a lock manager for the requested lock. This is a stateless call, this means that every time a lock manager is requested a new one would be created. Make sure that you release the lock once you are done.

Specified by:

getLockManager in interface EventManagementService

Parameters:

lockName - the name of the lock that is being requested

Returns:

the lock manager for the given lock