Package org.flowable.eventregistry.impl

Class EventRegistryEngineConfiguration

java.lang.Object

org.flowable.common.engine.impl.AbstractEngineConfiguration

org.flowable.eventregistry.impl.EventRegistryEngineConfiguration

All Implemented Interfaces:

HasExpressionManagerEngineConfiguration, EventRegistryConfigurationApi

Direct Known Subclasses:

SpringEventRegistryEngineConfiguration, StandaloneEventRegistryEngineConfiguration

public class EventRegistryEngineConfiguration
extends AbstractEngineConfiguration
implements EventRegistryConfigurationApi, HasExpressionManagerEngineConfiguration

Field Summary

Fields

Modifier and Type	Field	Description
protected CachingAndArtifactsManager	cachingAndArtifactsManager
protected DeploymentCache<ChannelDefinitionCacheEntry>	channelDefinitionCache
protected ChannelDefinitionDataManager	channelDefinitionDataManager
protected ChannelDefinitionEntityManager	channelDefinitionEntityManager
protected ChannelDefinitionDeploymentHelper	channelDeploymentHelper
protected ChannelJsonConverter	channelJsonConverter
protected Collection<ChannelModelProcessor>	channelModelProcessors
protected ChannelDefinitionParseFactory	channelParseFactory
protected List<Deployer>	customPostDeployers
protected List<Deployer>	customPreDeployers
static final String	DEFAULT_MYBATIS_MAPPING_FILE
protected InboundEventPayloadExtractor<?>	defaultInboundEventPayloadExtractor
protected List<Deployer>	deployers
protected EventDeploymentDataManager	deploymentDataManager
protected EventDeploymentEntityManager	deploymentEntityManager
protected EventDeploymentManager	deploymentManager
protected boolean	enableEventRegistryChangeDetection
protected boolean	enableEventRegistryChangeDetectionAfterEngineCreate
protected DeploymentCache<EventDefinitionCacheEntry>	eventDefinitionCache
protected int	eventDefinitionCacheLimit
protected EventDefinitionDataManager	eventDefinitionDataManager
protected EventDefinitionEntityManager	eventDefinitionEntityManager
protected EventDefinitionDeployer	eventDeployer
protected EventDefinitionDeploymentHelper	eventDeploymentHelper
protected EventJsonConverter	eventJsonConverter
protected EventManagementService	eventManagementService
protected EventDefinitionParseFactory	eventParseFactory
protected EventRegistry	eventRegistry
protected long	eventRegistryChangeDetectionDelayInMs
protected EventRegistryChangeDetectionExecutor	eventRegistryChangeDetectionExecutor
protected long	eventRegistryChangeDetectionInitialDelayInMs
protected EventRegistryChangeDetectionManager	eventRegistryChangeDetectionManager
protected String	eventRegistryEngineName
protected EventRepositoryService	eventRepositoryService
protected ExpressionManager	expressionManager
protected Collection<Consumer<ExpressionManager>>	expressionManagerConfigurers
protected InboundChannelModelCacheManager	inboundChannelModelCacheManager
protected Map<String,InboundEventPayloadExtractor<?>>	inboundEventPayloadExtractorsByChannelType
protected InboundEventProcessor	inboundEventProcessor
static final String	LIQUIBASE_CHANGELOG_PREFIX
protected EventRegistryNonMatchingEventConsumer	nonMatchingEventConsumer
protected OutboundEventProcessor	outboundEventProcessor
protected ParsedDeploymentBuilderFactory	parsedDeploymentBuilderFactory
protected Collection<ELResolver>	postDefaultELResolvers
protected Collection<ELResolver>	preBeanELResolvers
protected Collection<ELResolver>	preDefaultELResolvers
protected EventResourceDataManager	resourceDataManager
protected EventResourceEntityManager	resourceEntityManager
protected OutboundEventProcessor	systemOutboundEventProcessor

Fields inherited from class org.flowable.common.engine.impl.AbstractEngineConfiguration

