public class DynamicModule extends Object implements org.mule.api.lifecycle.Disposable
Modifier and Type | Class and Description |
---|---|
static interface |
DynamicModule.Listener<T>
Encapsulate logic dealing with event received from a
Source . |
Modifier and Type | Field and Description |
---|---|
protected static int |
DEFAULT_RETRY_MAX |
Constructor and Description |
---|
DynamicModule(Module module) |
DynamicModule(Module module,
Map<String,Object> overriddenParameters) |
DynamicModule(Module module,
Map<String,Object> overriddenParameters,
int retryMax) |
Modifier and Type | Method and Description |
---|---|
protected Map<String,Object> |
allParameters(List<Module.Parameter> defaultParameters,
Map<String,Object> overriddenParameters)
Aggregate all parameters: default and overridden ones.
|
protected Registrar |
createAndCacheRegistrar(org.mule.api.source.MessageSource messageSource) |
void |
dispose()
Cleanup all internal resources:
* call
Invoker.dispose() for all cached Invoker
* call Registrar.stop() for all cached Registrar
* call Disposable.dispose() |
protected void |
ensureNoMissingParameters(List<Module.Parameter> defaultParameters,
Map<String,Object> overriddenParameters) |
protected Module.Processor |
findProcessor(String processorName) |
protected Module.Source |
findSource(String sourceName) |
protected Invoker |
getInvoker(org.mule.api.processor.MessageProcessor messageProcessor) |
protected org.mule.api.MuleContext |
getMuleContext() |
protected Registrar |
getRegistrar(org.mule.api.source.MessageSource messageSource) |
protected <T> T |
invoke(org.mule.api.processor.MessageProcessor messageProcessor,
Map<String,Object> parameters) |
<T> T |
invoke(String processorName,
Map<String,Object> overriddenParameters)
Invoke `processorName` with provided `overriddenParameters`.
|
void |
subscribe(String sourceName,
Map<String,Object> overriddenParameters,
DynamicModule.Listener listener)
Subscribe
DynamicModule.Listener to `sourceName` Source with `overriddenParameters`. |
void |
unsubscribe(String sourceName)
Unsubscribe
DynamicModule.Listener previously registered to `sourceName` Source . |
protected void |
validateParameterTypeCorrectness(List<Module.Parameter> defaultParameters,
Map<String,Object> overriddenParameters) |
protected static final int DEFAULT_RETRY_MAX
public DynamicModule(Module module)
protected final org.mule.api.MuleContext getMuleContext()
protected final void validateParameterTypeCorrectness(List<Module.Parameter> defaultParameters, Map<String,Object> overriddenParameters)
protected final void ensureNoMissingParameters(List<Module.Parameter> defaultParameters, Map<String,Object> overriddenParameters)
protected final Map<String,Object> allParameters(List<Module.Parameter> defaultParameters, Map<String,Object> overriddenParameters)
protected final Module.Processor findProcessor(String processorName)
processorName
- Module.Processor
extracted from Module$Processor
with specified name, null otherwiseprotected final Invoker getInvoker(org.mule.api.processor.MessageProcessor messageProcessor) throws org.mule.api.lifecycle.InitialisationException, org.mule.api.MuleException
messageProcessor
- Invoker
for MessageProcessor
. Creates it if needed.org.mule.api.lifecycle.InitialisationException
org.mule.api.MuleException
#createInvoker(org.mule.api.processor.MessageProcessor)
public final <T> T invoke(String processorName, Map<String,Object> overriddenParameters) throws org.mule.api.lifecycle.InitialisationException, org.mule.api.MuleException
T
- processorName
- overriddenParameters
- org.mule.api.lifecycle.InitialisationException
org.mule.api.MuleException
protected <T> T invoke(org.mule.api.processor.MessageProcessor messageProcessor, Map<String,Object> parameters) throws org.mule.api.lifecycle.InitialisationException, org.mule.api.MuleException
org.mule.api.lifecycle.InitialisationException
org.mule.api.MuleException
protected final Module.Source findSource(String sourceName)
sourceName
- Module.Source
extracted from Module$Source
with specified name, null otherwiseprotected final Registrar getRegistrar(org.mule.api.source.MessageSource messageSource) throws org.mule.api.lifecycle.InitialisationException, org.mule.api.MuleException
messageSource
- Invoker
for MessageProcessor
.org.mule.api.lifecycle.InitialisationException
org.mule.api.MuleException
#createInvoker(org.mule.api.processor.MessageProcessor)
protected final Registrar createAndCacheRegistrar(org.mule.api.source.MessageSource messageSource)
messageSource
- Regsitrar
public final void subscribe(String sourceName, Map<String,Object> overriddenParameters, DynamicModule.Listener listener) throws org.mule.api.lifecycle.InitialisationException, org.mule.api.MuleException
DynamicModule.Listener
to `sourceName` Source
with `overriddenParameters`.sourceName
- overriddenParameters
- listener
- org.mule.api.lifecycle.InitialisationException
org.mule.api.MuleException
public final void unsubscribe(String sourceName) throws org.mule.api.MuleException
DynamicModule.Listener
previously registered to `sourceName` Source
.sourceName
- org.mule.api.lifecycle.InitialisationException
org.mule.api.MuleException
public final void dispose()
Invoker.dispose()
for all cached Invoker
* call Registrar.stop()
for all cached Registrar
* call Disposable.dispose()
dispose
in interface org.mule.api.lifecycle.Disposable
Copyright © 2010–2015 MuleSoft, Inc.. All rights reserved.