@groovy.transform.CompileStatic class ExecutionContextFactoryImpl extends java.lang.Object implements ExecutionContextFactory
Modifiers | Name | Description |
---|---|---|
static class |
ExecutionContextFactoryImpl.ComponentInfo |
|
static class |
ExecutionContextFactoryImpl.DeferredHitInfoFlush |
|
static class |
ExecutionContextFactoryImpl.WebappInfo |
Modifiers | Name | Description |
---|---|---|
java.lang.ThreadLocal<ExecutionContextImpl> |
activeContext |
|
java.util.Map<java.lang.Long, ExecutionContextImpl> |
activeContextMap |
|
protected java.util.Map<java.lang.String, ArtifactStatsInfo> |
artifactStatsInfoByType |
|
java.util.Map<ArtifactType, java.lang.Boolean> |
artifactTypeAuthzEnabled |
|
java.util.Map<ArtifactType, java.lang.Boolean> |
artifactTypeTarpitEnabled |
|
CacheFacadeImpl |
cacheFacade |
|
protected java.util.LinkedHashMap<java.lang.String, ComponentInfo> |
componentInfoMap |
|
protected MNode |
confXmlRoot |
|
ElasticFacadeImpl |
elasticFacade |
|
protected java.util.Set<java.lang.String> |
entitiesToSkipHitCount |
|
EntityFacadeImpl |
entityFacade |
|
protected groovy.lang.GroovyClassLoader |
groovyClassLoader |
|
protected boolean |
groovyCompileCacheToDisk |
|
protected org.codehaus.groovy.control.CompilerConfiguration |
groovyCompilerConf |
|
protected long |
hitBinLengthMillis |
|
java.lang.String |
initStartHex |
|
long |
initStartTime |
|
protected org.apache.shiro.mgt.SecurityManager |
internalSecurityManager |
The SecurityManager for Apache Shiro |
protected javax.websocket.server.ServerContainer |
internalServerContainer |
The WebSocket ServerContainer, if found in 'javax.websocket.server.ServerContainer' ServletContext attribute |
protected javax.servlet.ServletContext |
internalServletContext |
The ServletContext, if Moqui was initialized in a webapp (generally through MoquiContextListener) |
protected static boolean |
isTraceEnabled |
|
protected java.net.InetAddress |
localhostAddress |
|
protected java.util.ArrayList<LogEventSubscriber> |
logEventSubscribers |
|
protected static org.slf4j.Logger |
logger |
|
LoggerFacadeImpl |
loggerFacade |
|
protected MClassLoader |
moquiClassLoader |
|
protected java.lang.String |
moquiVersion |
|
protected java.util.List<NotificationMessageListener> |
registeredNotificationMessageListeners |
|
ResourceFacadeImpl |
resourceFacade |
|
protected java.lang.String |
runtimeConfPath |
|
protected java.lang.String |
runtimePath |
|
CustomScheduledExecutor |
scheduledExecutor |
An executor for the scheduled job runner |
java.util.ArrayList<ScheduledRunnableInfo> |
scheduledRunnableList |
|
ScreenFacadeImpl |
screenFacade |
|
protected MNode |
serverStatsNode |
|
ServiceFacadeImpl |
serviceFacade |
|
protected java.lang.String |
skipStatsCond |
|
protected java.util.LinkedHashMap<java.lang.String, ToolFactory> |
toolFactoryMap |
|
TransactionFacadeImpl |
transactionFacade |
|
protected java.util.Map |
versionMap |
|
protected java.util.Map<java.lang.String, WebappInfo> |
webappInfoMap |
|
ThreadPoolExecutor |
workerPool |
The main worker pool for services, running async closures and runnables, etc |
Type | Name and description |
---|---|
ConcurrentLinkedQueue<ArtifactHitInfo> |
deferredHitInfoQueue |
Constructor and description |
---|
ExecutionContextFactoryImpl
() This constructor gets runtime directory and conf file location from a properties file on the classpath so that it can initialize on its own. |
ExecutionContextFactoryImpl
(java.lang.String runtimePathParm, java.lang.String confPathParm) This constructor takes the runtime directory path and conf file path directly. |
Type Params | Return Type | Name and description |
---|---|---|
|
protected void |
addComponent(ExecutionContextFactoryImpl.ComponentInfo componentInfo) |
|
protected void |
addComponentDir(java.lang.String location) |
|
protected void |
advanceArtifactHitBin(ExecutionContextImpl eci, ArtifactStatsInfo statsInfo, long startTime, long hitBinLengthMillis) |
|
boolean |
checkEmptyDb() Called from MoquiContextListener.contextInitialized after ECFI init |
|
protected void |
checkSortDependentComponents() |
|
java.lang.Class |
compileGroovy(java.lang.String script, java.lang.String className) |
|
void |
countArtifactHit(ArtifactExecutionInfo.ArtifactType artifactTypeEnum, java.lang.String artifactSubType, java.lang.String artifactName, java.util.Map<java.lang.String, java.lang.Object> parameters, long startTime, double runningTimeMillis, java.lang.Long outputSize) |
|
void |
destroy() |
|
void |
destroyActiveExecutionContext() |
|
void |
finalize() |
|
MNode |
getArtifactExecutionNode(java.lang.String artifactTypeEnumId) |
|
protected MNode |
getArtifactStatsNode(java.lang.String artifactType, java.lang.String artifactSubType) |
|
CacheFacade |
getCache() |
|
java.lang.ClassLoader |
getClassLoader() |
|
java.util.LinkedHashMap<java.lang.String, java.lang.String> |
getComponentBaseLocations() |
|
java.util.List<java.util.Map<java.lang.String, java.lang.Object>> |
getComponentInfoList() |
|
MNode |
getConfXmlRoot() |
|
org.apache.shiro.authc.credential.CredentialsMatcher |
getCredentialsMatcher(java.lang.String hashType, boolean isBase64) |
|
ExecutionContextImpl |
getEci() |
|
ElasticFacade |
getElastic() |
|
EntityFacade |
getEntity() |
|
ExecutionContext |
getExecutionContext() |
|
groovy.lang.GroovyClassLoader |
getGroovyClassLoader() |
|
L10nFacade |
getL10n() |
|
java.net.InetAddress |
getLocalhostAddress() |
|
java.util.List<LogEventSubscriber> |
getLogEventSubscribers() |
|
LoggerFacade |
getLogger() |
|
float |
getLoginKeyExpireHours() |
|
java.lang.String |
getLoginKeyHashType() |
|
java.lang.String |
getMoquiVersion() |
|
NotificationWebSocketListener |
getNotificationWebSocketListener() |
|
java.lang.String |
getPasswordHashType() |
|
static java.lang.String |
getRandomSalt() |
|
ResourceFacade |
getResource() |
|
protected static ResourceReference |
getResourceReference(java.lang.String location) |
|
java.lang.String |
getRuntimePath() |
|
ScreenFacade |
getScreen() |
|
org.apache.shiro.mgt.SecurityManager |
getSecurityManager() |
|
javax.websocket.server.ServerContainer |
getServerContainer() |
|
MNode |
getServerStatsNode() |
|
ServiceFacade |
getService() |
|
javax.servlet.ServletContext |
getServletContext() |
|
java.lang.String |
getSimpleHash(java.lang.String source, java.lang.String salt) |
|
java.lang.String |
getSimpleHash(java.lang.String source, java.lang.String salt, java.lang.String hashType, boolean isBase64) |
|
java.util.Map<java.lang.String, java.lang.Object> |
getStatusMap() |
|
java.util.Map<java.lang.String, java.lang.Object> |
getStatusMap(boolean includeSensitive) |
<V> |
V |
getTool(java.lang.String toolName, java.lang.Class<V> instanceClass, java.lang.Object[] parameters) |
<V> |
ToolFactory<V> |
getToolFactory(java.lang.String toolName) |
|
TransactionFacade |
getTransaction() |
|
java.util.Map |
getVersionMap() |
|
ExecutionContextFactoryImpl.WebappInfo |
getWebappInfo(java.lang.String webappName) |
|
MNode |
getWebappNode(java.lang.String webappName) |
|
protected MNode |
initBaseConfig(MNode runtimeConfXmlRoot) |
|
protected void |
initComponents(MNode baseConfigNode) |
|
protected MNode |
initConfig(MNode baseConfigNode, MNode runtimeConfXmlRoot) |
|
void |
initServletContext(javax.servlet.ServletContext sc) |
|
boolean |
isDestroyed() |
|
protected ExecutionContextFactoryImpl.WebappInfo |
makeWebappInfo(java.lang.String webappName) |
|
protected static void |
mergeConfigComponentNodes(MNode baseNode, MNode overrideNode) |
|
protected static void |
mergeConfigNodes(MNode baseNode, MNode overrideNode) |
|
protected static void |
mergeWebappActions(MNode baseWebappNode, MNode overrideWebappNode, java.lang.String childNodeName) |
|
protected static void |
mergeWebappChildNodes(MNode baseNode, MNode overrideNode) |
|
void |
notifyNotificationMessageListeners(NotificationMessageImpl nmi) This is called when message received from topic (possibly distributed) |
|
protected void |
reconfigureLog4j() |
|
void |
registerLogEventSubscriber(LogEventSubscriber subscriber) |
|
void |
registerNotificationMessageListener(NotificationMessageListener nml) |
|
void |
scheduleAtFixedRate(java.lang.Runnable command, long initialDelaySeconds, long periodSeconds) |
|
void |
scheduledReInit() |
|
void |
sendNotificationMessageToTopic(NotificationMessageImpl nmi) Called by NotificationMessageImpl.send(), send to topic (possibly distributed) |
|
protected static java.lang.String |
stripVersionFromName(java.lang.String name) |
|
java.lang.String |
toString() |
|
void |
triggerDynamicReInit() Trigger ECF destroy and re-init in another thread, after short wait |
|
void |
useExecutionContextInThread(ExecutionContextImpl eci) Using an EC in multiple threads is dangerous as much of the ECI is not designed to be thread safe. |
|
boolean |
waitWorkerPoolEmpty(int retryLimit) |
|
void |
warmCache() |
Methods inherited from class | Name |
---|---|
class java.lang.Object |
java.lang.Object#wait(long), java.lang.Object#wait(long, int), java.lang.Object#wait(), java.lang.Object#equals(java.lang.Object), java.lang.Object#toString(), java.lang.Object#hashCode(), java.lang.Object#getClass(), java.lang.Object#notify(), java.lang.Object#notifyAll() |
The SecurityManager for Apache Shiro
The WebSocket ServerContainer, if found in 'javax.websocket.server.ServerContainer' ServletContext attribute
The ServletContext, if Moqui was initialized in a webapp (generally through MoquiContextListener)
An executor for the scheduled job runner
The main worker pool for services, running async closures and runnables, etc
This constructor gets runtime directory and conf file location from a properties file on the classpath so that it can initialize on its own. This is the constructor to be used by the ServiceLoader in the Moqui.java file, or by init methods in a servlet or context filter or OSGi component or Spring component or whatever.
This constructor takes the runtime directory path and conf file path directly.
Called from MoquiContextListener.contextInitialized after ECFI init
This is called when message received from topic (possibly distributed)
Called by NotificationMessageImpl.send(), send to topic (possibly distributed)
Trigger ECF destroy and re-init in another thread, after short wait
Using an EC in multiple threads is dangerous as much of the ECI is not designed to be thread safe.
Groovy Documentation