@groovy.transform.CompileStatic class ServiceFacadeImpl extends java.lang.Object implements ServiceFacade
Modifiers | Name | Description |
---|---|---|
protected ConcurrentMap<java.lang.String, java.util.List<ServiceCallback>> |
callbackRegistry |
|
protected ExecutorService |
distributedExecutorService |
Distributed ExecutorService for async services, etc |
ExecutionContextFactoryImpl |
ecfi |
|
protected java.util.List<EmailEcaRule> |
emecaRuleList |
|
protected java.util.concurrent.locks.ReentrantLock |
locationLoadLock |
|
protected static org.slf4j.Logger |
logger |
|
RestApi |
restApi |
|
protected java.util.Map<java.lang.String, java.util.ArrayList<ServiceEcaRule>> |
secaRulesByServiceName |
|
protected Cache<java.lang.String, ServiceDefinition> |
serviceLocationCache |
|
protected java.util.Map<java.lang.String, ServiceRunner> |
serviceRunners |
Constructor and description |
---|
ServiceFacadeImpl
(ExecutionContextFactoryImpl ecfi) |
Type Params | Return Type | Name and description |
---|---|---|
|
ServiceCallAsync |
async() |
|
java.util.Map<java.lang.String, java.lang.Object> |
callJsonRpc(java.lang.String location, java.lang.String method, java.util.Map<java.lang.String, java.lang.Object> parameters) |
|
void |
callRegisteredCallbacks(java.lang.String serviceName, java.util.Map<java.lang.String, java.lang.Object> context, java.util.Map<java.lang.String, java.lang.Object> result) |
|
void |
callRegisteredCallbacksThrowable(java.lang.String serviceName, java.util.Map<java.lang.String, java.lang.Object> context, java.lang.Throwable t) |
|
void |
destroy() |
|
protected MNode |
findServiceNode(java.lang.String path, java.lang.String verb, java.lang.String noun) |
|
protected MNode |
findServiceNode(ResourceReference serviceComponentRr, java.lang.String verb, java.lang.String noun) |
|
protected void |
findServicesInDir(java.lang.String baseLocation, ResourceReference dir, java.util.Set<java.lang.String> sns) |
|
protected void |
findServicesInFile(java.lang.String baseLocation, ResourceReference entryRr, java.util.Set<java.lang.String> sns) |
|
java.util.List<java.util.Map> |
getAllServiceInfo(int levels) |
|
ScheduledJobRunner |
getJobRunner() |
|
java.util.Set<java.lang.String> |
getKnownServiceNames() |
|
int |
getSecaRuleCount() |
|
ServiceDefinition |
getServiceDefinition(java.lang.String serviceName) |
|
ServiceRunner |
getServiceRunner(java.lang.String type) |
|
boolean |
isEntityAutoPattern(java.lang.String serviceName) |
|
boolean |
isEntityAutoPattern(java.lang.String path, java.lang.String verb, java.lang.String noun) |
|
boolean |
isServiceDefined(java.lang.String serviceName) |
|
ServiceCallJob |
job(java.lang.String jobName) |
|
protected void |
loadEmecaRulesAll() |
|
protected void |
loadEmecaRulesFile(ResourceReference rr) |
|
void |
loadSecaRulesAll() |
|
protected int |
loadSecaRulesFile(ResourceReference rr, java.util.HashMap<java.lang.String, ServiceEcaRule> ruleByIdMap, java.util.LinkedList<ServiceEcaRule> ruleNoIdList) |
|
protected static java.lang.String |
makeCacheKey(java.lang.String path, java.lang.String verb, java.lang.String noun) |
|
protected ServiceDefinition |
makeServiceDefinition(java.lang.String origServiceName, java.lang.String path, java.lang.String verb, java.lang.String noun) |
|
void |
postFacadeInit() |
|
void |
registerCallback(java.lang.String serviceName, ServiceCallback serviceCallback) |
|
void |
registerTxSecaRules(java.lang.String serviceName, java.util.Map<java.lang.String, java.lang.Object> parameters, java.util.Map<java.lang.String, java.lang.Object> results, java.util.ArrayList<ServiceEcaRule> lst) |
|
RestClient |
rest() |
|
void |
runEmecaRules(javax.mail.internet.MimeMessage message, java.lang.String emailServerId) |
|
static void |
runSecaRules(java.lang.String serviceName, java.util.Map<java.lang.String, java.lang.Object> parameters, java.util.Map<java.lang.String, java.lang.Object> results, java.lang.String when, java.util.ArrayList<ServiceEcaRule> lst, ExecutionContextImpl eci) |
|
java.util.ArrayList<ServiceEcaRule> |
secaRules(java.lang.String serviceName) |
|
void |
setDistributedExecutorService(ExecutorService executorService) |
|
ServiceCallSpecial |
special() |
|
ServiceCallSync |
sync() |
|
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() |
Distributed ExecutorService for async services, etc