additionalEventDispatchActions, agendaOperationExecutionListeners, agendaOperationRunner, allConfigurators, alwaysLookupLatestDefinitionVersion, beans, byteArrayDataManager, byteArrayEntityManager, classLoader, clock, commandContextFactory, commandExecutor, commandInterceptors, commandInvoker, commonSchemaManager, configurators, customMybatisInterceptors, customMybatisMappers, customMybatisXMLMappers, customPostCommandInterceptors, customPreCommandInterceptors, customSessionFactories, DATABASE_TYPE_COCKROACHDB, DATABASE_TYPE_DB2, DATABASE_TYPE_H2, DATABASE_TYPE_HSQL, DATABASE_TYPE_MSSQL, DATABASE_TYPE_MYSQL, DATABASE_TYPE_ORACLE, DATABASE_TYPE_POSTGRES, databaseCatalog, databaseSchema, databaseSchemaUpdate, databaseTablePrefix, databaseType, databaseTypeMappings, databaseWildcardEscapeCharacter, dataSource, dataSourceJndiName, DB_SCHEMA_UPDATE_CREATE, DB_SCHEMA_UPDATE_CREATE_DROP, DB_SCHEMA_UPDATE_DROP_CREATE, DB_SCHEMA_UPDATE_FALSE, DB_SCHEMA_UPDATE_TRUE, dbSqlSessionFactory, DEFAULT_GENERIC_MAX_LENGTH_STRING, DEFAULT_MAX_NR_OF_STATEMENTS_BULK_INSERT_SQL_SERVER, DEFAULT_ORACLE_MAX_LENGTH_STRING, defaultCommandConfig, defaultCommandInterceptors, defaultTenantProvider, dependentEngineMybatisTypeAliasConfigs, dependentEngineMybatisTypeHandlerConfigs, dependentEngineMyBatisXmlMappers, enableConfiguratorServiceLoader, enableEventDispatcher, enableLogSqlExecutionTime, engineConfigurations, engineLifecycleListeners, eventDispatcher, eventListeners, eventRegistryConfigurator, eventRegistryEventConsumers, fallbackToDefaultTenant, forceCloseMybatisConnectionPool, idGenerator, idmEngineConfigurator, isBulkInsertEnabled, isDbHistoryUsed, jdbcDefaultTransactionIsolationLevel, jdbcDriver, jdbcMaxActiveConnections, jdbcMaxCheckoutTime, jdbcMaxIdleConnections, jdbcMaxWaitTime, jdbcPassword, jdbcPingConnectionNotUsedFor, jdbcPingEnabled, jdbcPingQuery, jdbcUrl, jdbcUsername, lockPollRate, logger, loggingListener, maxLengthStringVariableType, maxNrOfStatementsInBulkInsert, mybatisMappingFile, NO_TENANT_ID, objectMapper, PRODUCT_NAME_CRDB, PRODUCT_NAME_POSTGRES, propertyDataManager, propertyEntityManager, schemaCommandConfig, schemaLockWaitTime, schemaManagementCmd, schemaManager, serviceConfigurations, sessionFactories, sqlSessionFactory, tableDataManager, tablePrefixIsSchema, transactionContextFactory, transactionFactory, transactionsExternallyManaged, typedEventListeners, useClassForNameClassLoading, useLockForDatabaseSchemaUpdate, usePrefixId, usingRelationalDatabase, usingSchemaMgmt, xmlEncoding

Constructor Summary

Constructors

Constructor	Description
EventRegistryEngineConfiguration()

Method Summary

