Modifier and Type | Class and Description |
---|---|
class |
DefaultMuleEvent
DefaultMuleEvent represents any data event occurring in the Mule environment. |
class |
VoidMuleEvent
A
VoidMuleEvent represents a void return from a MessageProcessor such as a ONE_WAY
OutboundEndpoint . |
Modifier and Type | Method and Description |
---|---|
static MuleEvent |
DefaultMuleEvent.copy(MuleEvent event)
This method does a complete deep copy of the event.
|
static MuleEvent |
OptimizedRequestContext.criticalSetEvent(MuleEvent event)
Deprecated.
Set an event for out-of-scope thread access.
|
static MuleEvent |
RequestContext.getEvent()
Deprecated.
|
protected static MuleEvent |
RequestContext.internalSetEvent(MuleEvent event)
Deprecated.
|
protected static MuleEvent |
RequestContext.newEvent(MuleEvent event,
boolean safe)
Deprecated.
|
static MuleEvent |
RequestContext.setEvent(MuleEvent event)
Deprecated.
Set an event for out-of-scope thread access.
|
static MuleEvent |
OptimizedRequestContext.unsafeSetEvent(MuleEvent event)
Deprecated.
Set an event for out-of-scope thread access.
|
Modifier and Type | Method and Description |
---|---|
void |
DefaultMessageCollection.addMessages(MuleEvent[] events) |
protected void |
DefaultMuleMessage.applyAllTransformers(MuleEvent event,
List<? extends Transformer> transformers) |
void |
DefaultMuleMessage.applyTransformers(MuleEvent event,
List<? extends Transformer> transformers)
Will apply a list of transformers to the payload of the message.
|
void |
DefaultMuleMessage.applyTransformers(MuleEvent event,
List<? extends Transformer> transformers,
Class<?> outputType) |
void |
DefaultMuleMessage.applyTransformers(MuleEvent event,
Transformer... transformers)
Will apply a list of transformers to the payload of the message.
|
static MuleEvent |
DefaultMuleEvent.copy(MuleEvent event)
This method does a complete deep copy of the event.
|
static MuleEvent |
OptimizedRequestContext.criticalSetEvent(MuleEvent event)
Deprecated.
Set an event for out-of-scope thread access.
|
protected static MuleEvent |
RequestContext.internalSetEvent(MuleEvent event)
Deprecated.
|
protected static MuleEvent |
RequestContext.newEvent(MuleEvent event,
boolean safe)
Deprecated.
|
static MuleEvent |
RequestContext.setEvent(MuleEvent event)
Deprecated.
Set an event for out-of-scope thread access.
|
static MuleEvent |
OptimizedRequestContext.unsafeSetEvent(MuleEvent event)
Deprecated.
Set an event for out-of-scope thread access.
|
Constructor and Description |
---|
DefaultMuleEvent(MuleEvent rewriteEvent,
FlowConstruct flowConstruct) |
DefaultMuleEvent(MuleEvent rewriteEvent,
FlowConstruct flowConstruct,
ReplyToHandler replyToHandler,
Object replyToDestination) |
DefaultMuleEvent(MuleMessage message,
MuleEvent rewriteEvent)
A helper constructor used to rewrite an event payload
|
DefaultMuleEvent(MuleMessage message,
MuleEvent rewriteEvent,
boolean synchronus) |
DefaultMuleEvent(MuleMessage message,
MuleEvent rewriteEvent,
boolean synchronus,
boolean shareFlowVars) |
DefaultMuleEvent(MuleMessage message,
MuleEvent rewriteEvent,
FlowConstruct flowConstruct,
MuleSession session,
boolean synchronous) |
DefaultMuleEvent(MuleMessage message,
MuleEvent rewriteEvent,
FlowConstruct flowConstruct,
MuleSession session,
boolean synchronous,
boolean shareFlowVars) |
DefaultMuleEvent(MuleMessage message,
MuleEvent rewriteEvent,
FlowConstruct flowConstruct,
MuleSession session,
boolean synchronous,
ReplyToHandler replyToHandler,
Object replyToDestination,
boolean shareFlowVars) |
DefaultMuleEvent(MuleMessage message,
MuleEvent rewriteEvent,
MuleSession session)
A helper constructor used to rewrite an event payload
|
DefaultMuleEventContext(MuleEvent event) |
Modifier and Type | Field and Description |
---|---|
protected MuleEvent |
MessagingException.event
The MuleEvent being processed when the error occurred
|
protected MuleEvent |
MessagingException.processedEvent |
Modifier and Type | Method and Description |
---|---|
MuleEvent |
MessagingException.getEvent() |
Modifier and Type | Method and Description |
---|---|
boolean |
Acceptor.accept(MuleEvent event) |
void |
MuleMessageCollection.addMessages(MuleEvent[] events) |
void |
MuleMessage.applyTransformers(MuleEvent event,
List<? extends Transformer> transformers)
Will apply a list of transformers to the payload of the message.
|
void |
MuleMessage.applyTransformers(MuleEvent event,
List<? extends Transformer> transformers,
Class<?> outputType)
Will apply a list of transformers to the payload of the message.
|
void |
MuleMessage.applyTransformers(MuleEvent event,
Transformer... transformers)
Will apply a list of transformers to the payload of the message.
|
protected void |
MessagingException.extractMuleMessage(MuleEvent event) |
Serializable |
MuleEventKeyGenerator.generateKey(MuleEvent event)
Generates a key for an event.
|
void |
MessagingException.setProcessedEvent(MuleEvent processedEvent)
Sets the event that should be processed once this exception is caught
|
Constructor and Description |
---|
MessagingException(Message message,
MuleEvent event) |
MessagingException(Message message,
MuleEvent event,
MessageProcessor failingMessageProcessor) |
MessagingException(Message message,
MuleEvent event,
Throwable cause) |
MessagingException(Message message,
MuleEvent event,
Throwable cause,
MessageProcessor failingMessageProcessor) |
MessagingException(MuleEvent event,
Throwable cause) |
MessagingException(MuleEvent event,
Throwable cause,
MessageProcessor failingMessageProcessor) |
Modifier and Type | Method and Description |
---|---|
MuleEvent |
CachingStrategy.process(MuleEvent request,
MessageProcessor messageProcessor)
Processes a
MuleEvent using a caching schema. |
Modifier and Type | Method and Description |
---|---|
MuleEvent |
CachingStrategy.process(MuleEvent request,
MessageProcessor messageProcessor)
Processes a
MuleEvent using a caching schema. |
Modifier and Type | Method and Description |
---|---|
MuleEvent |
SourceCallback.processEvent(MuleEvent event)
Dispatch the current event to the flow
|
Modifier and Type | Method and Description |
---|---|
MuleEvent |
SourceCallback.processEvent(MuleEvent event)
Dispatch the current event to the flow
|
Modifier and Type | Method and Description |
---|---|
MuleEvent |
InterfaceBinding.process(MuleEvent event)
This method is responsible for routing the Message via the MuleSession.
|
Modifier and Type | Method and Description |
---|---|
Object |
LifecycleAdapter.invoke(MuleEvent message) |
MuleEvent |
InterfaceBinding.process(MuleEvent event)
This method is responsible for routing the Message via the MuleSession.
|
Modifier and Type | Method and Description |
---|---|
T |
ProcessTemplate.execute(ProcessCallback<T,O> callback,
MessageProcessor messageProcessor,
MuleEvent event) |
T |
ProcessInterceptor.execute(ProcessCallback<T,O> callback,
O under,
MessageProcessor messageProcessor,
MuleEvent event) |
void |
NestedProcessorChain.setEvent(MuleEvent value)
Sets event
|
Constructor and Description |
---|
NestedProcessorChain(MuleEvent event,
MuleContext muleContext,
MessageProcessor chain) |
Modifier and Type | Method and Description |
---|---|
<T> T |
ExpressionLanguage.evaluate(String expression,
MuleEvent event)
Execute the expression returning the result.
|
<T> T |
ExpressionLanguage.evaluate(String expression,
MuleEvent event,
Map<String,Object> vars)
Execute the expression returning the result.
|
Modifier and Type | Method and Description |
---|---|
MuleEvent |
MessagingExceptionHandler.handleException(Exception exception,
MuleEvent event)
Take some action when a messaging exception has occurred (i.e., there was a message in play when the exception occurred).
|
Modifier and Type | Method and Description |
---|---|
MuleEvent |
MessagingExceptionHandler.handleException(Exception exception,
MuleEvent event)
Take some action when a messaging exception has occurred (i.e., there was a message in play when the exception occurred).
|
Constructor and Description |
---|
MessageRedeliveredException(String messageId,
int redeliveryCount,
int maxRedelivery,
InboundEndpoint endpoint,
MuleEvent event) |
MessageRedeliveredException(String messageId,
int redeliveryCount,
int maxRedelivery,
InboundEndpoint endpoint,
MuleEvent event,
Message message) |
Modifier and Type | Method and Description |
---|---|
void |
ExpressionManager.enrich(String expression,
MuleEvent message,
Object object) |
Object |
ExpressionManager.evaluate(String expression,
MuleEvent event) |
Object |
ExpressionManager.evaluate(String expression,
MuleEvent event,
boolean failIfNull) |
boolean |
ExpressionManager.evaluateBoolean(String expression,
MuleEvent event) |
boolean |
ExpressionManager.evaluateBoolean(String expression,
MuleEvent event,
boolean nullReturnsTrue,
boolean nonBooleanReturnsTrue) |
String |
ExpressionManager.parse(String expression,
MuleEvent event) |
String |
ExpressionManager.parse(String expression,
MuleEvent event,
boolean failIfNull) |
Modifier and Type | Method and Description |
---|---|
MuleEvent |
Interceptor.process(MuleEvent event)
Invoked when the component should be called.
|
Modifier and Type | Method and Description |
---|---|
MuleEvent |
Interceptor.process(MuleEvent event)
Invoked when the component should be called.
|
Modifier and Type | Method and Description |
---|---|
MuleEvent |
MessageProcessor.process(MuleEvent event)
Invokes the MessageProcessor.
|
MuleEvent |
LoggerMessageProcessor.process(MuleEvent event) |
Modifier and Type | Method and Description |
---|---|
protected void |
LoggerMessageProcessor.log(MuleEvent event) |
MuleEvent |
MessageProcessor.process(MuleEvent event)
Invokes the MessageProcessor.
|
MuleEvent |
LoggerMessageProcessor.process(MuleEvent event) |
Modifier and Type | Method and Description |
---|---|
MuleEvent |
RouterResultsHandler.aggregateResults(List<MuleEvent> results,
MuleEvent previous,
MuleContext muleContext) |
MuleEvent |
AggregationContext.getOriginalEvent() |
MuleEvent |
OutboundRouterCatchAllStrategy.process(MuleEvent event)
Deprecated.
This method will be invoked when an event is received or being sent where the criteria of the router(s) do not
match the current event.
|
Modifier and Type | Method and Description |
---|---|
List<MuleEvent> |
AggregationContext.collectEventsWithExceptions()
Returns all the
MuleEvent s which messages have a not null
ExceptionPayload and a not null
ExceptionPayload.getException() . |
List<MuleEvent> |
AggregationContext.collectEventsWithoutExceptions()
The exact opposite to
AggregationContext.collectEventsWithExceptions() Returns all the
MuleEvent s which messages have a null
ExceptionPayload or a null
ExceptionPayload.getException() . |
List<MuleEvent> |
AggregationContext.getEvents() |
Modifier and Type | Method and Description |
---|---|
MuleEvent |
RouterResultsHandler.aggregateResults(List<MuleEvent> results,
MuleEvent previous,
MuleContext muleContext) |
MuleEvent |
OutboundRouterCatchAllStrategy.process(MuleEvent event)
Deprecated.
This method will be invoked when an event is received or being sent where the criteria of the router(s) do not
match the current event.
|
Modifier and Type | Method and Description |
---|---|
MuleEvent |
RouterResultsHandler.aggregateResults(List<MuleEvent> results,
MuleEvent previous,
MuleContext muleContext) |
Constructor and Description |
---|
AggregationContext(MuleEvent originalEvent,
List<MuleEvent> events)
Creates a new instance
|
Constructor and Description |
---|
FilterUnacceptedException(Message message,
MuleEvent event) |
FilterUnacceptedException(Message message,
MuleEvent event,
Filter filter) |
FilterUnacceptedException(Message message,
MuleEvent event,
Filter filter,
Throwable cause) |
FilterUnacceptedException(Message message,
MuleEvent event,
Throwable cause) |
FilterUnacceptedException(MuleEvent event,
Filter filter,
Throwable cause) |
Modifier and Type | Method and Description |
---|---|
MuleEvent |
Authentication.getEvent() |
Modifier and Type | Method and Description |
---|---|
void |
AuthenticationFilter.authenticate(MuleEvent event) |
void |
SecurityFilter.doFilter(MuleEvent event) |
Object |
CredentialsAccessor.getCredentials(MuleEvent event) |
void |
CredentialsAccessor.setCredentials(MuleEvent event,
Object credentials) |
void |
Authentication.setEvent(MuleEvent event) |
Modifier and Type | Method and Description |
---|---|
MuleEvent |
Service.sendEvent(MuleEvent event)
Deprecated.
|
Modifier and Type | Method and Description |
---|---|
void |
Service.dispatchEvent(MuleEvent event)
Deprecated.
|
MuleEvent |
Service.sendEvent(MuleEvent event)
Deprecated.
|
Constructor and Description |
---|
FailedToQueueEventException(Message message,
MuleEvent event) |
FailedToQueueEventException(Message message,
MuleEvent event,
Throwable cause) |
Modifier and Type | Method and Description |
---|---|
Object |
MessageTransformer.transform(Object src,
MuleEvent event)
Thransforms the supplied data and returns the result
|
Object |
MessageTransformer.transform(Object src,
String encoding,
MuleEvent event)
Thransforms the supplied data and returns the result
|
Constructor and Description |
---|
TransformerMessagingException(Message message,
MuleEvent event,
Transformer transformer) |
TransformerMessagingException(Message message,
MuleEvent event,
Transformer transformer,
Throwable cause) |
TransformerMessagingException(MuleEvent event,
Transformer transformer,
Throwable cause) |
Modifier and Type | Method and Description |
---|---|
MuleEvent |
MessageReceiver.routeMessage(MuleMessage message) |
MuleEvent |
MessageReceiver.routeMessage(MuleMessage message,
Transaction trans) |
MuleEvent |
MessageReceiver.routeMessage(MuleMessage message,
Transaction trans,
OutputStream outputStream) |
Modifier and Type | Method and Description |
---|---|
void |
MessageDispatching.dispatch(MuleEvent event)
Dispatches an event from the endpoint to the external system
|
OutputStream |
Connector.getOutputStream(OutboundEndpoint endpoint,
MuleEvent event)
Will get the output stream for this type of transport.
|
void |
ReplyToHandler.processReplyTo(MuleEvent event,
MuleMessage returnMessage,
Object replyTo) |
MuleMessage |
MessageDispatching.send(MuleEvent event)
Sends an event from the endpoint to the external system
|
void |
OutputHandler.write(MuleEvent event,
OutputStream out)
Write the event payload to the stream.
|
Constructor and Description |
---|
DispatchException(Message message,
MuleEvent event,
MessageProcessor target) |
DispatchException(Message message,
MuleEvent event,
MessageProcessor target,
Throwable cause) |
DispatchException(MuleEvent event,
MessageProcessor target) |
DispatchException(MuleEvent event,
MessageProcessor target,
Throwable cause) |
Modifier and Type | Method and Description |
---|---|
protected MuleEvent |
DefaultLocalMuleClient.createMuleEvent(MuleMessage message,
OutboundEndpoint endpoint) |
protected MuleEvent |
DefaultLocalMuleClient.createRequestResponseMuleEvent(MuleMessage message) |
Modifier and Type | Method and Description |
---|---|
protected MuleMessage |
DefaultLocalMuleClient.returnMessage(MuleEvent event) |
Modifier and Type | Method and Description |
---|---|
protected MuleEvent |
AbstractComponent.createResultEvent(MuleEvent event,
Object result) |
MuleEvent |
DefaultInterfaceBinding.process(MuleEvent event) |
MuleEvent |
AbstractComponent.process(MuleEvent event) |
Modifier and Type | Method and Description |
---|---|
protected MuleEvent |
AbstractComponent.createResultEvent(MuleEvent event,
Object result) |
protected Object |
AbstractJavaComponent.doInvoke(MuleEvent event) |
protected abstract Object |
AbstractComponent.doInvoke(MuleEvent event) |
Object |
DefaultComponentLifecycleAdapter.invoke(MuleEvent event) |
protected Object |
SimpleCallableJavaComponent.invokeComponentInstance(MuleEvent event) |
protected Object |
AbstractJavaComponent.invokeComponentInstance(MuleEvent event) |
MuleEvent |
DefaultInterfaceBinding.process(MuleEvent event) |
MuleEvent |
AbstractComponent.process(MuleEvent event) |
Constructor and Description |
---|
ComponentException(Message message,
MuleEvent muleMessage,
Component component) |
ComponentException(Message message,
MuleEvent event,
Component component,
Throwable cause) |
ComponentException(MuleEvent message,
Component component,
Throwable cause) |
Modifier and Type | Method and Description |
---|---|
protected Object |
PassThroughComponent.doInvoke(MuleEvent event)
Deprecated.
|
Modifier and Type | Method and Description |
---|---|
MuleEvent |
ContentBasedRouter.route(MuleEvent theEvent)
Deprecated.
|
Modifier and Type | Method and Description |
---|---|
MuleEvent |
ContentBasedRouter.route(MuleEvent theEvent)
Deprecated.
|
Modifier and Type | Method and Description |
---|---|
MuleEvent |
AggregationStrategyDefinitionParser.AggregationStrategyDelegate.aggregate(AggregationContext context) |
Modifier and Type | Method and Description |
---|---|
protected MuleEvent |
AbstractPipeline.ProcessIfPipelineStartedMessageProcessor.handleUnaccepted(MuleEvent event) |
MuleEvent |
Flow.process(MuleEvent event) |
MuleEvent |
DynamicPipelineMessageProcessor.process(MuleEvent event) |
Modifier and Type | Method and Description |
---|---|
protected boolean |
AbstractPipeline.ProcessIfPipelineStartedMessageProcessor.accept(MuleEvent event) |
protected MuleEvent |
AbstractPipeline.ProcessIfPipelineStartedMessageProcessor.handleUnaccepted(MuleEvent event) |
MuleEvent |
Flow.process(MuleEvent event) |
MuleEvent |
DynamicPipelineMessageProcessor.process(MuleEvent event) |
Modifier and Type | Method and Description |
---|---|
MuleEvent |
FlowConstructStatisticsMessageProcessor.process(MuleEvent event) |
Modifier and Type | Method and Description |
---|---|
MuleEvent |
FlowConstructStatisticsMessageProcessor.process(MuleEvent event) |
Modifier and Type | Method and Description |
---|---|
MuleEvent |
MessageProcessorNotification.getSource() |
Constructor and Description |
---|
AsyncMessageNotification(FlowConstruct flowConstruct,
MuleEvent event,
MessageProcessor messageProcessor,
int action) |
AsyncMessageNotification(FlowConstruct flowConstruct,
MuleEvent event,
MessageProcessor messageProcessor,
int action,
MessagingException exception) |
MessageProcessorNotification(FlowConstruct flowConstruct,
MuleEvent event,
MessageProcessor processor,
MessagingException exceptionThrown,
int action) |
PipelineMessageNotification(Pipeline pipeline,
MuleEvent event,
int action) |
PipelineMessageNotification(Pipeline pipeline,
MuleEvent event,
int action,
MessagingException exception) |
Modifier and Type | Method and Description |
---|---|
protected abstract MuleEvent |
DevkitBasedMessageProcessor.doProcess(MuleEvent event)
Implementors of this class need to implement this method in order to perform
actual processing
|
MuleEvent |
DevkitBasedMessageProcessor.process(MuleEvent event)
This final process implementation shields actual processing into abstract
method
DevkitBasedMessageProcessor.doProcess(org.mule.api.MuleEvent) . |
Modifier and Type | Method and Description |
---|---|
protected abstract MuleEvent |
DevkitBasedMessageProcessor.doProcess(MuleEvent event)
Implementors of this class need to implement this method in order to perform
actual processing
|
protected Object |
ExpressionEvaluatorSupport.evaluateAndTransform(MuleContext muleContext,
MuleEvent event,
Type expectedType,
String expectedMimeType,
Object source) |
protected Object |
DevkitBasedMessageProcessor.findOrCreate(Class<?> moduleClass,
boolean shouldAutoCreate,
MuleEvent muleEvent)
Obtains the expression manager from the Mule context and initialises the
connector.
|
protected String |
ExpressionEvaluatorSupport.getAccessTokenId(MuleEvent event,
MessageProcessor processor,
OAuth2Manager<?> oauthManager) |
void |
DevkitBasedMessageProcessor.overwritePayload(MuleEvent event,
Object resultPayload)
Overwrites the event payload with the specified one
|
MuleEvent |
DevkitBasedMessageProcessor.process(MuleEvent event)
This final process implementation shields actual processing into abstract
method
DevkitBasedMessageProcessor.doProcess(org.mule.api.MuleEvent) . |
protected Object |
ExpressionEvaluatorSupport.transform(MuleContext muleContext,
MuleEvent event,
Type expectedType,
String expectedMimeType,
Object source) |
Modifier and Type | Method and Description |
---|---|
MuleEvent |
ExpressionLanguageComponent.process(MuleEvent event) |
Modifier and Type | Method and Description |
---|---|
MuleEvent |
ExpressionLanguageComponent.process(MuleEvent event) |
Modifier and Type | Method and Description |
---|---|
protected org.mule.mvel2.integration.VariableResolverFactory |
MVELExpressionLanguage.createVariableVariableResolverFactory(MuleEvent event) |
<T> T |
MVELExpressionLanguage.evaluate(String expression,
MuleEvent event) |
<T> T |
MVELExpressionLanguage.evaluate(String expression,
MuleEvent event,
Map<String,Object> vars) |
Constructor and Description |
---|
EventVariableResolverFactory(org.mule.mvel2.ParserConfiguration parserConfiguration,
MuleContext muleContext,
MuleEvent event) |
EventVariableResolverFactory(org.mule.mvel2.ParserConfiguration parserConfiguration,
MuleContext muleContext,
MuleEvent event,
org.mule.mvel2.integration.VariableResolverFactory next)
Convenience constructor to allow for more concise creation of VariableResolverFactory chains without
and performance overhead incurred by using a builder.
|
VariableVariableResolverFactory(org.mule.mvel2.ParserConfiguration parserConfiguration,
MuleContext muleContext,
MuleEvent event) |
Modifier and Type | Method and Description |
---|---|
MuleEvent |
DynamicURIOutboundEndpoint.process(MuleEvent event) |
MuleEvent |
DynamicOutboundEndpoint.process(MuleEvent event) |
MuleEvent |
DefaultOutboundEndpoint.process(MuleEvent event) |
Modifier and Type | Method and Description |
---|---|
String |
DynamicURIBuilder.build(MuleEvent event) |
OutboundEndpoint |
DynamicOutboundEndpoint.getStaticEndpoint(MuleEvent event) |
MuleEvent |
DynamicURIOutboundEndpoint.process(MuleEvent event) |
MuleEvent |
DynamicOutboundEndpoint.process(MuleEvent event) |
MuleEvent |
DefaultOutboundEndpoint.process(MuleEvent event) |
Modifier and Type | Method and Description |
---|---|
MuleEvent |
InboundNotificationMessageProcessor.process(MuleEvent event) |
MuleEvent |
InboundLoggingMessageProcessor.process(MuleEvent event) |
MuleEvent |
InboundExceptionDetailsMessageProcessor.process(MuleEvent event) |
MuleEvent |
InboundEndpointPropertyMessageProcessor.process(MuleEvent event) |
MuleEvent |
InboundEndpointMimeTypeCheckingMessageProcessor.process(MuleEvent event) |
Modifier and Type | Method and Description |
---|---|
MuleEvent |
InboundNotificationMessageProcessor.process(MuleEvent event) |
MuleEvent |
InboundLoggingMessageProcessor.process(MuleEvent event) |
MuleEvent |
InboundExceptionDetailsMessageProcessor.process(MuleEvent event) |
MuleEvent |
InboundEndpointPropertyMessageProcessor.process(MuleEvent event) |
MuleEvent |
InboundEndpointMimeTypeCheckingMessageProcessor.process(MuleEvent event) |
Modifier and Type | Method and Description |
---|---|
MuleEvent |
OutboundTxRollbackMessageProcessor.process(MuleEvent event) |
MuleEvent |
OutboundSessionHandlerMessageProcessor.process(MuleEvent event) |
MuleEvent |
OutboundRootMessageIdPropertyMessageProcessor.process(MuleEvent event) |
MuleEvent |
OutboundResponsePropertiesMessageProcessor.process(MuleEvent event) |
MuleEvent |
OutboundNotificationMessageProcessor.process(MuleEvent event) |
MuleEvent |
OutboundLoggingMessageProcessor.process(MuleEvent event) |
MuleEvent |
OutboundEventTimeoutMessageProcessor.process(MuleEvent event) |
MuleEvent |
OutboundEndpointPropertyMessageProcessor.process(MuleEvent event) |
MuleEvent |
OutboundEndpointMimeTypeCheckingMessageProcessor.process(MuleEvent event) |
Modifier and Type | Method and Description |
---|---|
EndpointMessageNotification |
OutboundNotificationMessageProcessor.createBeginNotification(MuleEvent event) |
MuleEvent |
OutboundTxRollbackMessageProcessor.process(MuleEvent event) |
MuleEvent |
OutboundSessionHandlerMessageProcessor.process(MuleEvent event) |
MuleEvent |
OutboundRootMessageIdPropertyMessageProcessor.process(MuleEvent event) |
MuleEvent |
OutboundResponsePropertiesMessageProcessor.process(MuleEvent event) |
MuleEvent |
OutboundNotificationMessageProcessor.process(MuleEvent event) |
MuleEvent |
OutboundLoggingMessageProcessor.process(MuleEvent event) |
MuleEvent |
OutboundEventTimeoutMessageProcessor.process(MuleEvent event) |
MuleEvent |
OutboundEndpointPropertyMessageProcessor.process(MuleEvent event) |
MuleEvent |
OutboundEndpointMimeTypeCheckingMessageProcessor.process(MuleEvent event) |
Modifier and Type | Method and Description |
---|---|
MuleEvent |
MessageEnricher.process(MuleEvent event) |
Modifier and Type | Method and Description |
---|---|
MuleEvent |
MessageEnricher.process(MuleEvent event) |
Modifier and Type | Method and Description |
---|---|
protected MuleEvent |
TemplateMessagingExceptionStrategy.afterRouting(Exception exception,
MuleEvent event) |
protected MuleEvent |
CatchMessagingExceptionStrategy.afterRouting(Exception exception,
MuleEvent event) |
protected MuleEvent |
TemplateMessagingExceptionStrategy.beforeRouting(Exception exception,
MuleEvent event) |
protected MuleEvent |
RollbackMessagingExceptionStrategy.beforeRouting(Exception exception,
MuleEvent event) |
protected MuleEvent |
CatchMessagingExceptionStrategy.beforeRouting(Exception exception,
MuleEvent event) |
MuleEvent |
TemplateMessagingExceptionStrategy.handleException(Exception exception,
MuleEvent event) |
MuleEvent |
MessagingExceptionStrategyAcceptorDelegate.handleException(Exception exception,
MuleEvent event) |
MuleEvent |
MessagingExceptionHandlerToSystemAdapter.handleException(Exception exception,
MuleEvent event) |
MuleEvent |
ChoiceMessagingExceptionStrategy.handleException(Exception exception,
MuleEvent event) |
MuleEvent |
AbstractMessagingExceptionStrategy.handleException(Exception ex,
MuleEvent event) |
MuleEvent |
RedeliveryExceeded.process(MuleEvent event) |
protected MuleEvent |
TemplateMessagingExceptionStrategy.route(MuleEvent event,
Exception t) |
protected MuleEvent |
RollbackMessagingExceptionStrategy.route(MuleEvent event,
Exception t) |
Modifier and Type | Method and Description |
---|---|
boolean |
TemplateMessagingExceptionStrategy.accept(MuleEvent event) |
boolean |
MessagingExceptionStrategyAcceptorDelegate.accept(MuleEvent event) |
boolean |
ChoiceMessagingExceptionStrategy.accept(MuleEvent event) |
protected boolean |
TemplateMessagingExceptionStrategy.acceptsEvent(MuleEvent event)
Determines if the exception strategy should process or not a message inside a choice exception strategy.
|
protected boolean |
RollbackMessagingExceptionStrategy.acceptsEvent(MuleEvent event)
Always accept MessageRedeliveryException exceptions if this rollback exception strategy handles redelivery.
|
protected MuleEvent |
TemplateMessagingExceptionStrategy.afterRouting(Exception exception,
MuleEvent event) |
protected MuleEvent |
CatchMessagingExceptionStrategy.afterRouting(Exception exception,
MuleEvent event) |
protected MuleEvent |
TemplateMessagingExceptionStrategy.beforeRouting(Exception exception,
MuleEvent event) |
protected MuleEvent |
RollbackMessagingExceptionStrategy.beforeRouting(Exception exception,
MuleEvent event) |
protected MuleEvent |
CatchMessagingExceptionStrategy.beforeRouting(Exception exception,
MuleEvent event) |
protected void |
AbstractMessagingExceptionStrategy.doHandleException(Exception ex,
MuleEvent event) |
MuleEvent |
TemplateMessagingExceptionStrategy.handleException(Exception exception,
MuleEvent event) |
MuleEvent |
MessagingExceptionStrategyAcceptorDelegate.handleException(Exception exception,
MuleEvent event) |
MuleEvent |
MessagingExceptionHandlerToSystemAdapter.handleException(Exception exception,
MuleEvent event) |
MuleEvent |
ChoiceMessagingExceptionStrategy.handleException(Exception exception,
MuleEvent event) |
MuleEvent |
AbstractMessagingExceptionStrategy.handleException(Exception ex,
MuleEvent event) |
protected void |
AbstractExceptionListener.logFatal(MuleEvent event,
Throwable t)
Logs a fatal error message to the logging system.
|
protected void |
TemplateMessagingExceptionStrategy.nullifyExceptionPayloadIfRequired(MuleEvent event) |
protected void |
CatchMessagingExceptionStrategy.nullifyExceptionPayloadIfRequired(MuleEvent event) |
MuleEvent |
RedeliveryExceeded.process(MuleEvent event) |
protected void |
TemplateMessagingExceptionStrategy.processReplyTo(MuleEvent event,
Exception e) |
protected void |
RollbackMessagingExceptionStrategy.processReplyTo(MuleEvent event,
Exception e) |
protected MuleEvent |
TemplateMessagingExceptionStrategy.route(MuleEvent event,
Exception t) |
protected MuleEvent |
RollbackMessagingExceptionStrategy.route(MuleEvent event,
Exception t) |
protected void |
AbstractExceptionListener.routeException(MuleEvent event,
MessageProcessor target,
Throwable t)
Deprecated.
|
protected void |
AbstractExceptionListener.routeException(MuleEvent event,
Throwable t)
Routes the current exception to an error endpoint such as a Dead Letter Queue
(jms) This method is only invoked if there is a MuleMessage available to
dispatch.
|
Modifier and Type | Method and Description |
---|---|
MuleEvent |
FlowProcessingPhaseTemplate.afterRouteEvent(MuleEvent muleEvent)
Post processing of the routed
MuleEvent |
MuleEvent |
FlowProcessingPhaseTemplate.beforeRouteEvent(MuleEvent muleEvent)
Pre processing of the
MuleEvent to route |
MuleEvent |
TransactionalErrorHandlingExecutionTemplate.execute(ExecutionCallback<MuleEvent> executionCallback) |
MuleEvent |
ErrorHandlingExecutionTemplate.execute(ExecutionCallback<MuleEvent> executionCallback) |
MuleEvent |
MessageProcessorExecutionTemplate.execute(MessageProcessor messageProcessor,
MuleEvent event) |
MuleEvent |
MessageProcessorExecutionInterceptor.execute(MessageProcessor messageProcessor,
MuleEvent event) |
MuleEvent |
ExceptionToMessagingExceptionExecutionInterceptor.execute(MessageProcessor messageProcessor,
MuleEvent event) |
MuleEvent |
ThrottlingPhaseTemplate.getMuleEvent() |
MuleEvent |
FlowProcessingPhaseTemplate.getMuleEvent() |
MuleEvent |
AsyncResponseFlowProcessingPhaseTemplate.getMuleEvent() |
MuleEvent |
FlowProcessingPhaseTemplate.routeEvent(MuleEvent muleEvent)
Routes the
MuleEvent through the processors chain |
MuleEvent |
AsyncResponseFlowProcessingPhaseTemplate.routeEvent(MuleEvent muleEvent)
Routes the
MuleEvent through the processors chain |
Modifier and Type | Method and Description |
---|---|
MuleEvent |
FlowProcessingPhaseTemplate.afterRouteEvent(MuleEvent muleEvent)
Post processing of the routed
MuleEvent |
void |
FlowProcessingPhaseTemplate.afterSuccessfulProcessingFlow(MuleEvent muleEvent)
Call after successfully processing the message through the flow
This method will always be called when the flow execution was successful.
|
MuleEvent |
FlowProcessingPhaseTemplate.beforeRouteEvent(MuleEvent muleEvent)
Pre processing of the
MuleEvent to route |
MuleEvent |
MessageProcessorExecutionTemplate.execute(MessageProcessor messageProcessor,
MuleEvent event) |
MuleEvent |
MessageProcessorExecutionInterceptor.execute(MessageProcessor messageProcessor,
MuleEvent event) |
MuleEvent |
ExceptionToMessagingExceptionExecutionInterceptor.execute(MessageProcessor messageProcessor,
MuleEvent event) |
void |
ResponseCompletionCallback.responseSentWithFailure(Exception e,
MuleEvent event)
Notifies that the response writing failed
|
MuleEvent |
FlowProcessingPhaseTemplate.routeEvent(MuleEvent muleEvent)
Routes the
MuleEvent through the processors chain |
MuleEvent |
AsyncResponseFlowProcessingPhaseTemplate.routeEvent(MuleEvent muleEvent)
Routes the
MuleEvent through the processors chain |
void |
RequestResponseFlowProcessingPhaseTemplate.sendResponseToClient(MuleEvent muleEvent)
Template method to send a response after processing the message.
|
void |
AsyncResponseFlowProcessingPhaseTemplate.sendResponseToClient(MuleEvent muleEvent,
ResponseCompletionCallback responseCompletionCallback)
Template method to send a response after processing the message.
|
Modifier and Type | Method and Description |
---|---|
MuleEvent |
TransactionalErrorHandlingExecutionTemplate.execute(ExecutionCallback<MuleEvent> executionCallback) |
MuleEvent |
ErrorHandlingExecutionTemplate.execute(ExecutionCallback<MuleEvent> executionCallback) |
Constructor and Description |
---|
ResponseDispatchException(Message message,
MuleEvent event) |
ResponseDispatchException(Message message,
MuleEvent event,
Throwable cause) |
ResponseDispatchException(MuleEvent event,
Throwable cause) |
Modifier and Type | Method and Description |
---|---|
void |
DefaultExpressionManager.enrich(String expression,
MuleEvent event,
Object object) |
Object |
DefaultExpressionManager.evaluate(String expression,
MuleEvent event) |
Object |
DefaultExpressionManager.evaluate(String expression,
MuleEvent event,
boolean failIfNull)
Evaluates the given expression.
|
boolean |
DefaultExpressionManager.evaluateBoolean(String expression,
MuleEvent event) |
boolean |
DefaultExpressionManager.evaluateBoolean(String expression,
MuleEvent event,
boolean nullReturnsTrue,
boolean nonBooleanReturnsTrue) |
String |
DefaultExpressionManager.parse(String expression,
MuleEvent event) |
String |
DefaultExpressionManager.parse(String expression,
MuleEvent event,
boolean failIfNull) |
Modifier and Type | Method and Description |
---|---|
MuleEvent |
ProcessingTimeInterceptor.after(MuleEvent event) |
MuleEvent |
LoggingInterceptor.after(MuleEvent event) |
abstract MuleEvent |
AbstractEnvelopeInterceptor.after(MuleEvent event)
This method is invoked after the event has been processed, unless an exception was thrown
|
MuleEvent |
ProcessingTimeInterceptor.before(MuleEvent event) |
MuleEvent |
LoggingInterceptor.before(MuleEvent event) |
abstract MuleEvent |
AbstractEnvelopeInterceptor.before(MuleEvent event)
This method is invoked before the event is processed
|
MuleEvent |
ProcessingTimeInterceptor.last(MuleEvent event,
ProcessingTime time,
long startTime,
boolean exceptionWasThrown) |
MuleEvent |
LoggingInterceptor.last(MuleEvent event,
ProcessingTime time,
long startTime,
boolean exceptionWasThrown) |
abstract MuleEvent |
AbstractEnvelopeInterceptor.last(MuleEvent event,
ProcessingTime time,
long startTime,
boolean exceptionWasThrown)
This method is always invoked after the event has been processed,
|
MuleEvent |
TimerInterceptor.process(MuleEvent event) |
MuleEvent |
InterceptorStack.process(MuleEvent event) |
MuleEvent |
AbstractEnvelopeInterceptor.process(MuleEvent event) |
Modifier and Type | Method and Description |
---|---|
MuleEvent |
ProcessingTimeInterceptor.after(MuleEvent event) |
MuleEvent |
LoggingInterceptor.after(MuleEvent event) |
abstract MuleEvent |
AbstractEnvelopeInterceptor.after(MuleEvent event)
This method is invoked after the event has been processed, unless an exception was thrown
|
MuleEvent |
ProcessingTimeInterceptor.before(MuleEvent event) |
MuleEvent |
LoggingInterceptor.before(MuleEvent event) |
abstract MuleEvent |
AbstractEnvelopeInterceptor.before(MuleEvent event)
This method is invoked before the event is processed
|
MuleEvent |
ProcessingTimeInterceptor.last(MuleEvent event,
ProcessingTime time,
long startTime,
boolean exceptionWasThrown) |
MuleEvent |
LoggingInterceptor.last(MuleEvent event,
ProcessingTime time,
long startTime,
boolean exceptionWasThrown) |
abstract MuleEvent |
AbstractEnvelopeInterceptor.last(MuleEvent event,
ProcessingTime time,
long startTime,
boolean exceptionWasThrown)
This method is always invoked after the event has been processed,
|
MuleEvent |
TimerInterceptor.process(MuleEvent event) |
MuleEvent |
InterceptorStack.process(MuleEvent event) |
MuleEvent |
AbstractEnvelopeInterceptor.process(MuleEvent event) |
Modifier and Type | Method and Description |
---|---|
Serializable |
SHA256MuleEventKeyGenerator.generateKey(MuleEvent event) |
Serializable |
MD5MuleEventKeyGenerator.generateKey(MuleEvent event)
Deprecated.
|
Serializable |
ExpressionMuleEventKeyGenerator.generateKey(MuleEvent event) |
Modifier and Type | Method and Description |
---|---|
protected MuleEvent |
ProcessIfStartedMessageProcessor.handleUnaccepted(MuleEvent event) |
MuleEvent |
ProcessIfStartedWaitIfSyncPausedMessageProcessor.process(MuleEvent event) |
MuleEvent |
ProcessIfStartedWaitIfPausedMessageProcessor.process(MuleEvent event) |
Modifier and Type | Method and Description |
---|---|
protected boolean |
ProcessIfStartedWaitIfPausedMessageProcessor.accept(MuleEvent event) |
protected boolean |
ProcessIfStartedMessageProcessor.accept(MuleEvent event) |
protected MuleEvent |
ProcessIfStartedMessageProcessor.handleUnaccepted(MuleEvent event) |
MuleEvent |
ProcessIfStartedWaitIfSyncPausedMessageProcessor.process(MuleEvent event) |
MuleEvent |
ProcessIfStartedWaitIfPausedMessageProcessor.process(MuleEvent event) |
Modifier and Type | Method and Description |
---|---|
static ProcessingTime |
ProcessingTime.newInstance(MuleEvent event)
Create a ProcessingTime for the specified MuleSession.
|
Constructor and Description |
---|
ExceptionMessage(MuleEvent event,
Throwable exception,
String componentName,
URI endpointUri) |
Modifier and Type | Method and Description |
---|---|
protected List<MuleMessage> |
FeedSplitter.splitMessage(MuleEvent event) |
Modifier and Type | Method and Description |
---|---|
protected Object |
RulesComponent.doInvoke(MuleEvent event) |
protected Object |
ProcessComponent.doInvoke(MuleEvent event) |
protected Object |
Rules.handleEvent(MuleEvent event) |
protected Object |
Process.handleEvent(MuleEvent event) |
protected void |
Process.populateProcessVariables(MuleEvent event,
Map processVariables,
PropertyScope propertyScope) |
Modifier and Type | Method and Description |
---|---|
protected MuleEvent |
MuleClient.getEvent(MuleMessage message,
MessageExchangePattern exchangePattern) |
Modifier and Type | Method and Description |
---|---|
protected MuleEvent |
CxfOutboundMessageProcessor.buildResponseMessage(MuleEvent request,
MuleEvent transportResponse,
Object[] response) |
protected MuleEvent |
CxfOutboundMessageProcessor.doSendWithClient(MuleEvent event) |
protected MuleEvent |
CxfOutboundMessageProcessor.doSendWithProxy(MuleEvent event) |
protected MuleEvent |
CxfInboundMessageProcessor.generateWSDLOrXSD(MuleEvent event,
String req) |
MuleEvent |
CxfOutboundMessageProcessor.process(MuleEvent event) |
MuleEvent |
CxfInboundMessageProcessor.process(MuleEvent event) |
MuleEvent |
CxfOutboundMessageProcessor.processNext(MuleEvent event)
This method is public so it can be invoked from the MuleUniversalConduit.
|
MuleEvent |
CxfInboundMessageProcessor.processNext(MuleEvent event) |
protected MuleEvent |
CxfInboundMessageProcessor.sendToDestination(MuleEvent event) |
Modifier and Type | Method and Description |
---|---|
protected MuleEvent |
CxfOutboundMessageProcessor.buildResponseMessage(MuleEvent request,
MuleEvent transportResponse,
Object[] response) |
protected void |
CxfComponentExceptionStrategy.doHandleException(Exception e,
MuleEvent event)
Deprecated.
|
protected MuleEvent |
CxfOutboundMessageProcessor.doSendWithClient(MuleEvent event) |
protected MuleEvent |
CxfOutboundMessageProcessor.doSendWithProxy(MuleEvent event) |
protected MuleEvent |
CxfInboundMessageProcessor.generateWSDLOrXSD(MuleEvent event,
String req) |
protected Object[] |
CxfOutboundMessageProcessor.getArgs(MuleEvent event) |
protected InputStream |
CxfInboundMessageProcessor.getMessageStream(MuleEvent context)
Gets the stream representation of the current message.
|
Method |
CxfOutboundMessageProcessor.getMethod(MuleEvent event) |
protected String |
CxfOutboundMessageProcessor.getMethodOrOperationName(MuleEvent event) |
org.apache.cxf.service.model.BindingOperationInfo |
CxfOutboundMessageProcessor.getOperation(MuleEvent event) |
static String |
HttpRequestPropertyManager.getScheme(MuleEvent event) |
MuleEvent |
CxfOutboundMessageProcessor.process(MuleEvent event) |
MuleEvent |
CxfInboundMessageProcessor.process(MuleEvent event) |
MuleEvent |
CxfOutboundMessageProcessor.processNext(MuleEvent event)
This method is public so it can be invoked from the MuleUniversalConduit.
|
MuleEvent |
CxfInboundMessageProcessor.processNext(MuleEvent event) |
protected MuleEvent |
CxfInboundMessageProcessor.sendToDestination(MuleEvent event) |
Constructor and Description |
---|
MuleSoapHeaders(MuleEvent event)
Extracts header properties from a Mule event
|
Modifier and Type | Method and Description |
---|---|
protected MuleMessage |
WebServiceWrapperComponent.doInvoke(MuleEvent event)
Deprecated.
|
Modifier and Type | Method and Description |
---|---|
MuleEvent |
FlowConfiguringMessageProcessor.process(MuleEvent event) |
Modifier and Type | Method and Description |
---|---|
MuleEvent |
FlowConfiguringMessageProcessor.process(MuleEvent event) |
Constructor and Description |
---|
WebServiceSecurityException(MuleEvent event,
Throwable cause) |
Modifier and Type | Method and Description |
---|---|
protected MuleEvent |
MuleUniversalConduit.processNext(MuleEvent event,
org.apache.cxf.message.Exchange exchange,
OutboundEndpoint endpoint) |
Modifier and Type | Method and Description |
---|---|
protected void |
MuleUniversalConduit.dispatchMuleMessage(org.apache.cxf.message.Message m,
MuleEvent reqEvent,
OutboundEndpoint endpoint) |
protected MuleEvent |
MuleUniversalConduit.processNext(MuleEvent event,
org.apache.cxf.message.Exchange exchange,
OutboundEndpoint endpoint) |
Modifier and Type | Method and Description |
---|---|
MuleEvent |
AbstractDbMessageProcessor.process(MuleEvent muleEvent) |
protected MuleEvent |
AbstractDbMessageProcessor.resolveSource(MuleEvent muleEvent) |
Modifier and Type | Method and Description |
---|---|
protected Object |
PreparedBulkUpdateMessageProcessor.executeQuery(DbConnection connection,
MuleEvent muleEvent) |
protected Object |
BulkExecuteMessageProcessor.executeQuery(DbConnection connection,
MuleEvent muleEvent) |
protected Object |
AbstractSingleQueryDbMessageProcessor.executeQuery(DbConnection connection,
MuleEvent muleEvent) |
protected abstract Object |
AbstractDbMessageProcessor.executeQuery(DbConnection connection,
MuleEvent muleEvent) |
MuleEvent |
AbstractDbMessageProcessor.process(MuleEvent muleEvent) |
protected MuleEvent |
AbstractDbMessageProcessor.resolveSource(MuleEvent muleEvent) |
Modifier and Type | Method and Description |
---|---|
DbConfig |
StaticDbConfigResolver.resolve(MuleEvent muleEvent) |
DbConfig |
DefaultDbConfigResolver.resolve(MuleEvent muleEvent) |
DbConfig |
DbConfigResolver.resolve(MuleEvent muleEvent)
Resolves which database configuration to use for a given event
|
Modifier and Type | Method and Description |
---|---|
List<QueryParamValue> |
StaticParamValueResolver.resolveParams(MuleEvent muleEvent,
List<QueryParamValue> templateParams) |
List<QueryParamValue> |
ParamValueResolver.resolveParams(MuleEvent muleEvent,
List<QueryParamValue> templateParams)
Resolves query parameters
|
List<QueryParamValue> |
DynamicParamValueResolver.resolveParams(MuleEvent muleEvent,
List<QueryParamValue> templateParams) |
Modifier and Type | Method and Description |
---|---|
protected BulkQuery |
StaticBulkQueryResolver.createBulkQuery(MuleEvent muleEvent) |
protected BulkQuery |
AbstractBulkQueryResolver.createBulkQuery(MuleEvent muleEvent) |
Query |
StaticQueryResolver.resolve(DbConnection connection,
MuleEvent muleEvent) |
Query |
QueryResolver.resolve(DbConnection connection,
MuleEvent muleEvent)
Resolves a query in the context of a given Mule event.
|
Query |
ParametrizedQueryResolver.resolve(DbConnection connection,
MuleEvent muleEvent) |
Query |
DynamicQueryResolver.resolve(DbConnection connection,
MuleEvent muleEvent) |
BulkQuery |
BulkQueryResolver.resolve(MuleEvent muleEvent)
Resolves a bulk query in the context of a given Mule event.
|
BulkQuery |
AbstractBulkQueryResolver.resolve(MuleEvent muleEvent) |
protected String |
FileBulkQueryResolver.resolveBulkQueries(MuleEvent muleEvent,
String bulkQuery) |
protected String |
DynamicBulkQueryResolver.resolveBulkQueries(MuleEvent muleEvent,
String bulkQuery) |
protected String |
AbstractBulkQueryResolver.resolveBulkQueries(MuleEvent muleEvent,
String bulkQuery) |
Modifier and Type | Method and Description |
---|---|
void |
HttpAuthentication.authenticate(MuleEvent muleEvent,
HttpRequestBuilder builder)
Adds authentication information to the request.
|
boolean |
HttpAuthentication.shouldRetry(MuleEvent firstAttemptResponseEvent)
Detects if there was an authentication failure in the response.
|
Modifier and Type | Method and Description |
---|---|
void |
HttpSingleParam.resolve(ParameterMap parameterMap,
MuleEvent muleEvent) |
abstract void |
HttpParam.resolve(ParameterMap parameterMap,
MuleEvent muleEvent) |
void |
HttpMapParam.resolve(ParameterMap parameterMap,
MuleEvent muleEvent) |
ParameterMap |
HttpMessageBuilder.resolveParams(MuleEvent muleEvent,
HttpParamType httpParamType) |
Modifier and Type | Method and Description |
---|---|
MuleEvent |
HttpMessageProcessorTemplate.getMuleEvent() |
MuleEvent |
HttpMessageProcessorTemplate.routeEvent(MuleEvent muleEvent) |
static MuleEvent |
HttpRequestToMuleEvent.transform(HttpRequestContext requestContext,
MuleContext muleContext,
FlowConstruct flowConstruct,
Boolean parseRequest,
String listenerPath) |
Modifier and Type | Method and Description |
---|---|
HttpResponse |
HttpResponseBuilder.build(HttpResponseBuilder httpResponseBuilder,
MuleEvent event) |
MuleEvent |
HttpMessageProcessorTemplate.routeEvent(MuleEvent muleEvent) |
void |
HttpMessageProcessorTemplate.sendResponseToClient(MuleEvent muleEvent,
ResponseCompletionCallback responseCompletationCallback) |
Constructor and Description |
---|
HttpMessageProcessorTemplate(MuleEvent sourceMuleEvent,
MessageProcessor messageProcessor,
HttpResponseReadyCallback responseReadyCallback,
HttpResponseBuilder responseBuilder,
HttpResponseBuilder errorResponseBuilder) |
Modifier and Type | Method and Description |
---|---|
MuleEvent |
DefaultHttpRequester.process(MuleEvent muleEvent) |
Modifier and Type | Method and Description |
---|---|
void |
DefaultHttpAuthentication.authenticate(MuleEvent muleEvent,
HttpRequestBuilder requestBuilder) |
void |
HttpResponseToMuleEvent.convert(MuleEvent muleEvent,
HttpResponse response) |
HttpRequestBuilder |
MuleEventToHttpRequest.create(MuleEvent event,
String resolvedMethod,
String resolvedUri) |
ParameterMap |
HttpRequesterRequestBuilder.getHeaders(MuleEvent event) |
ParameterMap |
HttpRequesterRequestBuilder.getQueryParams(MuleEvent event) |
MuleEvent |
DefaultHttpRequester.process(MuleEvent muleEvent) |
String |
HttpRequesterRequestBuilder.replaceUriParams(String path,
MuleEvent event) |
boolean |
DefaultHttpAuthentication.shouldRetry(MuleEvent firstAttemptResponseEvent) |
void |
SuccessStatusCodeValidator.validate(MuleEvent responseEvent) |
void |
ResponseValidator.validate(MuleEvent responseEvent) |
void |
FailureStatusCodeValidator.validate(MuleEvent responseEvent) |
Constructor and Description |
---|
ResponseValidatorException(String message,
MuleEvent event) |
Modifier and Type | Method and Description |
---|---|
MuleEvent |
OneWayHttpRequesterAdapter.process(MuleEvent event) |
Modifier and Type | Method and Description |
---|---|
MuleEvent |
OneWayHttpRequesterAdapter.process(MuleEvent event) |
Modifier and Type | Method and Description |
---|---|
MuleEvent |
JaasAuthentication.getEvent() |
Modifier and Type | Method and Description |
---|---|
void |
JaasAuthentication.setEvent(MuleEvent muleEvent) |
Modifier and Type | Method and Description |
---|---|
protected void |
JaasSecurityFilter.authenticateInbound(MuleEvent event) |
protected void |
JaasSecurityFilter.authenticateOutbound(MuleEvent event) |
Modifier and Type | Method and Description |
---|---|
protected Object |
JerseyResourcesComponent.doInvoke(MuleEvent event) |
Modifier and Type | Method and Description |
---|---|
MuleEvent |
ValidateJsonSchemaMessageProcessor.process(MuleEvent event) |
Modifier and Type | Method and Description |
---|---|
MuleEvent |
ValidateJsonSchemaMessageProcessor.process(MuleEvent event) |
void |
JsonSchemaValidator.validate(MuleEvent event)
Parses the
event 's payload as a Json by the rules of
DefaultJsonParser.asJsonNode(Object) . |
Modifier and Type | Method and Description |
---|---|
protected MuleEvent |
AbstractTokenRequestHandler.invokeTokenUrl(MuleEvent event) |
Modifier and Type | Method and Description |
---|---|
protected MuleEvent |
AbstractTokenRequestHandler.invokeTokenUrl(MuleEvent event) |
void |
TokenResponseProcessor.process(MuleEvent muleEvent) |
Modifier and Type | Method and Description |
---|---|
void |
DefaultAuthorizationCodeGrantType.authenticate(MuleEvent muleEvent,
HttpRequestBuilder builder) |
void |
AutoAuthorizationCodeTokenRequestHandler.doRefreshToken(MuleEvent currentEvent,
ResourceOwnerOAuthContext resourceOwnerOAuthContext)
Executes a refresh token for a particular user.
|
protected abstract void |
AbstractAuthorizationCodeTokenRequestHandler.doRefreshToken(MuleEvent currentEvent,
ResourceOwnerOAuthContext resourceOwnerOAuthContext)
ThreadSafe refresh token operation to be implemented by subclasses
|
void |
DefaultAuthorizationCodeGrantType.refreshToken(MuleEvent currentFlowEvent,
String resourceOwnerId) |
void |
AuthorizationCodeGrantType.refreshToken(MuleEvent currentFlowEvent,
String resourceOwnerId)
Does a refresh token for a particular oauth context id.
|
void |
AbstractAuthorizationCodeTokenRequestHandler.refreshToken(MuleEvent currentEvent,
String resourceOwnerId)
Updates the access token by calling the token url with refresh token grant type
|
boolean |
DefaultAuthorizationCodeGrantType.shouldRetry(MuleEvent firstAttemptResponseEvent) |
Modifier and Type | Method and Description |
---|---|
void |
ClientCredentialsGrantType.authenticate(MuleEvent muleEvent,
HttpRequestBuilder builder) |
boolean |
ClientCredentialsGrantType.shouldRetry(MuleEvent firstAttemptResponseEvent) |
Modifier and Type | Method and Description |
---|---|
MuleEvent |
InvalidateOauthContextMessageProcessor.process(MuleEvent event) |
Modifier and Type | Method and Description |
---|---|
MuleEvent |
InvalidateOauthContextMessageProcessor.process(MuleEvent event) |
Modifier and Type | Method and Description |
---|---|
MuleEvent |
PGPAuthentication.getEvent() |
Modifier and Type | Method and Description |
---|---|
void |
PGPAuthentication.setEvent(MuleEvent muleEvent) |
Constructor and Description |
---|
PGPAuthentication(String userName,
Message message,
MuleEvent event) |
Modifier and Type | Method and Description |
---|---|
protected void |
PGPSecurityFilter.authenticateInbound(MuleEvent event) |
protected void |
PGPSecurityFilter.authenticateOutbound(MuleEvent event) |
Modifier and Type | Method and Description |
---|---|
protected List<MuleMessage> |
FeedSplitter.splitMessage(MuleEvent event) |
protected com.sun.syndication.feed.synd.SyndFeed |
FeedSplitter.transformToFeed(MuleEvent event) |
Modifier and Type | Method and Description |
---|---|
protected Object |
ScriptComponent.doInvoke(MuleEvent event) |
void |
Scriptable.populateBindings(Bindings bindings,
MuleEvent event) |
Modifier and Type | Method and Description |
---|---|
protected boolean |
ScriptFilter.accept(MuleEvent event) |
Modifier and Type | Method and Description |
---|---|
MuleEvent |
SpringAuthenticationAdapter.getEvent() |
Modifier and Type | Method and Description |
---|---|
void |
AuthorizationFilter.doFilter(MuleEvent event) |
void |
SpringAuthenticationAdapter.setEvent(MuleEvent muleEvent) |
Constructor and Description |
---|
SpringAuthenticationAdapter(org.springframework.security.core.Authentication authentication,
Map<String,Object> properties,
MuleEvent event) |
Modifier and Type | Method and Description |
---|---|
MuleEvent |
WSConsumer.process(MuleEvent event) |
Modifier and Type | Method and Description |
---|---|
MuleEvent |
WSConsumer.process(MuleEvent event) |
Constructor and Description |
---|
SoapFaultException(MuleEvent event,
QName faultCode,
QName subCode,
String message,
Element detail) |
Modifier and Type | Method and Description |
---|---|
Node |
AbstractJaxpFilter.toDOMNode(Object src,
MuleEvent event) |
Modifier and Type | Method and Description |
---|---|
static Node |
XMLUtils.toDOMNode(Object src,
MuleEvent event) |
static Node |
XMLUtils.toDOMNode(Object src,
MuleEvent event,
DocumentBuilderFactory factory) |
Modifier and Type | Method and Description |
---|---|
String |
XPathEvaluator.evaluate(String xpathExpression,
Node input,
MuleEvent event)
|
String |
JaxpXPathEvaluator.evaluate(String xpathExpression,
Node input,
MuleEvent event)
|
Object |
XPathEvaluator.evaluate(String xpathExpression,
Node input,
XPathReturnType returnType,
MuleEvent event)
Evaluates the
xpathExpression over the input
and returns the evaluation as a type in concordance with returnType . |
Object |
JaxpXPathEvaluator.evaluate(String xpathExpression,
Node input,
XPathReturnType returnType,
MuleEvent event)
Evaluates the
xpathExpression over the input
and returns the evaluation as a type in concordance with returnType . |
Modifier and Type | Method and Description |
---|---|
protected MuleEvent |
InvokerMessageProcessor.createResultEvent(MuleEvent event,
Object result) |
protected MuleEvent |
SedaStageInterceptingMessageProcessor.dequeue() |
protected MuleEvent |
AbstractFilteringMessageProcessor.handleUnaccepted(MuleEvent event) |
MuleEvent |
TransactionalInterceptingMessageProcessor.process(MuleEvent event) |
MuleEvent |
StopFurtherMessageProcessingMessageProcessor.process(MuleEvent event) |
MuleEvent |
SecurityFilterMessageProcessor.process(MuleEvent event) |
MuleEvent |
NullMessageProcessor.process(MuleEvent event) |
MuleEvent |
InvokerMessageProcessor.process(MuleEvent event) |
MuleEvent |
IdempotentRedeliveryPolicy.process(MuleEvent event) |
MuleEvent |
ExceptionHandlingMessageProcessor.process(MuleEvent event) |
MuleEvent |
EndpointTransactionalInterceptingMessageProcessor.process(MuleEvent event) |
MuleEvent |
AsyncInterceptingMessageProcessor.process(MuleEvent event) |
MuleEvent |
AsyncDelegateMessageProcessor.process(MuleEvent event) |
MuleEvent |
AbstractResponseMessageProcessor.process(MuleEvent event) |
MuleEvent |
AbstractFilteringMessageProcessor.process(MuleEvent event) |
MuleEvent |
AbstractDynamicMessageProcessor.process(MuleEvent event) |
protected MuleEvent |
AbstractInterceptingMessageProcessorBase.processNext(MuleEvent event) |
protected MuleEvent |
AsyncInterceptingMessageProcessor.processNextTimed(MuleEvent event) |
protected MuleEvent |
ResponseMessageProcessorAdapter.processResponse(MuleEvent event) |
protected abstract MuleEvent |
AbstractResponseMessageProcessor.processResponse(MuleEvent processNext) |
Modifier and Type | Method and Description |
---|---|
protected abstract boolean |
AbstractFilteringMessageProcessor.accept(MuleEvent event) |
protected MuleEvent |
InvokerMessageProcessor.createResultEvent(MuleEvent event,
Object result) |
protected void |
SedaStageInterceptingMessageProcessor.enqueue(MuleEvent event) |
protected Object[] |
InvokerMessageProcessor.evaluateArguments(MuleEvent event,
List<?> argumentTemplates) |
protected MuleException |
AbstractFilteringMessageProcessor.filterUnacceptedException(MuleEvent event) |
protected void |
AsyncInterceptingMessageProcessor.fireAsyncScheduledNotification(MuleEvent event) |
protected void |
AsyncInterceptingMessageProcessor.firePipelineNotification(MuleEvent event,
MessagingException exception) |
protected MuleEvent |
AbstractFilteringMessageProcessor.handleUnaccepted(MuleEvent event) |
protected boolean |
AbstractInterceptingMessageProcessorBase.isEventValid(MuleEvent event) |
protected boolean |
LaxSedaStageInterceptingMessageProcessor.isProcessAsync(MuleEvent event) |
protected boolean |
LaxAsyncInterceptingMessageProcessor.isProcessAsync(MuleEvent event) |
protected boolean |
AsyncInterceptingMessageProcessor.isProcessAsync(MuleEvent event) |
MuleEvent |
TransactionalInterceptingMessageProcessor.process(MuleEvent event) |
MuleEvent |
StopFurtherMessageProcessingMessageProcessor.process(MuleEvent event) |
MuleEvent |
SecurityFilterMessageProcessor.process(MuleEvent event) |
MuleEvent |
NullMessageProcessor.process(MuleEvent event) |
MuleEvent |
InvokerMessageProcessor.process(MuleEvent event) |
MuleEvent |
IdempotentRedeliveryPolicy.process(MuleEvent event) |
MuleEvent |
ExceptionHandlingMessageProcessor.process(MuleEvent event) |
MuleEvent |
EndpointTransactionalInterceptingMessageProcessor.process(MuleEvent event) |
MuleEvent |
AsyncInterceptingMessageProcessor.process(MuleEvent event) |
MuleEvent |
AsyncDelegateMessageProcessor.process(MuleEvent event) |
MuleEvent |
AbstractResponseMessageProcessor.process(MuleEvent event) |
MuleEvent |
AbstractFilteringMessageProcessor.process(MuleEvent event) |
MuleEvent |
AbstractDynamicMessageProcessor.process(MuleEvent event) |
protected MuleEvent |
AbstractInterceptingMessageProcessorBase.processNext(MuleEvent event) |
protected void |
SedaStageInterceptingMessageProcessor.processNextAsync(MuleEvent event) |
protected void |
AsyncInterceptingMessageProcessor.processNextAsync(MuleEvent event) |
protected MuleEvent |
AsyncInterceptingMessageProcessor.processNextTimed(MuleEvent event) |
protected MuleEvent |
ResponseMessageProcessorAdapter.processResponse(MuleEvent event) |
protected abstract MuleEvent |
AbstractResponseMessageProcessor.processResponse(MuleEvent processNext) |
protected abstract MessageProcessor |
AbstractDynamicMessageProcessor.resolveMessageProcessor(MuleEvent event)
Determines which MessageProcessor should be used.
|
protected void |
SedaStageInterceptingMessageProcessor.rollbackDequeue(MuleEvent event)
Roll back the previous dequeue(), i.e., put the event at the front of the queue, not at the back which
is what enqueue() does.
|
Modifier and Type | Method and Description |
---|---|
protected MuleEvent |
SimpleMessageProcessorChain.doProcess(MuleEvent event) |
protected MuleEvent |
InterceptingChainLifecycleWrapper.doProcess(MuleEvent event) |
protected MuleEvent |
DefaultMessageProcessorChain.doProcess(MuleEvent event) |
protected abstract MuleEvent |
AbstractMessageProcessorChain.doProcess(MuleEvent event) |
MuleEvent |
InterceptingChainLifecycleWrapper.process(MuleEvent event) |
MuleEvent |
AbstractMessageProcessorChain.process(MuleEvent event) |
Modifier and Type | Method and Description |
---|---|
protected MuleEvent |
SimpleMessageProcessorChain.doProcess(MuleEvent event) |
protected MuleEvent |
InterceptingChainLifecycleWrapper.doProcess(MuleEvent event) |
protected MuleEvent |
DefaultMessageProcessorChain.doProcess(MuleEvent event) |
protected abstract MuleEvent |
AbstractMessageProcessorChain.doProcess(MuleEvent event) |
MuleEvent |
InterceptingChainLifecycleWrapper.process(MuleEvent event) |
MuleEvent |
AbstractMessageProcessorChain.process(MuleEvent event) |
Modifier and Type | Field and Description |
---|---|
static MuleEvent[] |
EventGroup.EMPTY_EVENTS_ARRAY |
Modifier and Type | Method and Description |
---|---|
MuleEvent |
CollectAllAggregationStrategy.aggregate(AggregationContext context) |
MuleEvent |
AggregationStrategy.aggregate(AggregationContext context)
aggregates the events in the given context into a single one
|
protected abstract MuleEvent |
AbstractCorrelationAggregator.aggregateEvents(EventGroup events) |
MuleEvent |
DefaultRouterResultsHandler.aggregateResults(List<MuleEvent> results,
MuleEvent previous,
MuleContext muleContext)
Aggregates the events in the results list into one single
MuleEvent
You should only use this method when you're sure that all the events in the results list
were generated by the same thread that's going to handle the aggregated response |
protected MuleEvent |
CollectAllAggregationStrategy.aggregateWithFailedRoutes(AggregationContext context) |
protected MuleEvent |
CollectAllAggregationStrategy.aggregateWithoutFailedRoutes(AggregationContext context) |
protected MuleEvent |
AbstractRoutingStrategy.createEventToRoute(MuleEvent routedEvent,
MuleMessage message,
MessageProcessor route)
Create a new event to be routed to the target MP
|
MuleEvent |
ServiceCatchAllStrategy.doCatchMessage(MuleEvent event)
Deprecated.
|
MuleEvent |
LoggingCatchAllStrategy.doCatchMessage(MuleEvent event)
Deprecated.
|
MuleEvent |
ForwardingCatchAllStrategy.doCatchMessage(MuleEvent event)
Deprecated.
|
abstract MuleEvent |
AbstractCatchAllStrategy.doCatchMessage(MuleEvent event)
Deprecated.
|
MuleEvent |
EventGroup.getMessageCollectionEvent() |
MuleEvent |
WireTap.process(MuleEvent event) |
MuleEvent |
ScatterGatherRouter.process(MuleEvent event) |
MuleEvent |
Resequencer.process(MuleEvent event) |
MuleEvent |
Foreach.process(MuleEvent event) |
MuleEvent |
DynamicRoundRobin.process(MuleEvent event) |
MuleEvent |
DynamicFirstSuccessful.process(MuleEvent event) |
MuleEvent |
DynamicAll.process(MuleEvent event) |
MuleEvent |
AbstractSelectiveRouter.process(MuleEvent event) |
MuleEvent |
AbstractMatchingRouter.process(MuleEvent event) |
MuleEvent |
AbstractCatchAllStrategy.process(MuleEvent event)
Deprecated.
This method will be invoked when an event is received or being sent where the criteria of the router(s) do not
match the current event.
|
MuleEvent |
AbstractAggregator.process(MuleEvent event) |
protected MuleEvent |
AbstractMatchingRouter.processDefaultRoute(MuleEvent event) |
protected MuleEvent |
AbstractUntilSuccessfulProcessingStrategy.processEvent(MuleEvent event)
Process the event through the configured route in the until-successful configuration.
|
protected MuleEvent |
IdempotentMessageFilter.processNext(MuleEvent event) |
protected MuleEvent |
AbstractUntilSuccessfulProcessingStrategy.processResponseThroughAckResponseExpression(MuleEvent event) |
MuleEvent |
UntilSuccessfulProcessingStrategy.route(MuleEvent event) |
protected MuleEvent |
UntilSuccessful.route(MuleEvent event) |
MuleEvent |
SynchronousUntilSuccessfulProcessingStrategy.route(MuleEvent event) |
MuleEvent |
RoundRobin.route(MuleEvent event)
Process the event using the next target route in sequence
|
MuleEvent |
FirstSuccessful.route(MuleEvent event)
Route the given event to one of our targets
|
MuleEvent |
AsynchronousUntilSuccessfulProcessingStrategy.route(MuleEvent event) |
MuleEvent |
RoutingStrategy.route(MuleEvent event,
List<MessageProcessor> messageProcessors)
Routes
MuleEvent through a set of MessageProcessor |
MuleEvent |
RoundRobinRoutingStrategy.route(MuleEvent event,
List<MessageProcessor> messageProcessors) |
MuleEvent |
MulticastingRoutingStrategy.route(MuleEvent event,
List<MessageProcessor> messageProcessors) |
MuleEvent |
FirstSuccessfulRoutingStrategy.route(MuleEvent event,
List<MessageProcessor> messageProcessors) |
protected MuleEvent |
AbstractRoutingStrategy.sendRequest(MuleEvent routedEvent,
MuleMessage message,
MessageProcessor route,
boolean awaitResponse)
Send message event to destination.
|
protected MuleEvent |
AsynchronousUntilSuccessfulProcessingStrategy.threadSafeCopy(MuleEvent event) |
MuleEvent[] |
EventGroup.toArray()
Returns a snapshot of collected events in this group sorted by their arrival time.
|
MuleEvent[] |
EventGroup.toArray(boolean sortByArrival)
Returns a snapshot of collected events in this group, optionally sorted by their arrival time.
|
Modifier and Type | Method and Description |
---|---|
ListableObjectStore<MuleEvent> |
UntilSuccessfulConfiguration.getObjectStore() |
ListableObjectStore<MuleEvent> |
UntilSuccessful.getObjectStore() |
Iterator<MuleEvent> |
EventGroup.iterator()
Returns an iterator over a snapshot copy of this group's collected events
sorted by their arrival time.
|
Iterator<MuleEvent> |
EventGroup.iterator(boolean sortByArrival)
Returns an iterator over a snapshot copy of this group's collected events.,
optionally sorted by arrival order.
|
Modifier and Type | Method and Description |
---|---|
protected boolean |
MessageFilter.accept(MuleEvent event) |
protected boolean |
IdempotentMessageFilter.accept(MuleEvent event) |
protected boolean |
IdempotentMessageFilter.acceptMessageForFlowConstruct(MuleEvent event) |
void |
EventGroup.addEvent(MuleEvent event)
Add the given event to this group.
|
MuleEvent |
DefaultRouterResultsHandler.aggregateResults(List<MuleEvent> results,
MuleEvent previous,
MuleContext muleContext)
Aggregates the events in the results list into one single
MuleEvent
You should only use this method when you're sure that all the events in the results list
were generated by the same thread that's going to handle the aggregated response |
protected static void |
AbstractRoutingStrategy.assertNonConsumableMessage(MuleEvent event,
MuleMessage message)
Asserts that the
MuleMessage in the MuleEvent doesn't carry a consumable payload. |
static Serializable |
AsynchronousUntilSuccessfulProcessingStrategy.buildQueueKey(MuleEvent muleEvent) |
static MuleMessage |
AbstractRoutingStrategy.cloneMessage(MuleEvent event,
MuleMessage message,
MuleContext muleContext) |
int |
EventGroup.ArrivalOrderEventComparator.compare(MuleEvent event1,
MuleEvent event2) |
protected MuleEvent |
AbstractRoutingStrategy.createEventToRoute(MuleEvent routedEvent,
MuleMessage message,
MessageProcessor route)
Create a new event to be routed to the target MP
|
MuleEvent |
ServiceCatchAllStrategy.doCatchMessage(MuleEvent event)
Deprecated.
|
MuleEvent |
LoggingCatchAllStrategy.doCatchMessage(MuleEvent event)
Deprecated.
|
MuleEvent |
ForwardingCatchAllStrategy.doCatchMessage(MuleEvent event)
Deprecated.
|
abstract MuleEvent |
AbstractCatchAllStrategy.doCatchMessage(MuleEvent event)
Deprecated.
|
protected MuleException |
MessageFilter.filterUnacceptedException(MuleEvent event) |
protected String |
IdempotentSecureHashMessageFilter.getIdForEvent(MuleEvent event) |
protected String |
IdempotentMessageFilter.getIdForEvent(MuleEvent event) |
String |
IdentifiableDynamicRouteResolver.getRouteIdentifier(MuleEvent event)
Returns an identifier of the
DynamicRouteResolver . |
String |
DynamicRouteResolverAdapter.getRouteIdentifier(MuleEvent event) |
protected String |
IdempotentMessageFilter.getValueForEvent(MuleEvent event) |
protected boolean |
IdempotentMessageFilter.isNewMessage(MuleEvent event) |
protected boolean |
MessageChunkSplitter.isSplitRequired(MuleEvent event) |
MuleEvent |
WireTap.process(MuleEvent event) |
MuleEvent |
ScatterGatherRouter.process(MuleEvent event) |
MuleEvent |
Resequencer.process(MuleEvent event) |
MuleEvent |
Foreach.process(MuleEvent event) |
MuleEvent |
DynamicRoundRobin.process(MuleEvent event) |
MuleEvent |
DynamicFirstSuccessful.process(MuleEvent event) |
MuleEvent |
DynamicAll.process(MuleEvent event) |
MuleEvent |
AbstractSelectiveRouter.process(MuleEvent event) |
MuleEvent |
AbstractMatchingRouter.process(MuleEvent event) |
MuleEvent |
AbstractCatchAllStrategy.process(MuleEvent event)
Deprecated.
This method will be invoked when an event is received or being sent where the criteria of the router(s) do not
match the current event.
|
MuleEvent |
AbstractAggregator.process(MuleEvent event) |
protected MuleEvent |
AbstractMatchingRouter.processDefaultRoute(MuleEvent event) |
protected MuleEvent |
AbstractUntilSuccessfulProcessingStrategy.processEvent(MuleEvent event)
Process the event through the configured route in the until-successful configuration.
|
protected MuleEvent |
IdempotentMessageFilter.processNext(MuleEvent event) |
protected MuleEvent |
AbstractUntilSuccessfulProcessingStrategy.processResponseThroughAckResponseExpression(MuleEvent event) |
void |
EventGroup.removeEvent(MuleEvent event)
Remove the given event from the group.
|
List<MessageProcessor> |
DynamicRouteResolverAdapter.resolveRoutes(MuleEvent event) |
List<MessageProcessor> |
DynamicRouteResolver.resolveRoutes(MuleEvent event)
Return a list of
MessageProcessor to route the message. |
MuleEvent |
UntilSuccessfulProcessingStrategy.route(MuleEvent event) |
protected MuleEvent |
UntilSuccessful.route(MuleEvent event) |
MuleEvent |
SynchronousUntilSuccessfulProcessingStrategy.route(MuleEvent event) |
MuleEvent |
RoundRobin.route(MuleEvent event)
Process the event using the next target route in sequence
|
MuleEvent |
FirstSuccessful.route(MuleEvent event)
Route the given event to one of our targets
|
MuleEvent |
AsynchronousUntilSuccessfulProcessingStrategy.route(MuleEvent event) |
MuleEvent |
RoutingStrategy.route(MuleEvent event,
List<MessageProcessor> messageProcessors)
Routes
MuleEvent through a set of MessageProcessor |
MuleEvent |
RoundRobinRoutingStrategy.route(MuleEvent event,
List<MessageProcessor> messageProcessors) |
MuleEvent |
MulticastingRoutingStrategy.route(MuleEvent event,
List<MessageProcessor> messageProcessors) |
MuleEvent |
FirstSuccessfulRoutingStrategy.route(MuleEvent event,
List<MessageProcessor> messageProcessors) |
protected Collection<MessageProcessor> |
ChoiceRouter.selectProcessors(MuleEvent event) |
protected abstract Collection<MessageProcessor> |
AbstractSelectiveRouter.selectProcessors(MuleEvent event) |
protected MuleEvent |
AbstractRoutingStrategy.sendRequest(MuleEvent routedEvent,
MuleMessage message,
MessageProcessor route,
boolean awaitResponse)
Send message event to destination.
|
protected List<MuleMessage> |
MessageChunkSplitter.splitMessage(MuleEvent event) |
protected List<MuleMessage> |
MapSplitter.splitMessage(MuleEvent event) |
protected List<MuleMessage> |
ExpressionSplitter.splitMessage(MuleEvent event) |
protected abstract List<MuleMessage> |
AbstractSplitter.splitMessage(MuleEvent event) |
protected MessageSequence<?> |
CollectionSplitter.splitMessageIntoSequence(MuleEvent event) |
protected MessageSequence<?> |
AbstractSplitter.splitMessageIntoSequence(MuleEvent event) |
protected MuleEvent |
AsynchronousUntilSuccessfulProcessingStrategy.threadSafeCopy(MuleEvent event) |
static void |
AbstractRoutingStrategy.validateMessageIsNotConsumable(MuleEvent event,
MuleMessage message)
Validates that the payload is not consumable so it can be copied.
|
Modifier and Type | Method and Description |
---|---|
MuleEvent |
DefaultRouterResultsHandler.aggregateResults(List<MuleEvent> results,
MuleEvent previous,
MuleContext muleContext)
Aggregates the events in the results list into one single
MuleEvent
You should only use this method when you're sure that all the events in the results list
were generated by the same thread that's going to handle the aggregated response |
void |
UntilSuccessful.setObjectStore(ListableObjectStore<MuleEvent> objectStore) |
Modifier and Type | Field and Description |
---|---|
protected Comparator<MuleEvent> |
ResequenceCorrelatorCallback.eventComparator |
Modifier and Type | Method and Description |
---|---|
MuleEvent |
ResequenceMessagesCorrelatorCallback.aggregateEvents(EventGroup events)
This method is invoked if the shouldAggregate method is called and returns
true.
|
MuleEvent |
ResequenceCorrelatorCallback.aggregateEvents(EventGroup events)
This method is invoked if the shouldAggregate method is called and returns
true.
|
MuleEvent |
EventCorrelatorCallback.aggregateEvents(EventGroup events)
This method is invoked if the shouldAggregate method is called and returns
true.
|
MuleEvent |
CollectionCorrelatorCallback.aggregateEvents(EventGroup events)
This method is invoked if the shouldAggregate method is called and returns true.
|
MuleEvent |
EventCorrelator.process(MuleEvent event) |
Modifier and Type | Method and Description |
---|---|
int |
CorrelationSequenceComparator.compare(MuleEvent event1,
MuleEvent event2) |
EventGroup |
EventCorrelatorCallback.createEventGroup(MuleEvent event,
Object id)
Creates the event group with a specific correlation size based on the Mule
Correlation support
|
EventGroup |
CollectionCorrelatorCallback.createEventGroup(MuleEvent event,
Object groupId)
Creates a new EventGroup that will expect the number of events as returned by
MuleMessage.getCorrelationGroupSize() . |
protected MuleSession |
CollectionCorrelatorCallback.getMergedSession(MuleEvent[] events) |
MuleEvent |
EventCorrelator.process(MuleEvent event) |
Constructor and Description |
---|
CorrelationTimeoutException(Message message,
MuleEvent event) |
CorrelationTimeoutException(Message message,
MuleEvent event,
Throwable cause) |
Constructor and Description |
---|
ResequenceCorrelatorCallback(Comparator<MuleEvent> eventComparator,
MuleContext muleContext,
boolean persistentStores,
String storePrefix) |
Modifier and Type | Method and Description |
---|---|
protected MuleEvent |
DefaultOutboundRouterCollection.catchAll(MuleEvent event)
Deprecated.
|
protected MuleEvent |
AbstractOutboundRouter.createEventToRoute(MuleEvent routedEvent,
MuleMessage message,
MessageProcessor route)
Create a new event to be routed to the target MP
|
MuleEvent |
DefaultOutboundRouterCollection.process(MuleEvent event)
Deprecated.
|
MuleEvent |
AbstractOutboundRouter.process(MuleEvent event) |
MuleEvent |
AbstractMessageSequenceSplitter.process(MuleEvent event) |
MuleEvent |
TransformerRouter.route(MuleEvent event)
Deprecated.
|
MuleEvent |
OutboundPassThroughRouter.route(MuleEvent event)
Deprecated.
|
MuleEvent |
MessageChunkingRouter.route(MuleEvent event)
Deprecated.
|
MuleEvent |
FilteringOutboundRouter.route(MuleEvent event) |
MuleEvent |
ExceptionBasedRouter.route(MuleEvent event)
Deprecated.
|
MuleEvent |
EndpointSelector.route(MuleEvent event)
Deprecated.
|
MuleEvent |
ChainingRouter.route(MuleEvent event)
Deprecated.
|
MuleEvent |
AbstractSequenceRouter.route(MuleEvent event) |
MuleEvent |
AbstractRecipientList.route(MuleEvent event) |
protected abstract MuleEvent |
AbstractOutboundRouter.route(MuleEvent event) |
MuleEvent |
AbstractMessageSplitter.route(MuleEvent event) |
protected MuleEvent |
AbstractOutboundRouter.sendRequest(MuleEvent routedEvent,
MuleMessage message,
MessageProcessor route,
boolean awaitResponse) |
protected MuleEvent |
AbstractOutboundRouter.sendRequestEvent(MuleEvent routedEvent,
MuleMessage message,
MessageProcessor route,
boolean awaitResponse)
Send message event to destination.
|
Modifier and Type | Method and Description |
---|---|
protected List<MuleEvent> |
AbstractMessageSequenceSplitter.processParts(MessageSequence<?> seq,
MuleEvent originalEvent) |
Modifier and Type | Method and Description |
---|---|
protected MuleEvent |
DefaultOutboundRouterCollection.catchAll(MuleEvent event)
Deprecated.
|
protected MuleMessage |
AbstractOutboundRouter.cloneMessage(MuleEvent event,
MuleMessage message)
Creates a fresh copy of a
MuleMessage ensuring that the payload can be cloned (i.e. |
protected boolean |
SequenceRouter.continueRoutingMessageAfter(MuleEvent event)
Deprecated.
Determines if the routing should continue after receiving a given
response from an synchronous endpoint.
|
protected boolean |
MulticastingRouter.continueRoutingMessageAfter(MuleEvent response)
Deprecated.
Indicates that this router always routes messages to all the configured
endpoints no matters what a given response is.
|
protected abstract boolean |
AbstractSequenceRouter.continueRoutingMessageAfter(MuleEvent response)
Lets subclasses decide if the routing of a given message should continue
or not after receiving a given response from a synchronous endpoint.
|
protected MuleEvent |
AbstractOutboundRouter.createEventToRoute(MuleEvent routedEvent,
MuleMessage message,
MessageProcessor route)
Create a new event to be routed to the target MP
|
protected List<Object> |
StaticRecipientList.getRecipients(MuleEvent event)
Deprecated.
|
protected List<Object> |
ExpressionRecipientList.getRecipients(MuleEvent event) |
protected abstract List<Object> |
AbstractRecipientList.getRecipients(MuleEvent event) |
MessageProcessor |
FilteringOutboundRouter.getRoute(int index,
MuleEvent event)
Will Return the target at the given index and will resolve any template tags
on the Endpoint URI if necessary
|
protected boolean |
AbstractMessageSequenceSplitter.isSplitRequired(MuleEvent event) |
MuleEvent |
DefaultOutboundRouterCollection.process(MuleEvent event)
Deprecated.
|
MuleEvent |
AbstractOutboundRouter.process(MuleEvent event) |
MuleEvent |
AbstractMessageSequenceSplitter.process(MuleEvent event) |
protected List<MuleEvent> |
AbstractMessageSequenceSplitter.processParts(MessageSequence<?> seq,
MuleEvent originalEvent) |
MuleEvent |
TransformerRouter.route(MuleEvent event)
Deprecated.
|
MuleEvent |
OutboundPassThroughRouter.route(MuleEvent event)
Deprecated.
|
MuleEvent |
MessageChunkingRouter.route(MuleEvent event)
Deprecated.
|
MuleEvent |
FilteringOutboundRouter.route(MuleEvent event) |
MuleEvent |
ExceptionBasedRouter.route(MuleEvent event)
Deprecated.
|
MuleEvent |
EndpointSelector.route(MuleEvent event)
Deprecated.
|
MuleEvent |
ChainingRouter.route(MuleEvent event)
Deprecated.
|
MuleEvent |
AbstractSequenceRouter.route(MuleEvent event) |
MuleEvent |
AbstractRecipientList.route(MuleEvent event) |
protected abstract MuleEvent |
AbstractOutboundRouter.route(MuleEvent event) |
MuleEvent |
AbstractMessageSplitter.route(MuleEvent event) |
protected MuleEvent |
AbstractOutboundRouter.sendRequest(MuleEvent routedEvent,
MuleMessage message,
MessageProcessor route,
boolean awaitResponse) |
protected MuleEvent |
AbstractOutboundRouter.sendRequestEvent(MuleEvent routedEvent,
MuleMessage message,
MessageProcessor route,
boolean awaitResponse)
Send message event to destination.
|
protected abstract MessageSequence<?> |
AbstractMessageSequenceSplitter.splitMessageIntoSequence(MuleEvent event)
Converts the event into a
MessageSequence that will retrieve each of
the event elements |
Modifier and Type | Field and Description |
---|---|
protected ConcurrentMap<String,MuleEvent> |
AbstractAsyncRequestReplyRequester.responseEvents |
Modifier and Type | Method and Description |
---|---|
MuleEvent |
SimpleRequestReplyReplier.process(MuleEvent event) |
MuleEvent |
AbstractReplyToPropertyRequestReplyReplier.process(MuleEvent event) |
MuleEvent |
AbstractAsyncRequestReplyRequester.process(MuleEvent event) |
protected MuleEvent |
AbstractAsyncRequestReplyRequester.receiveAsyncReply(MuleEvent event) |
Modifier and Type | Method and Description |
---|---|
protected String |
AbstractAsyncRequestReplyRequester.getAsyncReplyCorrelationId(MuleEvent event) |
MuleEvent |
SimpleRequestReplyReplier.process(MuleEvent event) |
MuleEvent |
AbstractReplyToPropertyRequestReplyReplier.process(MuleEvent event) |
MuleEvent |
AbstractAsyncRequestReplyRequester.process(MuleEvent event) |
protected void |
AbstractReplyToPropertyRequestReplyReplier.processReplyTo(MuleEvent event,
MuleEvent result,
ReplyToHandler replyToHandler,
Object replyTo) |
protected MuleEvent |
AbstractAsyncRequestReplyRequester.receiveAsyncReply(MuleEvent event) |
protected void |
SimpleAsyncRequestReplyRequester.sendAsyncRequest(MuleEvent event) |
protected void |
AbstractAsyncRequestReplyRequester.sendAsyncRequest(MuleEvent event) |
protected void |
SimpleAsyncRequestReplyRequester.setAsyncReplyProperties(MuleEvent event) |
protected boolean |
ReplyToPropertyRequestReplyReplier.shouldProcessEvent(MuleEvent event) |
protected boolean |
AsyncReplyToPropertyRequestReplyReplier.shouldProcessEvent(MuleEvent event) |
protected abstract boolean |
AbstractReplyToPropertyRequestReplyReplier.shouldProcessEvent(MuleEvent event) |
Modifier and Type | Method and Description |
---|---|
MuleEvent |
DefaultMuleAuthentication.getEvent() |
Modifier and Type | Method and Description |
---|---|
void |
UsernamePasswordAuthenticationFilter.authenticate(MuleEvent event)
Authenticates the current message.
|
void |
AbstractEndpointSecurityFilter.authenticate(MuleEvent event)
Deprecated.
|
abstract void |
AbstractAuthenticationFilter.authenticate(MuleEvent event) |
protected abstract void |
AbstractEndpointSecurityFilter.authenticateInbound(MuleEvent event)
Deprecated.
|
protected abstract void |
AbstractEndpointSecurityFilter.authenticateOutbound(MuleEvent event)
Deprecated.
|
abstract void |
AbstractSecurityFilter.doFilter(MuleEvent event) |
void |
AbstractEndpointSecurityFilter.doFilter(MuleEvent event)
Deprecated.
|
void |
AbstractAuthenticationFilter.doFilter(MuleEvent event) |
protected Authentication |
UsernamePasswordAuthenticationFilter.getAuthenticationToken(MuleEvent event) |
Object |
MuleHeaderCredentialsAccessor.getCredentials(MuleEvent event) |
void |
MuleHeaderCredentialsAccessor.setCredentials(MuleEvent event,
Object credentials) |
void |
DefaultMuleAuthentication.setEvent(MuleEvent muleEvent) |
protected void |
AbstractSecurityFilter.updatePayload(MuleMessage message,
Object payload,
MuleEvent event) |
Constructor and Description |
---|
DefaultMuleAuthentication(Credentials credentials,
MuleEvent event) |
Modifier and Type | Method and Description |
---|---|
protected void |
MuleEncryptionEndpointSecurityFilter.authenticateInbound(MuleEvent event) |
protected void |
MuleEncryptionEndpointSecurityFilter.authenticateOutbound(MuleEvent event) |
Modifier and Type | Method and Description |
---|---|
abstract MuleEvent |
OnNoTokenPolicy.handleNotAuthorized(Object source,
org.mule.common.security.oauth.exception.NotAuthorizedException e,
MuleEvent event)
This method handles a
NotAuthorizedException
according to each policy |
MuleEvent |
DefaultHttpCallback.FlowRefMessageProcessor.process(MuleEvent event) |
MuleEvent |
OAuth2Manager.restoreAuthorizationEvent(String eventId)
Recovers a MuleEvent from the object store.
|
MuleEvent |
BaseOAuth2Manager.restoreAuthorizationEvent(String eventId)
Recovers a MuleEvent from the object store.
|
Modifier and Type | Method and Description |
---|---|
abstract MuleEvent |
OnNoTokenPolicy.handleNotAuthorized(Object source,
org.mule.common.security.oauth.exception.NotAuthorizedException e,
MuleEvent event)
This method handles a
NotAuthorizedException
according to each policy |
MuleEvent |
DefaultHttpCallback.FlowRefMessageProcessor.process(MuleEvent event) |
void |
OAuth2Manager.storeAuthorizationEvent(MuleEvent event)
This method is expected to receive the
MuleEvent corresponding to
the execution of an OAuth2 authorize processor. |
void |
BaseOAuth2Manager.storeAuthorizationEvent(MuleEvent event)
This method is expected to receive the
MuleEvent corresponding to
the execution of an OAuth2 authorize processor. |
Modifier and Type | Method and Description |
---|---|
MuleEvent |
CallbackContinuationMessageProcessor.process(MuleEvent event) |
Modifier and Type | Method and Description |
---|---|
MuleEvent |
CallbackContinuationMessageProcessor.process(MuleEvent event) |
Modifier and Type | Method and Description |
---|---|
MuleEvent |
OAuthAuthorizeNotification.getMuleEvent() |
Constructor and Description |
---|
OAuthAuthorizeNotification(MuleEvent event,
int action) |
Modifier and Type | Method and Description |
---|---|
P |
OAuthProcessTemplate.execute(ProcessCallback<P,Capabilities> processCallback,
MessageProcessor messageProcessor,
MuleEvent event) |
P |
ManagedAccessTokenProcessTemplate.execute(ProcessCallback<P,OAuth2Adapter> processCallback,
MessageProcessor messageProcessor,
MuleEvent event) |
T |
RetryProcessInterceptor.execute(ProcessCallback<T,O> processCallback,
O object,
MessageProcessor messageProcessor,
MuleEvent event) |
T |
ProcessCallbackProcessInterceptor.execute(ProcessCallback<T,O> processCallback,
O object,
MessageProcessor messageProcessor,
MuleEvent event) |
T |
RefreshTokenProcessInterceptor.execute(ProcessCallback<T,OAuth2Adapter> processCallback,
OAuth2Adapter object,
MessageProcessor messageProcessor,
MuleEvent event) |
T |
ManagedAccessTokenProcessInterceptor.execute(ProcessCallback<T,OAuth2Adapter> processCallback,
OAuth2Adapter object,
MessageProcessor messageProcessor,
MuleEvent event) |
Modifier and Type | Method and Description |
---|---|
protected MuleEvent |
OAuth2FetchAccessTokenMessageProcessor.doProcess(MuleEvent event)
Implementors of this class need to implement this method in order to perform
actual processing
|
protected MuleEvent |
OAuth1FetchAccessTokenMessageProcessor.doProcess(MuleEvent event)
Implementors of this class need to implement this method in order to perform
actual processing
|
protected MuleEvent |
BaseOAuth2UnauthorizeMessageProcessor.doProcess(MuleEvent event)
Unauthorize the connector
|
protected MuleEvent |
BaseOAuth2AuthorizeMessageProcessor.doProcess(MuleEvent event)
Starts the OAuth authorization process
|
protected MuleEvent |
BaseOAuth1UnauthorizeMessageProcessor.doProcess(MuleEvent event)
Unauthorize the connector
|
protected MuleEvent |
BaseOAuth1AuthorizeMessageProcessor.doProcess(MuleEvent event)
Starts the OAuth authorization process
|
protected MuleEvent |
AbstractListeningMessageProcessor.doProcess(MuleEvent event)
Not valid for this class or its extensions
|
MuleEvent |
ExtractAuthorizationCodeMessageProcessor.process(MuleEvent event) |
MuleEvent |
AbstractListeningMessageProcessor.processEvent(MuleEvent event)
|
Modifier and Type | Method and Description |
---|---|
protected MuleEvent |
OAuth2FetchAccessTokenMessageProcessor.doProcess(MuleEvent event)
Implementors of this class need to implement this method in order to perform
actual processing
|
protected MuleEvent |
OAuth1FetchAccessTokenMessageProcessor.doProcess(MuleEvent event)
Implementors of this class need to implement this method in order to perform
actual processing
|
protected MuleEvent |
BaseOAuth2UnauthorizeMessageProcessor.doProcess(MuleEvent event)
Unauthorize the connector
|
protected MuleEvent |
BaseOAuth2AuthorizeMessageProcessor.doProcess(MuleEvent event)
Starts the OAuth authorization process
|
protected MuleEvent |
BaseOAuth1UnauthorizeMessageProcessor.doProcess(MuleEvent event)
Unauthorize the connector
|
protected MuleEvent |
BaseOAuth1AuthorizeMessageProcessor.doProcess(MuleEvent event)
Starts the OAuth authorization process
|
protected MuleEvent |
AbstractListeningMessageProcessor.doProcess(MuleEvent event)
Not valid for this class or its extensions
|
protected void |
AbstractAuthorizeMessageProcessor.notifyAuthorizeStart(MuleEvent event) |
protected void |
FetchAccessTokenMessageProcessor.notifyCallbackReception(MuleEvent event) |
MuleEvent |
ExtractAuthorizationCodeMessageProcessor.process(MuleEvent event) |
MuleEvent |
AbstractListeningMessageProcessor.processEvent(MuleEvent event)
|
protected String |
AbstractAuthorizeMessageProcessor.toString(MuleEvent event,
Object value) |
Modifier and Type | Method and Description |
---|---|
MuleEvent |
AbstractService.process(MuleEvent event)
Deprecated.
|
MuleEvent |
ForwardingConsumer.processNext(MuleEvent event)
Deprecated.
|
MuleEvent |
AbstractService.sendEvent(MuleEvent event)
Deprecated.
|
Modifier and Type | Method and Description |
---|---|
void |
AbstractService.dispatchEvent(MuleEvent event)
Deprecated.
|
MuleEvent |
AbstractService.process(MuleEvent event)
Deprecated.
|
MuleEvent |
ForwardingConsumer.processNext(MuleEvent event)
Deprecated.
|
MuleEvent |
AbstractService.sendEvent(MuleEvent event)
Deprecated.
|
Modifier and Type | Method and Description |
---|---|
MuleEvent |
ServiceStatisticsMessageProcessor.process(MuleEvent event)
Deprecated.
|
MuleEvent |
ServiceSetEventRequestContextMessageProcessor.process(MuleEvent event)
Deprecated.
|
MuleEvent |
ServiceOutboundStatisticsMessageProcessor.process(MuleEvent event)
Deprecated.
|
MuleEvent |
ServiceOutboundMessageProcessor.process(MuleEvent event)
Deprecated.
|
MuleEvent |
ServiceLoggingMessageProcessor.process(MuleEvent event)
Deprecated.
|
MuleEvent |
ServiceInternalMessageProcessor.process(MuleEvent event)
Deprecated.
We do all this together here rather than chaining them in order to conserve
2.x exception handling behaviour
|
Modifier and Type | Method and Description |
---|---|
MuleEvent |
ServiceStatisticsMessageProcessor.process(MuleEvent event)
Deprecated.
|
MuleEvent |
ServiceSetEventRequestContextMessageProcessor.process(MuleEvent event)
Deprecated.
|
MuleEvent |
ServiceOutboundStatisticsMessageProcessor.process(MuleEvent event)
Deprecated.
|
MuleEvent |
ServiceOutboundMessageProcessor.process(MuleEvent event)
Deprecated.
|
MuleEvent |
ServiceLoggingMessageProcessor.process(MuleEvent event)
Deprecated.
|
MuleEvent |
ServiceInternalMessageProcessor.process(MuleEvent event)
Deprecated.
We do all this together here rather than chaining them in order to conserve
2.x exception handling behaviour
|
protected void |
ServiceInternalMessageProcessor.processReplyTo(MuleEvent event,
MuleEvent result,
ReplyToHandler replyToHandler,
Object replyTo)
Deprecated.
|
Modifier and Type | Method and Description |
---|---|
protected MuleEvent |
AbstractDevkitBasedPageableMessageProcessor.doProcess(MuleEvent event)
This method sets the message payload to an instance of
ConsumerIterator configured
accordingly to the configured outputUnit and the
PagingDelegate obtained by invoking AbstractDevkitBasedPageableMessageProcessor.getPagingDelegate(org.mule.api.MuleEvent, org.mule.streaming.PagingConfiguration) |
Modifier and Type | Method and Description |
---|---|
protected MuleEvent |
AbstractDevkitBasedPageableMessageProcessor.doProcess(MuleEvent event)
This method sets the message payload to an instance of
ConsumerIterator configured
accordingly to the configured outputUnit and the
PagingDelegate obtained by invoking AbstractDevkitBasedPageableMessageProcessor.getPagingDelegate(org.mule.api.MuleEvent, org.mule.streaming.PagingConfiguration) |
protected abstract PagingDelegate<?> |
AbstractDevkitBasedPageableMessageProcessor.getPagingDelegate(MuleEvent event,
PagingConfiguration pagingConfiguration)
Implement this method to return the
PagingDelegate
to be used when paging. |
Constructor and Description |
---|
ManagedPagingDelegateAdapter(ProviderAwarePagingDelegate<T,Object> delegate,
ProcessTemplate<Object,Object> processTemplate,
List<Class<? extends Exception>> managedExceptions,
boolean isProtected,
MessageProcessor originalMessageProcessor,
MuleEvent originalEvent) |
Modifier and Type | Method and Description |
---|---|
MuleEvent |
InvocationCountMessageProcessor.process(MuleEvent event) |
MuleEvent |
AssertionMessageProcessor.process(MuleEvent event) |
Modifier and Type | Method and Description |
---|---|
protected void |
QuietExceptionStrategy.doHandleException(Exception e,
MuleEvent event) |
MuleEvent |
InvocationCountMessageProcessor.process(MuleEvent event) |
MuleEvent |
AssertionMessageProcessor.process(MuleEvent event) |
Modifier and Type | Method and Description |
---|---|
protected MuleEvent |
FunctionalTestCase.runFlow(String flowName)
Runs the given flow with a default event
|
protected MuleEvent |
FunctionalTestCase.runFlow(String flowName,
MuleEvent event)
Executes the given flow with the given
event |
protected <T> MuleEvent |
FunctionalTestCase.runFlow(String flowName,
T payload)
Executes the given flow with a default message carrying the payload
|
Modifier and Type | Method and Description |
---|---|
protected MuleEvent |
FunctionalTestCase.runFlow(String flowName,
MuleEvent event)
Executes the given flow with the given
event |
protected void |
FunctionalTestCase.testFlow(String flowName,
MuleEvent event)
Looks up the given flow in the registry and processes it with the given event.
|
Modifier and Type | Method and Description |
---|---|
void |
FlowExecutionListener.addListener(Callback<MuleEvent> callback) |
Modifier and Type | Method and Description |
---|---|
boolean |
ManualConstraint.accept(MuleEvent event) |
boolean |
ConstraintFilter.accept(MuleEvent event) |
boolean |
BatchConstraint.accept(MuleEvent event) |
Modifier and Type | Method and Description |
---|---|
MuleEvent |
CompositeConverter.process(MuleEvent event) |
MuleEvent |
AbstractTransformer.process(MuleEvent event) |
Modifier and Type | Method and Description |
---|---|
protected Object |
AbstractMessageTransformer.checkReturnClass(Object object,
MuleEvent event)
Check if the return class is supported by this transformer
|
MuleEvent |
CompositeConverter.process(MuleEvent event) |
MuleEvent |
AbstractTransformer.process(MuleEvent event) |
Object |
AbstractMessageTransformer.transform(Object src,
MuleEvent event) |
Object |
AbstractMessageTransformer.transform(Object src,
String enc,
MuleEvent event) |
Modifier and Type | Method and Description |
---|---|
MuleEvent |
CombineCollectionsTransformer.process(MuleEvent event) |
Modifier and Type | Method and Description |
---|---|
MuleEvent |
CombineCollectionsTransformer.process(MuleEvent event) |
Modifier and Type | Method and Description |
---|---|
MuleEvent |
AbstractTransportMessageProcessTemplate.afterRouteEvent(MuleEvent muleEvent) |
MuleEvent |
AbstractTransportMessageProcessTemplate.beforeRouteEvent(MuleEvent muleEvent) |
protected MuleEvent |
AbstractTransportMessageProcessTemplate.createEventFromMuleMessage(MuleMessage muleMessage) |
protected MuleEvent |
AbstractMessageReceiver.createMuleEvent(MuleMessage message,
OutputStream outputStream) |
MuleEvent |
AbstractTransportMessageProcessTemplate.getMuleEvent() |
MuleEvent |
TransactedPollingMessageReceiver.MessageProcessorWorker.process() |
MuleEvent |
AbstractMessageDispatcher.process(MuleEvent event) |
MuleEvent |
AbstractTransportMessageProcessTemplate.routeEvent(MuleEvent muleEvent) |
MuleEvent |
AbstractMessageReceiver.routeEvent(MuleEvent muleEvent) |
MuleEvent |
AbstractMessageReceiver.routeMessage(MuleMessage message) |
MuleEvent |
AbstractMessageReceiver.routeMessage(MuleMessage message,
MuleSession session,
OutputStream outputStream) |
MuleEvent |
AbstractMessageReceiver.routeMessage(MuleMessage message,
MuleSession session,
Transaction trans,
OutputStream outputStream) |
MuleEvent |
AbstractMessageReceiver.routeMessage(MuleMessage message,
Transaction trans) |
MuleEvent |
AbstractMessageReceiver.routeMessage(MuleMessage message,
Transaction trans,
OutputStream outputStream) |
Modifier and Type | Method and Description |
---|---|
protected ExecutionTemplate<MuleEvent> |
AbstractMessageReceiver.createExecutionTemplate() |
Modifier and Type | Method and Description |
---|---|
MuleEvent |
AbstractTransportMessageProcessTemplate.afterRouteEvent(MuleEvent muleEvent) |
void |
AbstractTransportMessageProcessTemplate.afterSuccessfulProcessingFlow(MuleEvent response) |
protected void |
AbstractMessageReceiver.applyInboundTransformers(MuleEvent event) |
protected void |
AbstractMessageDispatcher.applyOutboundTransformers(MuleEvent event) |
protected void |
AbstractMessageReceiver.applyResponseTransformers(MuleEvent event) |
protected void |
AbstractMessageDispatcher.applyResponseTransformers(MuleEvent event) |
MuleEvent |
AbstractTransportMessageProcessTemplate.beforeRouteEvent(MuleEvent muleEvent) |
protected void |
UnsupportedMessageDispatcher.doDispatch(MuleEvent event) |
protected abstract void |
AbstractMessageDispatcher.doDispatch(MuleEvent event) |
protected MuleMessage |
UnsupportedMessageDispatcher.doSend(MuleEvent event) |
protected abstract MuleMessage |
AbstractMessageDispatcher.doSend(MuleEvent event) |
protected OutboundEndpoint |
DefaultReplyToHandler.getEndpoint(MuleEvent event,
String endpointUri) |
OutputStream |
AbstractConnector.getOutputStream(OutboundEndpoint endpoint,
MuleEvent event)
Will get the output stream for this type of transport.
|
MuleEvent |
AbstractMessageDispatcher.process(MuleEvent event) |
void |
DefaultReplyToHandler.processReplyTo(MuleEvent event,
MuleMessage returnMessage,
Object replyTo) |
protected boolean |
AbstractMessageDispatcher.returnResponse(MuleEvent event)
Deprecated.
|
protected boolean |
AbstractMessageDispatcher.returnResponse(MuleEvent event,
boolean doSend)
Used to determine if the dispatcher implementation should wait for a response to an event on a response
channel after it sends the event.
|
MuleEvent |
AbstractTransportMessageProcessTemplate.routeEvent(MuleEvent muleEvent) |
MuleEvent |
AbstractMessageReceiver.routeEvent(MuleEvent muleEvent) |
Modifier and Type | Method and Description |
---|---|
protected List<Object> |
AbstractReceiverWorker.handleEventResults(List<MuleEvent> events) |
Constructor and Description |
---|
TransactedPollingMessageReceiver.MessageProcessorWorker(ExecutionTemplate<MuleEvent> pt,
CountDownLatch latch,
SystemExceptionHandler exceptionHandler,
Object message) |
Modifier and Type | Method and Description |
---|---|
protected void |
AjaxMessageDispatcher.doDispatch(MuleEvent event) |
protected MuleMessage |
AjaxMessageDispatcher.doSend(MuleEvent event) |
void |
AjaxReplyToHandler.processReplyTo(MuleEvent event,
MuleMessage returnMessage,
Object replyTo) |
Modifier and Type | Method and Description |
---|---|
protected void |
SmtpMessageDispatcher.doDispatch(MuleEvent event) |
protected void |
RetrieveMessageRequester.doDispatch(MuleEvent event) |
protected MuleMessage |
SmtpMessageDispatcher.doSend(MuleEvent event) |
protected MuleMessage |
RetrieveMessageRequester.doSend(MuleEvent event) |
Modifier and Type | Method and Description |
---|---|
protected void |
FileMessageDispatcher.doDispatch(MuleEvent event) |
protected MuleMessage |
FileMessageDispatcher.doSend(MuleEvent event) |
OutputStream |
FileConnector.getOutputStream(OutboundEndpoint endpoint,
MuleEvent event)
Well get the output stream (if any) for this type of transport.
|
Modifier and Type | Method and Description |
---|---|
protected void |
FtpMessageDispatcher.doDispatch(MuleEvent event) |
protected MuleMessage |
FtpMessageDispatcher.doSend(MuleEvent event) |
OutputStream |
FtpConnector.getOutputStream(OutboundEndpoint endpoint,
MuleEvent event)
Well get the output stream (if any) for this type of transport.
|
Modifier and Type | Method and Description |
---|---|
MuleEvent |
HttpsMessageProcessTemplate.beforeRouteEvent(MuleEvent muleEvent) |
MuleEvent |
HttpMessageProcessTemplate.beforeRouteEvent(MuleEvent muleEvent) |
Modifier and Type | Method and Description |
---|---|
static void |
CookieHelper.addCookiesToClient(HttpClient client,
Object cookiesObject,
String policy,
MuleEvent event,
URI destinationUri)
Adds to the client all the cookies present in the cookiesObject.
|
MuleEvent |
HttpsMessageProcessTemplate.beforeRouteEvent(MuleEvent muleEvent) |
MuleEvent |
HttpMessageProcessTemplate.beforeRouteEvent(MuleEvent muleEvent) |
protected HttpMethod |
HttpClientMessageDispatcher.createEntityMethod(MuleEvent event,
Object body,
EntityEnclosingMethod postMethod) |
protected void |
HttpClientMessageDispatcher.doDispatch(MuleEvent event) |
protected MuleMessage |
HttpClientMessageDispatcher.doSend(MuleEvent event) |
protected HttpMethod |
HttpClientMessageDispatcher.execute(MuleEvent event,
HttpMethod httpMethod) |
protected HttpMethod |
HttpClientMessageDispatcher.getMethod(MuleEvent event) |
protected MuleMessage |
HttpClientMessageDispatcher.handleRedirect(HttpMethod method,
MuleEvent event) |
protected void |
HttpClientMessageDispatcher.processCookies(MuleEvent event) |
protected boolean |
HttpClientMessageDispatcher.returnException(MuleEvent event,
HttpMethod httpMethod)
An exception is thrown if http.status >= 400 and exceptions are not disabled
through one of the following mechanisms in order of precedence:
- setting to true the flow variable "http.disable.status.code.exception.check"
- setting to true the outbound property "http.disable.status.code.exception.check"
- setting to false the outbound endpoint attribute "exceptionOnMessageError"
|
void |
HttpMessageProcessTemplate.sendResponseToClient(MuleEvent responseMuleEvent) |
protected void |
HttpClientMessageDispatcher.setPropertyFromEndpoint(MuleEvent event,
MuleMessage msg,
String prop) |
protected void |
HttpConnector.setupClientAuthorization(MuleEvent event,
HttpMethod httpMethod,
HttpClient client,
ImmutableEndpoint endpoint) |
protected HttpResponse |
OldHttpMessageReceiver.transformResponse(Object response,
MuleEvent event) |
Constructor and Description |
---|
StreamPayloadRequestEntity(OutputHandler outputHandler,
MuleEvent event) |
Modifier and Type | Method and Description |
---|---|
MuleEvent |
StaticResourceMessageProcessor.process(MuleEvent event) |
MuleEvent |
HttpResponseBuilder.process(MuleEvent event) |
Modifier and Type | Method and Description |
---|---|
Object |
RestServiceWrapper.doInvoke(MuleEvent event) |
MuleEvent |
StaticResourceMessageProcessor.process(MuleEvent event) |
MuleEvent |
HttpResponseBuilder.process(MuleEvent event) |
protected void |
HttpResponseBuilder.setBody(HttpResponse response,
MuleMessage message,
MuleEvent event) |
Constructor and Description |
---|
ResourceNotFoundException(Message message,
MuleEvent event) |
RestServiceException(Message message,
MuleEvent event) |
RestServiceException(Message message,
MuleEvent event,
Throwable cause) |
Modifier and Type | Method and Description |
---|---|
void |
HttpBasicAuthenticationFilter.authenticateInbound(MuleEvent event)
Authenticates the current message if authenticate is set to true.
|
void |
HttpBasicAuthenticationFilter.authenticateOutbound(MuleEvent event)
Authenticates the current message if authenticate is set to true.
|
protected Authentication |
HttpBasicAuthenticationFilter.createAuthentication(String username,
String password,
MuleEvent event) |
protected void |
HttpBasicAuthenticationFilter.setUnauthenticated(MuleEvent event) |
Modifier and Type | Method and Description |
---|---|
Object |
ServletTransformer.transform(Object src,
MuleEvent event) |
Constructor and Description |
---|
MuleHttpServletRequest(MuleEvent event) |
MuleHttpServletResponse(MuleEvent event) |
Modifier and Type | Method and Description |
---|---|
protected void |
JdbcMessageDispatcher.doDispatch(MuleEvent event) |
protected MuleMessage |
JdbcMessageRequester.doRequest(long timeout,
MuleEvent event)
Make a specific request to the underlying transport
Special case: The event is need when doReceive was called from doSend
|
protected MuleMessage |
JdbcMessageDispatcher.doSend(MuleEvent event) |
Modifier and Type | Method and Description |
---|---|
MuleMessage |
SqlStatementStrategyExecutor.execute(SqlStatementStrategy strategy,
JdbcConnector connector,
ImmutableEndpoint endpoint,
MuleEvent event,
long timeout,
Connection connection) |
MuleMessage |
SqlStatementStrategy.executeStatement(JdbcConnector connector,
ImmutableEndpoint endpoint,
MuleEvent event,
long timeout,
Connection connection) |
MuleMessage |
SimpleUpdateSqlStatementStrategy.executeStatement(JdbcConnector connector,
ImmutableEndpoint endpoint,
MuleEvent event,
long timeout,
Connection connection) |
MuleMessage |
SelectSqlStatementStrategy.executeStatement(JdbcConnector connector,
ImmutableEndpoint endpoint,
MuleEvent event,
long timeout,
Connection connection) |
Modifier and Type | Method and Description |
---|---|
protected void |
JmsMessageDispatcher.applyOutboundTransformers(MuleEvent event) |
protected MessageConsumer |
JmsMessageDispatcher.createReplyToConsumer(Message currentMessage,
MuleEvent event,
Session session,
Destination replyTo,
boolean topic) |
protected void |
JmsMessageDispatcher.doDispatch(MuleEvent event) |
protected MuleMessage |
JmsMessageDispatcher.doSend(MuleEvent event) |
protected Destination |
JmsMessageDispatcher.getReplyToDestination(Message message,
Session session,
MuleEvent event,
boolean remoteSync,
boolean topic) |
protected boolean |
JmsMessageDispatcher.isHandleReplyTo(Message msg,
MuleEvent event)
Some JMS implementations do not support ReplyTo or require some further fiddling of the message
|
protected void |
JmsReplyToHandler.processMessage(Message replyToMessage,
MuleEvent event) |
protected void |
JmsMessageDispatcher.processMessage(Message msg,
MuleEvent event)
This method is called once the JMS message is created.
|
void |
JmsReplyToHandler.processReplyTo(MuleEvent event,
MuleMessage returnMessage,
Object replyTo) |
Modifier and Type | Method and Description |
---|---|
static Message |
JmsMessages.messageMarkedForRedelivery(MuleEvent event) |
Modifier and Type | Method and Description |
---|---|
MuleEvent |
MessageProcessorPollingInterceptor.prepareRouting(MuleEvent sourceEvent,
MuleEvent event)
Called after the polling message processor processes the event, but before an event is routed to the rest of the flow.
|
MuleEvent |
MessageProcessorPollingInterceptor.prepareSourceEvent(MuleEvent event)
Called before sending the event to the message processor that will do poll for events.
|
Modifier and Type | Method and Description |
---|---|
protected boolean |
MessageProcessorPollingMessageReceiver.isNewMessage(MuleEvent sourceEvent) |
void |
MessageProcessorPollingInterceptor.postProcessRouting(MuleEvent event)
Post process the event after it was routed to the rest of the flow.
|
MuleEvent |
MessageProcessorPollingInterceptor.prepareRouting(MuleEvent sourceEvent,
MuleEvent event)
Called after the polling message processor processes the event, but before an event is routed to the rest of the flow.
|
MuleEvent |
MessageProcessorPollingInterceptor.prepareSourceEvent(MuleEvent event)
Called before sending the event to the message processor that will do poll for events.
|
Modifier and Type | Method and Description |
---|---|
MuleEvent |
WatermarkPollingInterceptor.prepareRouting(MuleEvent sourceEvent,
MuleEvent event)
Watermark route preparation carries the value from the source event to the
flow event
|
MuleEvent |
WatermarkPollingInterceptor.prepareSourceEvent(MuleEvent event)
Watermark source preprocessing puts the watermark value into a flow variable
|
Modifier and Type | Method and Description |
---|---|
static Serializable |
WatermarkUtils.evaluate(String expression,
MuleEvent event)
Evaluates a mel expression.
|
protected abstract Object |
Watermark.getUpdatedValue(MuleEvent event)
This method is executed once the flow containing the poll has been executed.
|
protected Object |
UpdateExpressionWatermark.getUpdatedValue(MuleEvent event)
Returns the new watermark value by evaluating
UpdateExpressionWatermark.updateExpression on the
flowVar of the given name |
void |
WatermarkPollingInterceptor.postProcessRouting(MuleEvent event)
Watermark post processing saves the flow variable to the object store
|
MuleEvent |
WatermarkPollingInterceptor.prepareRouting(MuleEvent sourceEvent,
MuleEvent event)
Watermark route preparation carries the value from the source event to the
flow event
|
MuleEvent |
WatermarkPollingInterceptor.prepareSourceEvent(MuleEvent event)
Watermark source preprocessing puts the watermark value into a flow variable
|
void |
Watermark.putInto(MuleEvent event)
Retrieves the watermark value from the underlying peristent store and enriches
the event.If there is no value stored, a default expression will be used to
create a new one.
|
protected String |
Watermark.resolveVariable(MuleEvent event) |
void |
Watermark.updateFrom(MuleEvent event)
Updates the watermark in persistent storage based on the flow variable defined
in the event
|
void |
Watermark.updateWith(MuleEvent event,
Serializable newValue) |
Modifier and Type | Method and Description |
---|---|
MuleEvent |
SelectorWatermarkPollingInterceptor.prepareRouting(MuleEvent sourceEvent,
MuleEvent event)
Watermark route preparation carries the value from the source event to the
flow event
|
Modifier and Type | Method and Description |
---|---|
protected Object |
SelectorWatermark.getUpdatedValue(MuleEvent event)
Returns the
SelectorWatermark.selectorBroker value and resets it so that its reusable. |
void |
SelectorWatermarkPollingInterceptor.postProcessRouting(MuleEvent event) |
MuleEvent |
SelectorWatermarkPollingInterceptor.prepareRouting(MuleEvent sourceEvent,
MuleEvent event)
Watermark route preparation carries the value from the source event to the
flow event
|
Constructor and Description |
---|
WatermarkSelectorWrapper(WatermarkSelector wrapped,
String selectorExpression,
MuleEvent muleEvent) |
Modifier and Type | Method and Description |
---|---|
protected MuleEvent |
QuartzMessageReceiver.createMuleEvent(MuleMessage message,
OutputStream outputStream) |
Modifier and Type | Method and Description |
---|---|
protected void |
QuartzMessageDispatcher.doDispatch(MuleEvent event) |
protected MuleMessage |
QuartzMessageDispatcher.doSend(MuleEvent event) |
Modifier and Type | Method and Description |
---|---|
MuleEvent |
RmiCallbackMessageReceiver.routeMessage(Object payload) |
Modifier and Type | Method and Description |
---|---|
protected void |
RmiMessageDispatcher.doDispatch(MuleEvent event) |
MuleMessage |
RmiMessageDispatcher.doSend(MuleEvent event) |
protected Class[] |
RmiConnector.getArgTypes(Object args,
MuleEvent fromEvent) |
Method |
RmiConnector.getMethodObject(Remote remoteObject,
MuleEvent event,
OutboundEndpoint outboundEndpoint)
Helper method for Dispatchers and Receives to extract the correct method from
a Remote object
|
Modifier and Type | Method and Description |
---|---|
protected MuleEvent |
MuleReceiverServlet.routeMessage(MessageReceiver receiver,
MuleMessage requestMessage,
HttpServletRequest request) |
Modifier and Type | Method and Description |
---|---|
void |
JettyMessageProcessTemplate.sendResponseToClient(MuleEvent muleEvent) |
void |
JettyContinuationsMessageProcessTemplate.sendResponseToClient(MuleEvent muleEvent) |
Modifier and Type | Method and Description |
---|---|
protected void |
SftpMessageDispatcher.doDispatch(MuleEvent event) |
protected MuleMessage |
SftpMessageDispatcher.doSend(MuleEvent event) |
Modifier and Type | Method and Description |
---|---|
protected void |
AxisMessageDispatcher.addAttachments(MuleEvent event,
org.apache.axis.client.Call call) |
protected void |
AxisMessageDispatcher.buildSoapMethods(MuleEvent event,
org.apache.axis.client.Call call,
Object method,
String methodNamespace,
Object[] args) |
protected void |
AxisMessageDispatcher.doDispatch(MuleEvent event) |
protected MuleMessage |
AxisMessageDispatcher.doSend(MuleEvent event) |
protected org.apache.axis.client.Call |
AxisMessageDispatcher.getCall(MuleEvent event,
Object[] args) |
protected Object |
AxisMessageDispatcher.getInitialMethod(MuleEvent event) |
String |
AxisMessageDispatcher.parseSoapAction(String soapAction,
QName method,
MuleEvent event) |
protected void |
AxisMessageDispatcher.parseStyle(MuleEvent event,
org.apache.axis.client.Call call) |
protected void |
AxisMessageDispatcher.parseUse(MuleEvent event,
org.apache.axis.client.Call call) |
protected Object |
AxisMessageDispatcher.refineMethod(MuleEvent event,
org.apache.axis.client.Call call,
Object method) |
protected void |
AxisMessageDispatcher.setCustomProperties(MuleEvent event,
org.apache.axis.client.Call call) |
protected void |
AxisMessageDispatcher.setSoapAction(MuleEvent event,
EndpointURI endpointUri,
org.apache.axis.client.Call call) |
Modifier and Type | Method and Description |
---|---|
protected Object |
WebServiceWrapperComponent.doInvoke(MuleEvent event) |
Modifier and Type | Method and Description |
---|---|
protected org.apache.axis.client.Service |
AxisWsdlMessageDispatcher.createService(MuleEvent event) |
Modifier and Type | Method and Description |
---|---|
protected void |
StdioMessageDispatcher.doDispatch(MuleEvent event) |
protected MuleMessage |
StdioMessageDispatcher.doSend(MuleEvent event) |
Modifier and Type | Method and Description |
---|---|
protected void |
LocalSocketTcpMessageDispatcher.dispatchToSocket(MuleEvent event) |
protected void |
TcpMessageDispatcher.doDispatch(MuleEvent event) |
protected void |
LocalSocketTcpMessageDispatcher.doDispatch(MuleEvent event) |
protected MuleMessage |
TcpMessageDispatcher.doSend(MuleEvent event) |
protected MuleMessage |
LocalSocketTcpMessageDispatcher.doSend(MuleEvent event) |
Modifier and Type | Method and Description |
---|---|
protected void |
UdpMessageDispatcher.doDispatch(MuleEvent event) |
protected MuleMessage |
UdpMessageDispatcher.doSend(MuleEvent event) |
Modifier and Type | Method and Description |
---|---|
protected MuleEvent |
VMMessageReceiver.getFirstMessage() |
Modifier and Type | Method and Description |
---|---|
protected void |
VMMessageDispatcher.doDispatch(MuleEvent event) |
protected MuleMessage |
VMMessageDispatcher.doSend(MuleEvent event) |
Modifier and Type | Method and Description |
---|---|
protected void |
XmppMessageDispatcher.doDispatch(MuleEvent event) |
protected MuleMessage |
XmppMessageDispatcher.doSend(MuleEvent event) |
protected void |
XmppMessageDispatcher.sendMessage(MuleEvent event) |
Modifier and Type | Method and Description |
---|---|
Boolean |
AttributeEvaluator.resolveBooleanValue(MuleEvent event) |
Integer |
AttributeEvaluator.resolveIntegerValue(MuleEvent event) |
String |
AttributeEvaluator.resolveStringValue(MuleEvent event) |
Object |
AttributeEvaluator.resolveValue(MuleEvent event) |
Modifier and Type | Method and Description |
---|---|
MessageSequence<?> |
EventToMessageSequenceSplittingStrategy.split(MuleEvent event) |
Modifier and Type | Field and Description |
---|---|
protected MuleEvent |
AbstractMuleEventWork.event |
Modifier and Type | Method and Description |
---|---|
MuleEvent |
AbstractMuleEventWork.getEvent() |
MuleEvent |
ProcessingMuleEventWork.getResult(long timeout,
TimeUnit timeUnit)
This method is useful for having a thread other than the one executing this
work waiting for the result being available.
|
Constructor and Description |
---|
AbstractMuleEventWork(MuleEvent event) |
ProcessingMuleEventWork(MessageProcessor messageProcessor,
MuleEvent muleEvent) |
Copyright © 2003–2015 MuleSoft, Inc.. All rights reserved.