Modifier and Type	Method	Description
void	addChannelModelProcessor(ChannelModelProcessor channelModelProcessor)
AbstractEngineConfiguration	addExpressionManagerConfigurer(Consumer<ExpressionManager> configurer)
EventRegistryEngineConfiguration	addPostDefaultELResolver(ELResolver elResolver)
EventRegistryEngineConfiguration	addPreBeanELResolver(ELResolver elResolver)
EventRegistryEngineConfiguration	addPreDefaultELResolver(ELResolver elResolver)
EventRegistryEngine	buildEventRegistryEngine()
DbSqlSessionFactory	createDbSqlSessionFactory()
static EventRegistryEngineConfiguration	createEventRegistryEngineConfigurationFromInputStream(InputStream inputStream)
static EventRegistryEngineConfiguration	createEventRegistryEngineConfigurationFromInputStream(InputStream inputStream, String beanName)
static EventRegistryEngineConfiguration	createEventRegistryEngineConfigurationFromResource(String resource)
static EventRegistryEngineConfiguration	createEventRegistryEngineConfigurationFromResource(String resource, String beanName)
static EventRegistryEngineConfiguration	createEventRegistryEngineConfigurationFromResourceDefault()
static EventRegistryEngineConfiguration	createStandaloneEventRegistryEngineConfiguration()
static EventRegistryEngineConfiguration	createStandaloneInMemEventRegistryEngineConfiguration()
CommandInterceptor	createTransactionInterceptor()
DeploymentCache<ChannelDefinitionCacheEntry>	getChannelDefinitionCache()
ChannelDefinitionEntityManager	getChannelDefinitionEntityManager()
ChannelJsonConverter	getChannelJsonConverter()
Collection<ChannelModelProcessor>	getChannelModelProcessors()
Collection<? extends Deployer>	getDefaultDeployers()
InboundEventPayloadExtractor<?>	getDefaultInboundEventPayloadExtractor()
EventDeploymentDataManager	getDeploymentDataManager()
EventDeploymentEntityManager	getDeploymentEntityManager()
EventDeploymentManager	getDeploymentManager()
String	getEngineCfgKey()
String	getEngineName()
String	getEngineScopeType()
DeploymentCache<EventDefinitionCacheEntry>	getEventDefinitionCache()
int	getEventDefinitionCacheLimit()
EventDefinitionDataManager	getEventDefinitionDataManager()
EventDefinitionEntityManager	getEventDefinitionEntityManager()
EventDefinitionDeployer	getEventDeployer()
EventJsonConverter	getEventJsonConverter()
EventManagementService	getEventManagementService()
EventDefinitionParseFactory	getEventParseFactory()
EventRegistry	getEventRegistry()
long	getEventRegistryChangeDetectionDelayInMs()
EventRegistryChangeDetectionExecutor	getEventRegistryChangeDetectionExecutor()
long	getEventRegistryChangeDetectionInitialDelayInMs()
EventRegistryChangeDetectionManager	getEventRegistryChangeDetectionManager()
EventRepositoryService	getEventRepositoryService()
ExpressionManager	getExpressionManager()
Collection<Consumer<ExpressionManager>>	getExpressionManagerConfigurers()
EventRegistryEngineConfiguration	getFormEngineConfiguration()
InboundChannelModelCacheManager	getInboundChannelModelCacheManager()
Map<String,InboundEventPayloadExtractor<?>>	getInboundEventPayloadExtractorsByChannelType()
InboundEventProcessor	getInboundEventProcessor()
InputStream	getMyBatisXmlConfigurationStream()
EventRegistryNonMatchingEventConsumer	getNonMatchingEventConsumer()
OutboundEventProcessor	getOutboundEventProcessor()
Collection<ELResolver>	getPostDefaultELResolvers()
Collection<ELResolver>	getPreBeanELResolvers()
Collection<ELResolver>	getPreDefaultELResolvers()
EventResourceDataManager	getResourceDataManager()
EventResourceEntityManager	getResourceEntityManager()
OutboundEventProcessor	getSystemOutboundEventProcessor()
protected void	init()
void	initChangeDetectionExecutor()
void	initChangeDetectionManager()
void	initChannelDefinitionProcessors()
void	initCommandExecutors()
void	initCommandInterceptors()
void	initDataManagers()
void	initDbSqlSessionFactory()
protected void	initDbSqlSessionFactoryEntitySettings()
protected void	initDeployers()
void	initEntityManagers()
void	initEventDeployerDependencies()
void	initEventRegistry()
void	initExpressionManager()
void	initInboundChannelModelCacheManager()
void	initInboundEventPayloadExtractorProvider()
void	initInboundEventProcessor()
void	initOutboundEventProcessor()
void	initSchemaManagementCommand()
void	initSchemaManager()
protected void	initServices()
void	initSystemOutboundEventProcessor()
boolean	isEnableEventRegistryChangeDetection()
boolean	isEnableEventRegistryChangeDetectionAfterEngineCreate()
EventRegistryEngineConfiguration	registerInboundEventPayloadExtractor(String channelType, InboundEventPayloadExtractor<?> payloadExtractor)
EventRegistryEngineConfiguration	removeInboundEventPayloadExtractor(String channelType)
EventRegistryEngineConfiguration	setChannelDefinitionCache(DeploymentCache<ChannelDefinitionCacheEntry> channelDefinitionCache)
EventRegistryEngineConfiguration	setChannelDefinitionEntityManager(ChannelDefinitionEntityManager channelDefinitionEntityManager)
EventRegistryEngineConfiguration	setChannelJsonConverter(ChannelJsonConverter channelJsonConverter)
EventRegistryEngineConfiguration	setChannelModelProcessors(Collection<ChannelModelProcessor> channelModelProcessors)
EventRegistryEngineConfiguration	setDefaultInboundEventPayloadExtractor(InboundEventPayloadExtractor<?> defaultInboundEventPayloadExtractor)
EventRegistryEngineConfiguration	setDeploymentDataManager(EventDeploymentDataManager deploymentDataManager)
EventRegistryEngineConfiguration	setDeploymentEntityManager(EventDeploymentEntityManager deploymentEntityManager)
EventRegistryEngineConfiguration	setEnableEventRegistryChangeDetection(boolean enableEventRegistryChangeDetection)
EventRegistryEngineConfiguration	setEnableEventRegistryChangeDetectionAfterEngineCreate(boolean enableEventRegistryChangeDetectionAfterEngineCreate)
EventRegistryEngineConfiguration	setEngineName(String eventRegistryEngineName)
EventRegistryEngineConfiguration	setEventDefinitionCache(DeploymentCache<EventDefinitionCacheEntry> eventDefinitionCache)
EventRegistryEngineConfiguration	setEventDefinitionCacheLimit(int eventDefinitionCacheLimit)
EventRegistryEngineConfiguration	setEventDefinitionDataManager(EventDefinitionDataManager eventDefinitionDataManager)
EventRegistryEngineConfiguration	setEventDefinitionEntityManager(EventDefinitionEntityManager eventDefinitionEntityManager)
EventRegistryEngineConfiguration	setEventDeployer(EventDefinitionDeployer eventDeployer)
EventRegistryEngineConfiguration	setEventJsonConverter(EventJsonConverter eventJsonConverter)
EventRegistryEngineConfiguration	setEventManagementService(EventManagementService eventManagementService)
EventRegistryEngineConfiguration	setEventParseFactory(EventDefinitionParseFactory eventParseFactory)
EventRegistryEngineConfiguration	setEventRegistry(EventRegistry eventRegistry)
EventRegistryEngineConfiguration	setEventRegistryChangeDetectionDelayInMs(long eventRegistryChangeDetectionDelayInMs)
EventRegistryEngineConfiguration	setEventRegistryChangeDetectionExecutor(EventRegistryChangeDetectionExecutor eventRegistryChangeDetectionExecutor)
EventRegistryEngineConfiguration	setEventRegistryChangeDetectionInitialDelayInMs(long eventRegistryChangeDetectionInitialDelayInMs)
EventRegistryEngineConfiguration	setEventRegistryChangeDetectionManager(EventRegistryChangeDetectionManager eventRegistryChangeDetectionManager)
EventRegistryEngineConfiguration	setEventRepositoryService(EventRepositoryService eventRepositoryService)
EventRegistryEngineConfiguration	setExpressionManager(ExpressionManager expressionManager)
EventRegistryEngineConfiguration	setInboundChannelModelCacheManager(InboundChannelModelCacheManager inboundChannelModelCacheManager)
EventRegistryEngineConfiguration	setInboundEventPayloadExtractorsByChannelType(Map<String,InboundEventPayloadExtractor<?>> inboundEventPayloadExtractorsByChannelType)
EventRegistryEngineConfiguration	setInboundEventProcessor(InboundEventProcessor inboundEventProcessor)
EventRegistryEngineConfiguration	setNonMatchingEventConsumer(EventRegistryNonMatchingEventConsumer nonMatchingEventConsumer)
EventRegistryEngineConfiguration	setOutboundEventProcessor(OutboundEventProcessor outboundEventProcessor)
EventRegistryEngineConfiguration	setPostDefaultELResolvers(Collection<ELResolver> postDefaultELResolvers)
EventRegistryEngineConfiguration	setPreBeanELResolvers(Collection<ELResolver> preBeanELResolvers)
EventRegistryEngineConfiguration	setPreDefaultELResolvers(Collection<ELResolver> preDefaultELResolvers)
EventRegistryEngineConfiguration	setResourceDataManager(EventResourceDataManager resourceDataManager)
EventRegistryEngineConfiguration	setResourceEntityManager(EventResourceEntityManager resourceEntityManager)
EventRegistryEngineConfiguration	setSystemOutboundEventProcessor(OutboundEventProcessor systemOutboundEventProcessor)
EventRegistryEngineConfiguration	setTableDataManager(TableDataManager tableDataManager)

Methods inherited from class org.flowable.common.engine.impl.AbstractEngineConfiguration

addAgendaOperationExecutionListener, addConfigurator, addCustomPostCommandInterceptor, addCustomPreCommandInterceptor, addCustomSessionFactory, addEngineConfiguration, addEngineLifecycleListener, addEventRegistryEventConsumer, addServiceConfiguration, addSessionFactory, applyCustomMybatisCustomizations, close, configuratorsAfterInit, configuratorsBeforeInit, defaultInitDbSqlSessionFactoryEntitySettings, getAdditionalDefaultCommandInterceptors, getAdditionalEventDispatchActions, getAgendaOperationExecutionListeners, getAgendaOperationRunner, getAllConfigurators, getBeans, getByteArrayDataManager, getByteArrayEntityManager, getClassLoader, getClock, getCommandContextFactory, getCommandExecutor, getCommandInterceptors, getCommandInvoker, getCommonSchemaManager, getConfigurators, getCustomMybatisInterceptors, getCustomMybatisMappers, getCustomMybatisXMLMappers, getCustomPostCommandInterceptors, getCustomPostDeployers, getCustomPreCommandInterceptors, getCustomPreDeployers, getCustomSessionFactories, getDatabaseCatalog, getDatabaseSchema, getDatabaseSchemaUpdate, getDatabaseTablePrefix, getDatabaseType, getDatabaseWildcardEscapeCharacter, getDataSource, getDataSourceJndiName, getDbSqlSessionFactory, getDefaultCommandConfig, getDefaultCommandInterceptors, getDefaultDatabaseTypeMappings, getDefaultTenantProvider, getDependentEngineMybatisTypeAliasConfigs, getDependentEngineMybatisTypeHandlerConfigs, getDependentEngineMyBatisXmlMappers, getDeployers, getEngineConfigurations, getEngineLifecycleListeners, getEngineSpecificEngineConfigurators, getEventDispatcher, getEventListeners, getEventRegistryConfigurator, getEventRegistryEventConsumers, getIdGenerator, getIdmEngineConfigurator, getJdbcDefaultTransactionIsolationLevel, getJdbcDriver, getJdbcMaxActiveConnections, getJdbcMaxCheckoutTime, getJdbcMaxIdleConnections, getJdbcMaxWaitTime, getJdbcPassword, getJdbcPingConnectionNotUsedFor, getJdbcPingQuery, getJdbcUrl, getJdbcUsername, getLockManager, getLockPollRate, getLoggingListener, getMaxLengthString, getMaxLengthStringVariableType, getMaxNrOfStatementsInBulkInsert, getMybatisMappingFile, getObjectMapper, getPropertyDataManager, getPropertyEntityManager, getResourceAsStream, getSchemaCommandConfig, getSchemaLockWaitTime, getSchemaManagementCmd, getSchemaManager, getServiceConfigurations, getSessionFactories, getSqlSessionFactory, getTableDataManager, getTransactionContextFactory, getTransactionFactory, getTypedEventListeners, getXmlEncoding, initAdditionalEventDispatchActions, initBeans, initClock, initCommandContextFactory, initCommandExecutor, initCommandInvoker, initConfigurators, initCustomMybatisInterceptors, initCustomMybatisMappers, initDatabaseType, initDataSource, initDefaultCommandConfig, initEngineConfigurations, initEventDispatcher, initEventListeners, initIdGenerator, initInterceptorChain, initMybatisConfiguration, initMyBatisLogSqlExecutionTimePlugin, initMybatisTypeHandlers, initObjectMapper, initSchemaCommandConfig, initService, initSessionFactories, initSqlSessionFactory, initTransactionContextFactory, initTransactionFactory, initTypedEventListeners, isAlwaysLookupLatestDefinitionVersion, isBulkInsertEnabled, isDbHistoryUsed, isEnableConfiguratorServiceLoader, isEnableEventDispatcher, isEnableLogSqlExecutionTime, isFallbackToDefaultTenant, isForceCloseMybatisConnectionPool, isJdbcPingEnabled, isLoggingSessionEnabled, isTablePrefixIsSchema, isTransactionsExternallyManaged, isUseClassForNameClassLoading, isUseLockForDatabaseSchemaUpdate, isUsePrefixId, isUsingRelationalDatabase, isUsingSchemaMgmt, parseCustomMybatisXMLMappers, parseDependentEngineMybatisXMLMappers, parseMybatisConfiguration, parseMybatisXmlMapping, pathToEngineDbProperties, setAdditionalEventDispatchActions, setAgendaOperationExecutionListeners, setAgendaOperationRunner, setAlwaysLookupLatestDefinitionVersion, setBeans, setBulkInsertEnabled, setByteArrayDataManager, setByteArrayEntityManager, setClassLoader, setClock, setCommandContextFactory, setCommandExecutor, setCommandInterceptors, setCommandInvoker, setCommonSchemaManager, setConfigurators, setCustomMybatisInterceptors, setCustomMybatisMappers, setCustomMybatisXMLMappers, setCustomPostCommandInterceptors, setCustomPostDeployers, setCustomPreCommandInterceptors, setCustomPreDeployers, setCustomSessionFactories, setDatabaseCatalog, setDatabaseSchema, setDatabaseSchemaUpdate, setDatabaseTablePrefix, setDatabaseType, setDatabaseWildcardEscapeCharacter, setDataSource, setDataSourceJndiName, setDbHistoryUsed, setDbSqlSessionFactory, setDefaultCommandConfig, setDefaultCommandInterceptors, setDefaultTenantProvider, setDefaultTenantValue, setDependentEngineMybatisTypeAliasConfigs, setDependentEngineMybatisTypeHandlerConfigs, setDependentEngineMyBatisXmlMappers, setDeployers, setEnableConfiguratorServiceLoader, setEnableEventDispatcher, setEnableLogSqlExecutionTime, setEngineConfigurations, setEngineLifecycleListeners, setEventDispatcher, setEventListeners, setEventRegistryConfigurator, setEventRegistryEventConsumers, setFallbackToDefaultTenant, setForceCloseMybatisConnectionPool, setIdGenerator, setIdmEngineConfigurator, setJdbcDefaultTransactionIsolationLevel, setJdbcDriver, setJdbcMaxActiveConnections, setJdbcMaxCheckoutTime, setJdbcMaxIdleConnections, setJdbcMaxWaitTime, setJdbcPassword, setJdbcPingConnectionNotUsedFor, setJdbcPingEnabled, setJdbcPingQuery, setJdbcUrl, setJdbcUsername, setLockPollRate, setLoggingListener, setMaxLengthStringVariableType, setMaxNrOfStatementsInBulkInsert, setMybatisMappingFile, setObjectMapper, setPropertyDataManager, setPropertyEntityManager, setSchemaCommandConfig, setSchemaLockWaitTime, setSchemaManagementCmd, setSchemaManager, setServiceConfigurations, setSessionFactories, setSqlSessionFactory, setTablePrefixIsSchema, setTransactionContextFactory, setTransactionFactory, setTransactionsExternallyManaged, setTypedEventListeners, setUseClassForNameClassLoading, setUseLockForDatabaseSchemaUpdate, setUsePrefixId, setUsingRelationalDatabase, setUsingSchemaMgmt, setXmlEncoding

Methods inherited from class java.lang.Object

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

Field Details

DEFAULT_MYBATIS_MAPPING_FILE

public static final String DEFAULT_MYBATIS_MAPPING_FILE

See Also:

• Constant Field Values

LIQUIBASE_CHANGELOG_PREFIX

public static final String LIQUIBASE_CHANGELOG_PREFIX

See Also:

• Constant Field Values

eventRegistryEngineName

protected String eventRegistryEngineName

eventRepositoryService

protected EventRepositoryService eventRepositoryService

eventManagementService

protected EventManagementService eventManagementService

deploymentDataManager

protected EventDeploymentDataManager deploymentDataManager

eventDefinitionDataManager

protected EventDefinitionDataManager eventDefinitionDataManager

channelDefinitionDataManager

protected ChannelDefinitionDataManager channelDefinitionDataManager

resourceDataManager

protected EventResourceDataManager resourceDataManager

deploymentEntityManager

protected EventDeploymentEntityManager deploymentEntityManager

eventDefinitionEntityManager

protected EventDefinitionEntityManager eventDefinitionEntityManager

channelDefinitionEntityManager

protected ChannelDefinitionEntityManager channelDefinitionEntityManager

resourceEntityManager

protected EventResourceEntityManager resourceEntityManager

expressionManager

protected ExpressionManager expressionManager

expressionManagerConfigurers

protected Collection<Consumer<ExpressionManager>> expressionManagerConfigurers

preDefaultELResolvers

protected Collection<ELResolver> preDefaultELResolvers

preBeanELResolvers

protected Collection<ELResolver> preBeanELResolvers

postDefaultELResolvers

protected Collection<ELResolver> postDefaultELResolvers

eventJsonConverter

protected EventJsonConverter eventJsonConverter

channelJsonConverter

protected ChannelJsonConverter channelJsonConverter

eventDeployer

protected EventDefinitionDeployer eventDeployer

eventParseFactory

protected EventDefinitionParseFactory eventParseFactory

channelParseFactory

protected ChannelDefinitionParseFactory channelParseFactory

parsedDeploymentBuilderFactory

protected ParsedDeploymentBuilderFactory parsedDeploymentBuilderFactory

eventDeploymentHelper

protected EventDefinitionDeploymentHelper eventDeploymentHelper

channelDeploymentHelper

protected ChannelDefinitionDeploymentHelper channelDeploymentHelper

cachingAndArtifactsManager

protected CachingAndArtifactsManager cachingAndArtifactsManager

customPreDeployers

protected List<Deployer> customPreDeployers

customPostDeployers

protected List<Deployer> customPostDeployers

deployers

protected List<Deployer> deployers

deploymentManager

protected EventDeploymentManager deploymentManager

inboundChannelModelCacheManager

protected InboundChannelModelCacheManager inboundChannelModelCacheManager

eventDefinitionCacheLimit

protected int eventDefinitionCacheLimit

eventDefinitionCache

protected DeploymentCache<EventDefinitionCacheEntry> eventDefinitionCache

channelDefinitionCache

protected DeploymentCache<ChannelDefinitionCacheEntry> channelDefinitionCache

channelModelProcessors

protected Collection<ChannelModelProcessor> channelModelProcessors

eventRegistry

protected EventRegistry eventRegistry

inboundEventProcessor

protected InboundEventProcessor inboundEventProcessor

outboundEventProcessor

protected OutboundEventProcessor outboundEventProcessor

systemOutboundEventProcessor

protected OutboundEventProcessor systemOutboundEventProcessor

inboundEventPayloadExtractorsByChannelType

protected Map<String,InboundEventPayloadExtractor<?>> inboundEventPayloadExtractorsByChannelType

defaultInboundEventPayloadExtractor

protected InboundEventPayloadExtractor<?> defaultInboundEventPayloadExtractor

enableEventRegistryChangeDetection

protected boolean enableEventRegistryChangeDetection

eventRegistryChangeDetectionInitialDelayInMs

protected long eventRegistryChangeDetectionInitialDelayInMs

eventRegistryChangeDetectionDelayInMs

protected long eventRegistryChangeDetectionDelayInMs

eventRegistryChangeDetectionManager

protected EventRegistryChangeDetectionManager eventRegistryChangeDetectionManager

eventRegistryChangeDetectionExecutor

protected EventRegistryChangeDetectionExecutor eventRegistryChangeDetectionExecutor

nonMatchingEventConsumer

protected EventRegistryNonMatchingEventConsumer nonMatchingEventConsumer

enableEventRegistryChangeDetectionAfterEngineCreate

protected boolean enableEventRegistryChangeDetectionAfterEngineCreate

Constructor Details

EventRegistryEngineConfiguration

public EventRegistryEngineConfiguration()

Method Details

createEventRegistryEngineConfigurationFromResourceDefault

public static EventRegistryEngineConfiguration createEventRegistryEngineConfigurationFromResourceDefault()

createEventRegistryEngineConfigurationFromResource

public static EventRegistryEngineConfiguration createEventRegistryEngineConfigurationFromResource(String resource)

createEventRegistryEngineConfigurationFromResource

public static EventRegistryEngineConfiguration createEventRegistryEngineConfigurationFromResource(String resource,
 String beanName)

createEventRegistryEngineConfigurationFromInputStream

public static EventRegistryEngineConfiguration createEventRegistryEngineConfigurationFromInputStream(InputStream inputStream)

createEventRegistryEngineConfigurationFromInputStream

public static EventRegistryEngineConfiguration createEventRegistryEngineConfigurationFromInputStream(InputStream inputStream,
 String beanName)

createStandaloneEventRegistryEngineConfiguration

public static EventRegistryEngineConfiguration createStandaloneEventRegistryEngineConfiguration()

createStandaloneInMemEventRegistryEngineConfiguration

public static EventRegistryEngineConfiguration createStandaloneInMemEventRegistryEngineConfiguration()

buildEventRegistryEngine

public EventRegistryEngine buildEventRegistryEngine()

init

protected void init()

initServices

protected void initServices()

initExpressionManager

public void initExpressionManager()

initDataManagers

public void initDataManagers()

Overrides:

initDataManagers in class AbstractEngineConfiguration

initEntityManagers

public void initEntityManagers()

Overrides:

initEntityManagers in class AbstractEngineConfiguration

initSchemaManager

public void initSchemaManager()

Overrides:

initSchemaManager in class AbstractEngineConfiguration

initSchemaManagementCommand

public void initSchemaManagementCommand()

initDbSqlSessionFactory

public void initDbSqlSessionFactory()

Overrides:

initDbSqlSessionFactory in class AbstractEngineConfiguration

initDbSqlSessionFactoryEntitySettings

protected void initDbSqlSessionFactoryEntitySettings()

Specified by:

initDbSqlSessionFactoryEntitySettings in class AbstractEngineConfiguration

createDbSqlSessionFactory

public DbSqlSessionFactory createDbSqlSessionFactory()

Overrides:

createDbSqlSessionFactory in class AbstractEngineConfiguration

initCommandExecutors

public void initCommandExecutors()

Overrides:

initCommandExecutors in class AbstractEngineConfiguration

initCommandInterceptors

public void initCommandInterceptors()

Overrides:

initCommandInterceptors in class AbstractEngineConfiguration

getEngineCfgKey

public String getEngineCfgKey()

Specified by:

getEngineCfgKey in class AbstractEngineConfiguration

getEngineScopeType

public String getEngineScopeType()

Specified by:

getEngineScopeType in class AbstractEngineConfiguration

createTransactionInterceptor

public CommandInterceptor createTransactionInterceptor()

Specified by:

createTransactionInterceptor in class AbstractEngineConfiguration

initDeployers

protected void initDeployers()

getDefaultDeployers

public Collection<? extends Deployer> getDefaultDeployers()

initEventDeployerDependencies

public void initEventDeployerDependencies()

initInboundChannelModelCacheManager

public void initInboundChannelModelCacheManager()

initEventRegistry

public void initEventRegistry()

initInboundEventProcessor

public void initInboundEventProcessor()

initOutboundEventProcessor

public void initOutboundEventProcessor()

initSystemOutboundEventProcessor

public void initSystemOutboundEventProcessor()

initInboundEventPayloadExtractorProvider

public void initInboundEventPayloadExtractorProvider()

initChannelDefinitionProcessors

public void initChannelDefinitionProcessors()

initChangeDetectionManager

public void initChangeDetectionManager()

initChangeDetectionExecutor

public void initChangeDetectionExecutor()

getMyBatisXmlConfigurationStream

public InputStream getMyBatisXmlConfigurationStream()

Specified by:

getMyBatisXmlConfigurationStream in class AbstractEngineConfiguration

getEngineName

public String getEngineName()

Specified by:

getEngineName in class AbstractEngineConfiguration

setEngineName

public EventRegistryEngineConfiguration setEngineName(String eventRegistryEngineName)

getEventRepositoryService

public EventRepositoryService getEventRepositoryService()

Specified by:

getEventRepositoryService in interface EventRegistryConfigurationApi

setEventRepositoryService

public EventRegistryEngineConfiguration setEventRepositoryService(EventRepositoryService eventRepositoryService)

getEventManagementService

public EventManagementService getEventManagementService()

Specified by:

getEventManagementService in interface EventRegistryConfigurationApi

setEventManagementService

public EventRegistryEngineConfiguration setEventManagementService(EventManagementService eventManagementService)

getDeploymentManager

public EventDeploymentManager getDeploymentManager()

getFormEngineConfiguration

public EventRegistryEngineConfiguration getFormEngineConfiguration()

getEventDeployer

public EventDefinitionDeployer getEventDeployer()

setEventDeployer

public EventRegistryEngineConfiguration setEventDeployer(EventDefinitionDeployer eventDeployer)

getEventParseFactory

public EventDefinitionParseFactory getEventParseFactory()

setEventParseFactory

public EventRegistryEngineConfiguration setEventParseFactory(EventDefinitionParseFactory eventParseFactory)

getEventRegistry

public EventRegistry getEventRegistry()

Specified by:

getEventRegistry in interface EventRegistryConfigurationApi

setEventRegistry

public EventRegistryEngineConfiguration setEventRegistry(EventRegistry eventRegistry)

getInboundEventProcessor

public InboundEventProcessor getInboundEventProcessor()

setInboundEventProcessor

public EventRegistryEngineConfiguration setInboundEventProcessor(InboundEventProcessor inboundEventProcessor)

getOutboundEventProcessor

public OutboundEventProcessor getOutboundEventProcessor()

setOutboundEventProcessor

public EventRegistryEngineConfiguration setOutboundEventProcessor(OutboundEventProcessor outboundEventProcessor)

getSystemOutboundEventProcessor

public OutboundEventProcessor getSystemOutboundEventProcessor()

setSystemOutboundEventProcessor

public EventRegistryEngineConfiguration setSystemOutboundEventProcessor(OutboundEventProcessor systemOutboundEventProcessor)

getInboundEventPayloadExtractorsByChannelType

public Map<String,InboundEventPayloadExtractor<?>> getInboundEventPayloadExtractorsByChannelType()

setInboundEventPayloadExtractorsByChannelType

public EventRegistryEngineConfiguration setInboundEventPayloadExtractorsByChannelType(Map<String,InboundEventPayloadExtractor<?>> inboundEventPayloadExtractorsByChannelType)

registerInboundEventPayloadExtractor

public EventRegistryEngineConfiguration registerInboundEventPayloadExtractor(String channelType,
 InboundEventPayloadExtractor<?> payloadExtractor)

removeInboundEventPayloadExtractor

public EventRegistryEngineConfiguration removeInboundEventPayloadExtractor(String channelType)

getDefaultInboundEventPayloadExtractor

public InboundEventPayloadExtractor<?> getDefaultInboundEventPayloadExtractor()

setDefaultInboundEventPayloadExtractor

public EventRegistryEngineConfiguration setDefaultInboundEventPayloadExtractor(InboundEventPayloadExtractor<?> defaultInboundEventPayloadExtractor)

isEnableEventRegistryChangeDetection

public boolean isEnableEventRegistryChangeDetection()

setEnableEventRegistryChangeDetection

public EventRegistryEngineConfiguration setEnableEventRegistryChangeDetection(boolean enableEventRegistryChangeDetection)

getEventRegistryChangeDetectionInitialDelayInMs

public long getEventRegistryChangeDetectionInitialDelayInMs()

setEventRegistryChangeDetectionInitialDelayInMs

public EventRegistryEngineConfiguration setEventRegistryChangeDetectionInitialDelayInMs(long eventRegistryChangeDetectionInitialDelayInMs)

getEventRegistryChangeDetectionDelayInMs

public long getEventRegistryChangeDetectionDelayInMs()

setEventRegistryChangeDetectionDelayInMs

public EventRegistryEngineConfiguration setEventRegistryChangeDetectionDelayInMs(long eventRegistryChangeDetectionDelayInMs)

getEventRegistryChangeDetectionManager

public EventRegistryChangeDetectionManager getEventRegistryChangeDetectionManager()

setEventRegistryChangeDetectionManager

public EventRegistryEngineConfiguration setEventRegistryChangeDetectionManager(EventRegistryChangeDetectionManager eventRegistryChangeDetectionManager)

getEventRegistryChangeDetectionExecutor

public EventRegistryChangeDetectionExecutor getEventRegistryChangeDetectionExecutor()

setEventRegistryChangeDetectionExecutor

public EventRegistryEngineConfiguration setEventRegistryChangeDetectionExecutor(EventRegistryChangeDetectionExecutor eventRegistryChangeDetectionExecutor)

getNonMatchingEventConsumer

public EventRegistryNonMatchingEventConsumer getNonMatchingEventConsumer()

setNonMatchingEventConsumer

public EventRegistryEngineConfiguration setNonMatchingEventConsumer(EventRegistryNonMatchingEventConsumer nonMatchingEventConsumer)

getEventDefinitionCacheLimit

public int getEventDefinitionCacheLimit()

setEventDefinitionCacheLimit

public EventRegistryEngineConfiguration setEventDefinitionCacheLimit(int eventDefinitionCacheLimit)

getEventDefinitionCache

public DeploymentCache<EventDefinitionCacheEntry> getEventDefinitionCache()

setEventDefinitionCache

public EventRegistryEngineConfiguration setEventDefinitionCache(DeploymentCache<EventDefinitionCacheEntry> eventDefinitionCache)

getChannelDefinitionCache

public DeploymentCache<ChannelDefinitionCacheEntry> getChannelDefinitionCache()

setChannelDefinitionCache

public EventRegistryEngineConfiguration setChannelDefinitionCache(DeploymentCache<ChannelDefinitionCacheEntry> channelDefinitionCache)

getInboundChannelModelCacheManager

public InboundChannelModelCacheManager getInboundChannelModelCacheManager()

setInboundChannelModelCacheManager

public EventRegistryEngineConfiguration setInboundChannelModelCacheManager(InboundChannelModelCacheManager inboundChannelModelCacheManager)

getChannelModelProcessors

public Collection<ChannelModelProcessor> getChannelModelProcessors()

addChannelModelProcessor

public void addChannelModelProcessor(ChannelModelProcessor channelModelProcessor)

setChannelModelProcessors

public EventRegistryEngineConfiguration setChannelModelProcessors(Collection<ChannelModelProcessor> channelModelProcessors)

getDeploymentDataManager

public EventDeploymentDataManager getDeploymentDataManager()

setDeploymentDataManager

public EventRegistryEngineConfiguration setDeploymentDataManager(EventDeploymentDataManager deploymentDataManager)

getEventDefinitionDataManager

public EventDefinitionDataManager getEventDefinitionDataManager()

setEventDefinitionDataManager

public EventRegistryEngineConfiguration setEventDefinitionDataManager(EventDefinitionDataManager eventDefinitionDataManager)

getResourceDataManager

public EventResourceDataManager getResourceDataManager()

setResourceDataManager

public EventRegistryEngineConfiguration setResourceDataManager(EventResourceDataManager resourceDataManager)

getDeploymentEntityManager

public EventDeploymentEntityManager getDeploymentEntityManager()

setDeploymentEntityManager

public EventRegistryEngineConfiguration setDeploymentEntityManager(EventDeploymentEntityManager deploymentEntityManager)

getEventDefinitionEntityManager

public EventDefinitionEntityManager getEventDefinitionEntityManager()

setEventDefinitionEntityManager

public EventRegistryEngineConfiguration setEventDefinitionEntityManager(EventDefinitionEntityManager eventDefinitionEntityManager)

getChannelDefinitionEntityManager

public ChannelDefinitionEntityManager getChannelDefinitionEntityManager()

setChannelDefinitionEntityManager

public EventRegistryEngineConfiguration setChannelDefinitionEntityManager(ChannelDefinitionEntityManager channelDefinitionEntityManager)

getResourceEntityManager

public EventResourceEntityManager getResourceEntityManager()

setResourceEntityManager

public EventRegistryEngineConfiguration setResourceEntityManager(EventResourceEntityManager resourceEntityManager)

setTableDataManager

public EventRegistryEngineConfiguration setTableDataManager(TableDataManager tableDataManager)

Overrides:

setTableDataManager in class AbstractEngineConfiguration

getExpressionManager

public ExpressionManager getExpressionManager()

Specified by:

getExpressionManager in interface HasExpressionManagerEngineConfiguration

setExpressionManager

public EventRegistryEngineConfiguration setExpressionManager(ExpressionManager expressionManager)

Specified by:

setExpressionManager in interface HasExpressionManagerEngineConfiguration

getExpressionManagerConfigurers

public Collection<Consumer<ExpressionManager>> getExpressionManagerConfigurers()

addExpressionManagerConfigurer

public AbstractEngineConfiguration addExpressionManagerConfigurer(Consumer<ExpressionManager> configurer)

Specified by:

addExpressionManagerConfigurer in interface HasExpressionManagerEngineConfiguration

getPreDefaultELResolvers

public Collection<ELResolver> getPreDefaultELResolvers()

setPreDefaultELResolvers

public EventRegistryEngineConfiguration setPreDefaultELResolvers(Collection<ELResolver> preDefaultELResolvers)

addPreDefaultELResolver

public EventRegistryEngineConfiguration addPreDefaultELResolver(ELResolver elResolver)

getPreBeanELResolvers

public Collection<ELResolver> getPreBeanELResolvers()

setPreBeanELResolvers

public EventRegistryEngineConfiguration setPreBeanELResolvers(Collection<ELResolver> preBeanELResolvers)

addPreBeanELResolver

public EventRegistryEngineConfiguration addPreBeanELResolver(ELResolver elResolver)

getPostDefaultELResolvers

public Collection<ELResolver> getPostDefaultELResolvers()

setPostDefaultELResolvers

public EventRegistryEngineConfiguration setPostDefaultELResolvers(Collection<ELResolver> postDefaultELResolvers)

addPostDefaultELResolver

public EventRegistryEngineConfiguration addPostDefaultELResolver(ELResolver elResolver)

getEventJsonConverter

public EventJsonConverter getEventJsonConverter()

setEventJsonConverter

public EventRegistryEngineConfiguration setEventJsonConverter(EventJsonConverter eventJsonConverter)

getChannelJsonConverter

public ChannelJsonConverter getChannelJsonConverter()

setChannelJsonConverter

public EventRegistryEngineConfiguration setChannelJsonConverter(ChannelJsonConverter channelJsonConverter)

isEnableEventRegistryChangeDetectionAfterEngineCreate

public boolean isEnableEventRegistryChangeDetectionAfterEngineCreate()

setEnableEventRegistryChangeDetectionAfterEngineCreate

public EventRegistryEngineConfiguration setEnableEventRegistryChangeDetectionAfterEngineCreate(boolean enableEventRegistryChangeDetectionAfterEngineCreate)