Modifier and Type | Class and Description |
---|---|
class |
DefaultMuleEvent
DefaultMuleEvent represents any data event occurring in the Mule environment. |
class |
NonBlockingVoidMuleEvent
A
NonBlockingVoidMuleEvent represents a void return, but in contrast to VoidMuleEvent
while the return up the stack is void, an asynchronous response is expected. |
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(MuleEvent rewriteEvent,
FlowConstruct flowConstruct,
ReplyToHandler replyToHandler,
Object replyToDestination,
boolean synchronous) |
DefaultMuleEvent(MuleEvent rewriteEvent,
ReplyToHandler replyToHandler)
Copy constructor used when ReplyToHandler instance needs switching out
|
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,
boolean synchronus,
boolean shareFlowVars,
MessageExchangePattern messageExchangePattern)
Copy constructor to be used when synchronicity and
MessageExchangePattern both need changing. |
DefaultMuleEvent(MuleMessage message,
MuleEvent rewriteEvent,
FlowConstruct flowConstruct,
MuleSession session,
boolean synchronous) |
DefaultMuleEvent(MuleMessage message,
MuleEvent rewriteEvent,
FlowConstruct flowConstruct,
MuleSession session,
boolean synchronous,
boolean shareFlowVars,
MessageExchangePattern messageExchangePattern) |
DefaultMuleEvent(MuleMessage message,
MuleEvent rewriteEvent,
FlowConstruct flowConstruct,
MuleSession session,
boolean synchronous,
ReplyToHandler replyToHandler,
Object replyToDestination,
boolean shareFlowVars,
MessageExchangePattern messageExchangePattern) |
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 |
---|---|
void |
FlowTraceManager.onFlowComplete(MuleEvent event)
Handles the completion of the current flow for the given event.
|
void |
FlowTraceManager.onFlowStart(MuleEvent event,
String flowName)
Handles the start of the passed flowName for the given event.
|
Modifier and Type | Method and Description |
---|---|
static FieldDebugInfo<?> |
FieldDebugInfoFactory.createFieldDebugInfo(String name,
Class<?> type,
AttributeEvaluator evaluator,
MuleEvent event)
Creates a debug info for a field
|
List<FieldDebugInfo<?>> |
DebugInfoProvider.getDebugInfo(MuleEvent event)
Returns debug information about the fields of this object.
|
void |
DebuggerCallback.onExecutionBegun(MuleEvent event)
Notifies when the execution of the event has begun.
|
void |
DebuggerCallback.onExecutionEnded(MuleEvent event)
Notifies when the execution of the event has ended.
|
void |
DebuggerCallback.onExecutionPaused(MuleEvent event,
List<DebuggerFrame> frameStack,
String location)
Notifies when the execution is paused for debugging the current execution state.
|
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) |
Constructor and Description |
---|
NestedProcessorChain(MuleEvent event,
MuleContext muleContext,
MessageProcessor chain)
Deprecated.
|
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,
Message message) |
MessageRedeliveredException(String messageId,
int redeliveryCount,
int maxRedelivery,
InboundEndpoint endpoint,
MuleEvent event,
Message message,
MessageProcessor failingMessageProcessor) |
MessageRedeliveredException(String messageId,
int redeliveryCount,
int maxRedelivery,
InboundEndpoint endpoint,
MuleEvent event,
MessageProcessor failingMessageProcessor) |
Modifier and Type | Method and Description |
---|---|
Map<String,Object> |
ExceptionContextProvider.getContextInfo(MuleEvent event,
MessageProcessor lastProcessed) |
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 |
ProcessorExecutor.execute()
Executes a list of
MessageProcessor s. |
MuleEvent |
LoggerMessageProcessor.process(MuleEvent event) |
MuleEvent |
MessageProcessor.process(MuleEvent event)
Invokes the MessageProcessor.
|
Modifier and Type | Method and Description |
---|---|
protected void |
LoggerMessageProcessor.log(MuleEvent event) |
MuleEvent |
LoggerMessageProcessor.process(MuleEvent event) |
MuleEvent |
MessageProcessor.process(MuleEvent event)
Invokes the MessageProcessor.
|
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,
Filter filter,
MessageProcessor failingMessageProcessor) |
FilterUnacceptedException(Message message,
MuleEvent event,
Filter filter,
Throwable cause) |
FilterUnacceptedException(Message message,
MuleEvent event,
MessageProcessor failingMessageProcessor) |
FilterUnacceptedException(Message message,
MuleEvent event,
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,
MessageProcessor failingMessageProcessor) |
FailedToQueueEventException(Message message,
MuleEvent event,
Throwable cause,
MessageProcessor failingMessageProcessor) |
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 |
ExceptionHandlingReplyToHandlerDecorator.processReplyTo(MuleEvent event,
MuleMessage returnMessage,
Object replyTo) |
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 abstract Object |
AbstractComponent.doInvoke(MuleEvent event) |
protected Object |
AbstractJavaComponent.doInvoke(MuleEvent event) |
Object |
DefaultComponentLifecycleAdapter.invoke(MuleEvent event) |
protected Object |
AbstractJavaComponent.invokeComponentInstance(MuleEvent event) |
protected Object |
SimpleCallableJavaComponent.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 |
DynamicPipelineMessageProcessor.process(MuleEvent event) |
MuleEvent |
Flow.process(MuleEvent event) |
Modifier and Type | Method and Description |
---|---|
protected boolean |
AbstractPipeline.ProcessIfPipelineStartedMessageProcessor.accept(MuleEvent event) |
protected MuleEvent |
AbstractPipeline.ProcessIfPipelineStartedMessageProcessor.handleUnaccepted(MuleEvent event) |
MuleEvent |
DynamicPipelineMessageProcessor.process(MuleEvent event) |
MuleEvent |
Flow.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() |
Modifier and Type | Method and Description |
---|---|
void |
NotificationHelper.fireNotification(MuleEvent event,
String uri,
FlowConstruct flowConstruct,
int action)
Fires a
ConnectorMessageNotification for the given arguments
using the ServerNotificationHandler associated to the given event |
void |
NotificationHelper.fireNotification(ServerNotification notification,
MuleEvent event)
Fires the given
notification using the ServerNotificationHandler that corresponds
to the given event |
Map<String,Object> |
MessageProcessingFlowTraceManager.getContextInfo(MuleEvent muleEvent,
MessageProcessor lastProcessed) |
boolean |
NotificationHelper.isNotificationEnabled(MuleEvent event)
Checks if the
ServerNotificationHandler associated to the given event
is enabled to fire instances of NotificationHelper.notificationClass |
void |
MessageProcessingFlowTraceManager.onFlowComplete(MuleEvent muleEvent) |
void |
MessageProcessingFlowTraceManager.onFlowStart(MuleEvent muleEvent,
String flowName) |
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 |
InboundEndpointMimeTypeCheckingMessageProcessor.process(MuleEvent event) |
MuleEvent |
InboundLoggingMessageProcessor.process(MuleEvent event) |
MuleEvent |
InboundEndpointPropertyMessageProcessor.process(MuleEvent event) |
MuleEvent |
InboundExceptionDetailsMessageProcessor.process(MuleEvent event) |
Modifier and Type | Method and Description |
---|---|
MuleEvent |
InboundNotificationMessageProcessor.process(MuleEvent event) |
MuleEvent |
InboundEndpointMimeTypeCheckingMessageProcessor.process(MuleEvent event) |
MuleEvent |
InboundLoggingMessageProcessor.process(MuleEvent event) |
MuleEvent |
InboundEndpointPropertyMessageProcessor.process(MuleEvent event) |
MuleEvent |
InboundExceptionDetailsMessageProcessor.process(MuleEvent event) |
Modifier and Type | Method and Description |
---|---|
MuleEvent |
OutboundEndpointMimeTypeCheckingMessageProcessor.process(MuleEvent event) |
MuleEvent |
OutboundEventTimeoutMessageProcessor.process(MuleEvent event) |
MuleEvent |
OutboundSessionHandlerMessageProcessor.process(MuleEvent event) |
MuleEvent |
OutboundRootMessageIdPropertyMessageProcessor.process(MuleEvent event) |
MuleEvent |
OutboundEndpointPropertyMessageProcessor.process(MuleEvent event) |
MuleEvent |
OutboundTxRollbackMessageProcessor.process(MuleEvent event) |
MuleEvent |
OutboundLoggingMessageProcessor.process(MuleEvent event) |
MuleEvent |
OutboundNotificationMessageProcessor.process(MuleEvent event) |
protected MuleEvent |
OutboundResponsePropertiesMessageProcessor.processResponse(MuleEvent response,
MuleEvent request) |
Modifier and Type | Method and Description |
---|---|
EndpointMessageNotification |
OutboundNotificationMessageProcessor.createBeginNotification(MuleEvent event) |
void |
OutboundNotificationMessageProcessor.dispatchNotification(EndpointMessageNotification notification,
MuleEvent event) |
MuleEvent |
OutboundEndpointMimeTypeCheckingMessageProcessor.process(MuleEvent event) |
MuleEvent |
OutboundEventTimeoutMessageProcessor.process(MuleEvent event) |
MuleEvent |
OutboundSessionHandlerMessageProcessor.process(MuleEvent event) |
MuleEvent |
OutboundRootMessageIdPropertyMessageProcessor.process(MuleEvent event) |
MuleEvent |
OutboundEndpointPropertyMessageProcessor.process(MuleEvent event) |
MuleEvent |
OutboundTxRollbackMessageProcessor.process(MuleEvent event) |
MuleEvent |
OutboundLoggingMessageProcessor.process(MuleEvent event) |
MuleEvent |
OutboundNotificationMessageProcessor.process(MuleEvent event) |
protected MuleEvent |
OutboundResponsePropertiesMessageProcessor.processResponse(MuleEvent response,
MuleEvent request) |
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 |
RollbackMessagingExceptionStrategy.beforeRouting(Exception exception,
MuleEvent event) |
protected MuleEvent |
TemplateMessagingExceptionStrategy.beforeRouting(Exception exception,
MuleEvent event) |
protected MuleEvent |
CatchMessagingExceptionStrategy.beforeRouting(Exception exception,
MuleEvent event) |
MuleEvent |
MessagingExceptionStrategyAcceptorDelegate.handleException(Exception exception,
MuleEvent event) |
MuleEvent |
TemplateMessagingExceptionStrategy.handleException(Exception exception,
MuleEvent event) |
MuleEvent |
AbstractMessagingExceptionStrategy.handleException(Exception ex,
MuleEvent event) |
MuleEvent |
ChoiceMessagingExceptionStrategy.handleException(Exception exception,
MuleEvent event) |
MuleEvent |
MessagingExceptionHandlerToSystemAdapter.handleException(Exception exception,
MuleEvent event) |
MuleEvent |
RedeliveryExceeded.process(MuleEvent event) |
protected MuleEvent |
RollbackMessagingExceptionStrategy.route(MuleEvent event,
Exception t) |
protected MuleEvent |
TemplateMessagingExceptionStrategy.route(MuleEvent event,
Exception t) |
Modifier and Type | Method and Description |
---|---|
boolean |
MessagingExceptionStrategyAcceptorDelegate.accept(MuleEvent event) |
boolean |
TemplateMessagingExceptionStrategy.accept(MuleEvent event) |
boolean |
ChoiceMessagingExceptionStrategy.accept(MuleEvent event) |
protected boolean |
RollbackMessagingExceptionStrategy.acceptsEvent(MuleEvent event)
Always accept MessageRedeliveryException exceptions if this rollback exception strategy handles redelivery.
|
protected boolean |
TemplateMessagingExceptionStrategy.acceptsEvent(MuleEvent event)
Determines if the exception strategy should process or not a message inside a choice exception strategy.
|
protected MuleEvent |
TemplateMessagingExceptionStrategy.afterRouting(Exception exception,
MuleEvent event) |
protected MuleEvent |
CatchMessagingExceptionStrategy.afterRouting(Exception exception,
MuleEvent event) |
protected MuleEvent |
RollbackMessagingExceptionStrategy.beforeRouting(Exception exception,
MuleEvent event) |
protected MuleEvent |
TemplateMessagingExceptionStrategy.beforeRouting(Exception exception,
MuleEvent event) |
protected MuleEvent |
CatchMessagingExceptionStrategy.beforeRouting(Exception exception,
MuleEvent event) |
protected void |
AbstractMessagingExceptionStrategy.doHandleException(Exception ex,
MuleEvent event) |
Map<String,Object> |
MessagingExceptionLocationProvider.getContextInfo(MuleEvent event,
MessageProcessor lastProcessed) |
protected String |
MessagingExceptionLocationProvider.getProcessorPath(MuleEvent event,
MessageProcessor lastProcessed) |
MuleEvent |
MessagingExceptionStrategyAcceptorDelegate.handleException(Exception exception,
MuleEvent event) |
MuleEvent |
TemplateMessagingExceptionStrategy.handleException(Exception exception,
MuleEvent event) |
MuleEvent |
AbstractMessagingExceptionStrategy.handleException(Exception ex,
MuleEvent event) |
MuleEvent |
ChoiceMessagingExceptionStrategy.handleException(Exception exception,
MuleEvent event) |
MuleEvent |
MessagingExceptionHandlerToSystemAdapter.handleException(Exception exception,
MuleEvent event) |
protected void |
AbstractExceptionListener.logException(Throwable t,
MuleEvent event)
Used to log the error passed into this Exception Listener
|
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 |
RollbackMessagingExceptionStrategy.processReplyTo(MuleEvent event,
Exception e) |
protected void |
TemplateMessagingExceptionStrategy.processReplyTo(MuleEvent event,
Exception e) |
protected MuleEvent |
RollbackMessagingExceptionStrategy.route(MuleEvent event,
Exception t) |
protected MuleEvent |
TemplateMessagingExceptionStrategy.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 |
ExceptionToMessagingExceptionExecutionInterceptor.execute(MessageProcessor messageProcessor,
MuleEvent event) |
MuleEvent |
MessageProcessorExecutionInterceptor.execute(MessageProcessor messageProcessor,
MuleEvent event) |
MuleEvent |
FlowProcessingPhaseTemplate.getMuleEvent() |
MuleEvent |
AsyncResponseFlowProcessingPhaseTemplate.getMuleEvent() |
MuleEvent |
ThrottlingPhaseTemplate.getMuleEvent() |
MuleEvent |
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 |
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 |
ExceptionToMessagingExceptionExecutionInterceptor.execute(MessageProcessor messageProcessor,
MuleEvent event) |
MuleEvent |
MessageProcessorExecutionInterceptor.execute(MessageProcessor messageProcessor,
MuleEvent event) |
protected void |
NotificationFiringProcessingPhase.fireNotification(MuleEvent event,
int action) |
MuleEvent |
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 |
---|---|
<T extends Exception> |
ExceptionFactory.createException(ValidationResult result,
Class<T> exceptionClass,
MuleEvent event)
Creates an exception of the given
exceptionClass
which represents the given result . |
Exception |
ExceptionFactory.createException(ValidationResult result,
String exceptionClassName,
MuleEvent event)
Creates an exception of the given
exceptionClassName
which represents the given result . |
ValidationResult |
Validator.validate(MuleEvent event)
Performs the validation and generates a
ValidationResult back. |
Constructor and Description |
---|
MultipleValidationException(MultipleValidationResult multipleValidationResult,
MuleEvent event) |
ValidationException(ValidationResult validationResult,
MuleEvent event)
Creates a new instance for the given
validationResult |
Modifier and Type | Method and Description |
---|---|
MuleEvent |
ValidationContext.getMuleEvent()
Returns the
MuleEvent on which
the validation was triggered |
Modifier and Type | Method and Description |
---|---|
void |
ValidationStrategies.all(List<NestedProcessor> validations,
MuleEvent muleEvent)
Perform a list of nested validation operations and informs only one
MultipleValidationResult
which summarizes all of the found errors (if any). |
<T extends Exception> |
DefaultExceptionFactory.createException(ValidationResult result,
Class<T> exceptionClass,
MuleEvent event) |
Exception |
DefaultExceptionFactory.createException(ValidationResult result,
String exceptionClassName,
MuleEvent event) |
void |
CustomValidatorOperation.customValidator(ObjectSource<Validator> source,
ValidationOptions options,
MuleEvent event,
ValidationExtension config) |
void |
CommonValidationOperations.isEmail(String email,
ValidationOptions options,
MuleEvent event,
ValidationExtension config)
Validates that the
email address is valid |
void |
CommonValidationOperations.isEmpty(Object value,
ValidationOptions options,
MuleEvent event,
ValidationExtension config)
Validates that
value is empty. |
void |
CommonValidationOperations.isFalse(boolean expression,
ValidationOptions options,
MuleEvent event,
ValidationExtension config)
Validates that the given
value is false |
void |
CommonValidationOperations.isIp(String ip,
ValidationOptions options,
MuleEvent event,
ValidationExtension config)
Validates that an
ip address represented as a String is valid |
void |
CommonValidationOperations.isNotEmpty(Object value,
ValidationOptions options,
MuleEvent event,
ValidationExtension config)
Validates that
value is not empty. |
void |
CommonValidationOperations.isNotNull(Object value,
ValidationOptions options,
MuleEvent event,
ValidationExtension config)
|
void |
CommonValidationOperations.isNull(Object value,
ValidationOptions options,
MuleEvent event,
ValidationExtension config)
|
void |
NumberValidationOperation.isNumber(String value,
String locale,
String pattern,
String minValue,
String maxValue,
NumberType numberType,
ValidationOptions options,
MuleEvent event,
ValidationExtension config)
Receives a numeric
value as a String and validates that it can be parsed
per the rules of a numberType |
void |
CommonValidationOperations.isTime(String time,
String locale,
String pattern,
ValidationOptions options,
MuleEvent event,
ValidationExtension config)
|
void |
CommonValidationOperations.isTrue(boolean expression,
ValidationOptions options,
MuleEvent event,
ValidationExtension config)
Validates that the given
value is true |
void |
CommonValidationOperations.isUrl(String url,
ValidationOptions options,
MuleEvent event,
ValidationExtension config)
Validates that
url is a valid one |
protected void |
CustomValidatorOperation.logSuccessfulValidation(Validator validator,
MuleEvent event) |
void |
CommonValidationOperations.matchesRegex(String value,
String regex,
boolean caseSensitive,
ValidationOptions options,
MuleEvent event,
ValidationExtension config)
Validates that
value matches the regex regular expression |
void |
CommonValidationOperations.validateSize(Object value,
int min,
Integer max,
ValidationOptions options,
MuleEvent event,
ValidationExtension config)
Validates that
value has a size between certain inclusive boundaries. |
Constructor and Description |
---|
ValidationContext(ValidationMessages messages,
ValidationOptions options,
MuleEvent muleEvent) |
ValidationContext(ValidationMessages messages,
ValidationOptions options,
MuleEvent muleEvent,
ValidationExtension config) |
ValidationContext(ValidationOptions options,
MuleEvent muleEvent,
ValidationExtension config) |
Constructor and Description |
---|
ValidatorElContext(MuleEvent event) |
Modifier and Type | Method and Description |
---|---|
ValidationResult |
BooleanValidator.validate(MuleEvent event) |
ValidationResult |
MatchesRegexValidator.validate(MuleEvent event) |
ValidationResult |
SizeValidator.validate(MuleEvent event) |
ValidationResult |
IpValidator.validate(MuleEvent event) |
ValidationResult |
NumberValidator.validate(MuleEvent event) |
ValidationResult |
EmailValidator.validate(MuleEvent event) |
ValidationResult |
UrlValidator.validate(MuleEvent event) |
ValidationResult |
NotEmptyValidator.validate(MuleEvent event) |
ValidationResult |
NullValidator.validate(MuleEvent event) |
ValidationResult |
EmptyValidator.validate(MuleEvent event) |
ValidationResult |
NotNullValidator.validate(MuleEvent event) |
ValidationResult |
TimeValidator.validate(MuleEvent event) |
Modifier and Type | Method and Description |
---|---|
MuleEvent |
ProcessingTimeInterceptor.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 |
LoggingInterceptor.after(MuleEvent event) |
MuleEvent |
ProcessingTimeInterceptor.before(MuleEvent event) |
abstract MuleEvent |
AbstractEnvelopeInterceptor.before(MuleEvent event)
This method is invoked before the event is processed
|
MuleEvent |
LoggingInterceptor.before(MuleEvent event) |
MuleEvent |
ProcessingTimeInterceptor.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 |
LoggingInterceptor.last(MuleEvent event,
ProcessingTime time,
long startTime,
boolean exceptionWasThrown) |
MuleEvent |
TimerInterceptor.process(MuleEvent event) |
MuleEvent |
InterceptorStack.process(MuleEvent event) |
protected MuleEvent |
AbstractEnvelopeInterceptor.processBlocking(MuleEvent event) |
protected MuleEvent |
AbstractEnvelopeInterceptor.processNonBlocking(MuleEvent event) |
Modifier and Type | Method and Description |
---|---|
MuleEvent |
ProcessingTimeInterceptor.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 |
LoggingInterceptor.after(MuleEvent event) |
MuleEvent |
ProcessingTimeInterceptor.before(MuleEvent event) |
abstract MuleEvent |
AbstractEnvelopeInterceptor.before(MuleEvent event)
This method is invoked before the event is processed
|
MuleEvent |
LoggingInterceptor.before(MuleEvent event) |
MuleEvent |
ProcessingTimeInterceptor.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 |
LoggingInterceptor.last(MuleEvent event,
ProcessingTime time,
long startTime,
boolean exceptionWasThrown) |
MuleEvent |
TimerInterceptor.process(MuleEvent event) |
MuleEvent |
InterceptorStack.process(MuleEvent event) |
protected MuleEvent |
AbstractEnvelopeInterceptor.processBlocking(MuleEvent event) |
protected MuleEvent |
AbstractEnvelopeInterceptor.processNonBlocking(MuleEvent event) |
Modifier and Type | Method and Description |
---|---|
Serializable |
SHA256MuleEventKeyGenerator.generateKey(MuleEvent event) |
Serializable |
ExpressionMuleEventKeyGenerator.generateKey(MuleEvent event) |
Serializable |
MD5MuleEventKeyGenerator.generateKey(MuleEvent event)
Deprecated.
|
Modifier and Type | Method and Description |
---|---|
protected MuleEvent |
ProcessIfStartedMessageProcessor.handleUnaccepted(MuleEvent event) |
MuleEvent |
ProcessIfStartedWaitIfPausedMessageProcessor.process(MuleEvent event) |
MuleEvent |
ProcessIfStartedWaitIfSyncPausedMessageProcessor.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 |
ProcessIfStartedWaitIfPausedMessageProcessor.process(MuleEvent event) |
MuleEvent |
ProcessIfStartedWaitIfSyncPausedMessageProcessor.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 |
ProcessComponent.doInvoke(MuleEvent event) |
protected Object |
RulesComponent.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 |
CxfInboundMessageProcessor.process(MuleEvent event) |
MuleEvent |
CxfOutboundMessageProcessor.process(MuleEvent event) |
MuleEvent |
CxfInboundMessageProcessor.processNext(MuleEvent event) |
MuleEvent |
CxfOutboundMessageProcessor.processNext(MuleEvent event)
This method is public so it can be invoked from the MuleUniversalConduit.
|
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 |
CxfInboundMessageProcessor.process(MuleEvent event) |
MuleEvent |
CxfOutboundMessageProcessor.process(MuleEvent event) |
MuleEvent |
CxfInboundMessageProcessor.processNext(MuleEvent event) |
MuleEvent |
CxfOutboundMessageProcessor.processNext(MuleEvent event)
This method is public so it can be invoked from the MuleUniversalConduit.
|
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,
MessageProcessor failingMessageProcessor) |
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 |
---|---|
DataSourceConfig |
DataSourceConfig.resolve(MuleEvent muleEvent)
Resolves dataSource configuration using a given event
|
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 |
DynamicBulkUpdateMessageProcessor.executeQuery(DbConnection connection,
MuleEvent muleEvent) |
protected Object |
BulkExecuteMessageProcessor.executeQuery(DbConnection connection,
MuleEvent muleEvent) |
protected abstract Object |
AbstractDbMessageProcessor.executeQuery(DbConnection connection,
MuleEvent muleEvent) |
protected Object |
AbstractSingleQueryDbMessageProcessor.executeQuery(DbConnection connection,
MuleEvent muleEvent) |
List<FieldDebugInfo<?>> |
AbstractDbMessageProcessor.getDebugInfo(MuleEvent muleEvent) |
protected Iterator<Object> |
AbstractBulkUpdateMessageProcessor.getIterator(MuleEvent muleEvent) |
protected List<FieldDebugInfo<?>> |
PreparedBulkUpdateMessageProcessor.getMessageProcessorDebugInfo(DbConnection connection,
MuleEvent muleEvent) |
protected List<FieldDebugInfo<?>> |
DynamicBulkUpdateMessageProcessor.getMessageProcessorDebugInfo(DbConnection connection,
MuleEvent muleEvent) |
protected List<FieldDebugInfo<?>> |
BulkExecuteMessageProcessor.getMessageProcessorDebugInfo(DbConnection connection,
MuleEvent muleEvent) |
protected abstract List<FieldDebugInfo<?>> |
AbstractDbMessageProcessor.getMessageProcessorDebugInfo(DbConnection connection,
MuleEvent muleEvent) |
protected List<FieldDebugInfo<?>> |
AbstractSingleQueryDbMessageProcessor.getMessageProcessorDebugInfo(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 |
DynamicDbConfigResolver.resolve(MuleEvent muleEvent) |
DbConfig |
ConfiguredDbConfigResolver.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> |
ParamValueResolver.resolveParams(MuleEvent muleEvent,
List<QueryParamValue> templateParams)
Resolves query parameters
|
List<QueryParamValue> |
StaticParamValueResolver.resolveParams(MuleEvent muleEvent,
List<QueryParamValue> templateParams) |
List<QueryParamValue> |
DynamicParamValueResolver.resolveParams(MuleEvent muleEvent,
List<QueryParamValue> templateParams) |
Modifier and Type | Method and Description |
---|---|
protected BulkQuery |
AbstractBulkQueryResolver.createBulkQuery(MuleEvent muleEvent) |
protected BulkQuery |
StaticBulkQueryResolver.createBulkQuery(MuleEvent muleEvent) |
Query |
DynamicQueryResolver.resolve(DbConnection connection,
MuleEvent muleEvent) |
Query |
QueryResolver.resolve(DbConnection connection,
MuleEvent muleEvent)
Resolves a query in the context of a given Mule event.
|
Query |
StaticQueryResolver.resolve(DbConnection connection,
MuleEvent muleEvent) |
Query |
ParametrizedQueryResolver.resolve(DbConnection connection,
MuleEvent muleEvent) |
BulkQuery |
AbstractBulkQueryResolver.resolve(MuleEvent muleEvent) |
BulkQuery |
BulkQueryResolver.resolve(MuleEvent muleEvent)
Resolves a bulk query in the context of a given Mule event.
|
protected String |
AbstractBulkQueryResolver.resolveBulkQueries(MuleEvent muleEvent,
String bulkQuery) |
protected String |
FileBulkQueryResolver.resolveBulkQueries(MuleEvent muleEvent,
String bulkQuery) |
protected String |
DynamicBulkQueryResolver.resolveBulkQueries(MuleEvent muleEvent,
String bulkQuery) |
Modifier and Type | Method and Description |
---|---|
MuleEvent |
OperationContextAdapter.getEvent()
Returns the
MuleEvent on which
an operation is to be executed |
MuleEvent |
DefaultOperationContext.getEvent() |
Modifier and Type | Method and Description |
---|---|
Object |
ConfigurationObjectBuilder.build(MuleEvent event) |
T |
ObjectBuilder.build(MuleEvent event)
Returns a new instance of the specified class.
|
Constructor and Description |
---|
DefaultOperationContext(org.mule.extension.introspection.Extension extension,
org.mule.extension.introspection.Operation operation,
String configurationInstanceProviderName,
ResolverSetResult parameters,
MuleEvent event,
ExtensionManagerAdapter extensionManager)
Creates a new instance with the given state
|
Modifier and Type | Method and Description |
---|---|
MuleEvent |
OperationMessageProcessor.process(MuleEvent event) |
Modifier and Type | Method and Description |
---|---|
MuleEvent |
OperationMessageProcessor.process(MuleEvent event) |
Modifier and Type | Method and Description |
---|---|
MuleEvent |
EventArgumentResolver.resolve(org.mule.extension.runtime.OperationContext operationContext)
Resolves an argument's value from the given
operationContext |
Modifier and Type | Method and Description |
---|---|
T |
RegistryLookupValueResolver.resolve(MuleEvent event)
Returns the registry value associated with
RegistryLookupValueResolver.key |
T |
TypeSafeExpressionValueResolver.resolve(MuleEvent event) |
NestedProcessor |
NestedProcessorValueResolver.resolve(MuleEvent event)
Returns a
NestedProcessor that wraps the event |
Collection<T> |
CollectionValueResolver.resolve(MuleEvent event)
Passes the given
event to each resolvers and outputs
a collection of type collectionType with each result |
T |
StaticValueResolver.resolve(MuleEvent event)
Resolves a value from the given
event |
T |
ObjectBuilderValueResolver.resolve(MuleEvent event)
Delegates to
builder |
ResolverSetResult |
ResolverSet.resolve(MuleEvent event)
Evaluates all the added
ValueResolver s and returns the results into
a ResolverSetResult |
T |
ValueResolver.resolve(MuleEvent event)
Resolves a value from the given
event |
T |
CachingValueResolverWrapper.resolve(MuleEvent event)
Upon first invocation, the value is resolved using the
CachingValueResolverWrapper.delegate
and the return value is stored. |
Modifier and Type | Method and Description |
---|---|
static MuleEvent |
MuleExtensionUtils.getInitialiserEvent(MuleContext muleContext) |
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 |
HttpMapParam.resolve(ParameterMap parameterMap,
MuleEvent muleEvent) |
abstract void |
HttpParam.resolve(ParameterMap parameterMap,
MuleEvent muleEvent) |
void |
HttpSingleParam.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,
ListenerPath listenerPath) |
Modifier and Type | Method and Description |
---|---|
HttpResponse |
HttpResponseBuilder.build(HttpResponseBuilder httpResponseBuilder,
MuleEvent event) |
protected HttpResponse |
HttpMessageProcessorTemplate.buildResponse(MuleEvent muleEvent,
HttpResponseBuilder responseBuilder,
ResponseCompletionCallback responseCompletationCallback) |
protected HttpResponse |
HttpMessageProcessorTemplate.doBuildResponse(MuleEvent muleEvent,
HttpResponseBuilder responseBuilder,
ResponseCompletionCallback responseCompletationCallback) |
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 |
---|---|
protected MuleEvent |
DefaultHttpRequester.processBlocking(MuleEvent muleEvent) |
Modifier and Type | Method and Description |
---|---|
void |
DefaultHttpAuthentication.authenticate(MuleEvent muleEvent,
HttpRequestBuilder requestBuilder) |
void |
HttpResponseToMuleEvent.convert(MuleEvent muleEvent,
HttpResponse response,
String uri) |
HttpRequestBuilder |
MuleEventToHttpRequest.create(MuleEvent event,
String resolvedMethod,
String resolvedUri) |
List<FieldDebugInfo<?>> |
DefaultHttpRequester.getDebugInfo(MuleEvent event) |
ParameterMap |
HttpRequesterRequestBuilder.getHeaders(MuleEvent event) |
ParameterMap |
HttpRequesterRequestBuilder.getQueryParams(MuleEvent event) |
protected void |
DefaultHttpRequester.innerProcessNonBlocking(MuleEvent muleEvent,
CompletionHandler completionHandler,
boolean checkRetry) |
protected MuleEvent |
DefaultHttpRequester.processBlocking(MuleEvent muleEvent) |
protected void |
DefaultHttpRequester.processNonBlocking(MuleEvent muleEvent,
CompletionHandler completionHandler) |
String |
HttpRequesterRequestBuilder.replaceUriParams(String path,
MuleEvent event) |
HttpRequestAuthentication |
DefaultHttpAuthentication.resolveRequestAuthentication(MuleEvent event) |
boolean |
DefaultHttpAuthentication.shouldRetry(MuleEvent firstAttemptResponseEvent) |
void |
FailureStatusCodeValidator.validate(MuleEvent responseEvent) |
void |
ResponseValidator.validate(MuleEvent responseEvent) |
void |
SuccessStatusCodeValidator.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 |
---|---|
MuleEvent |
TokenNotFoundException.getTokenUrlResponse() |
MuleEvent |
AbstractTokenRequestHandler.TokenUrlResponseException.getTokenUrlResponse() |
protected MuleEvent |
AbstractTokenRequestHandler.invokeTokenUrl(MuleEvent event) |
Modifier and Type | Method and Description |
---|---|
protected MuleEvent |
AbstractTokenRequestHandler.invokeTokenUrl(MuleEvent event) |
void |
MuleEventLogger.logContent(MuleEvent muleEvent)
Logs the event message payload type, the payload as string and the message properties.
|
void |
TokenResponseProcessor.process(MuleEvent muleEvent) |
Constructor and Description |
---|
AbstractTokenRequestHandler.TokenUrlResponseException(MuleEvent tokenUrlResponse) |
TokenNotFoundException(MuleEvent tokenUrlResponse,
TokenResponseProcessor tokenResponseProcessor) |
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 |
AbstractAuthorizationCodeTokenRequestHandler.refreshToken(MuleEvent currentEvent,
String resourceOwnerId)
Updates the access token by calling the token url with refresh token grant type
|
void |
AuthorizationCodeGrantType.refreshToken(MuleEvent currentFlowEvent,
String resourceOwnerId)
Does a refresh token for a particular oauth context id.
|
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) |
protected void |
Scriptable.populatePropertyBindings(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,
MessageProcessor failingMessageProcessor) |
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) |
static XMLStreamReader |
XMLUtils.toXMLStreamReader(XMLInputFactory factory,
MuleEvent event,
Object obj)
Returns an XMLStreamReader for an object of unknown type if possible.
|
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 | Field and Description |
---|---|
protected MuleEvent |
BlockingProcessorExecutor.event |
Modifier and Type | Method and Description |
---|---|
protected MuleEvent |
InvokerMessageProcessor.createResultEvent(MuleEvent event,
Object result) |
protected MuleEvent |
SedaStageInterceptingMessageProcessor.dequeue() |
MuleEvent |
BlockingProcessorExecutor.execute() |
protected MuleEvent |
BlockingProcessorExecutor.executeNext() |
protected MuleEvent |
AbstractFilteringMessageProcessor.handleUnaccepted(MuleEvent event) |
MuleEvent |
InvokerMessageProcessor.process(MuleEvent event) |
MuleEvent |
AsyncDelegateMessageProcessor.process(MuleEvent event) |
MuleEvent |
IdempotentRedeliveryPolicy.process(MuleEvent event) |
MuleEvent |
NullMessageProcessor.process(MuleEvent event) |
MuleEvent |
StopFurtherMessageProcessingMessageProcessor.process(MuleEvent event) |
MuleEvent |
AbstractRequestResponseMessageProcessor.process(MuleEvent event) |
MuleEvent |
TransactionalInterceptingMessageProcessor.process(MuleEvent event) |
MuleEvent |
AbstractFilteringMessageProcessor.process(MuleEvent event) |
MuleEvent |
AbstractNonBlockingMessageProcessor.process(MuleEvent event) |
MuleEvent |
EndpointTransactionalInterceptingMessageProcessor.process(MuleEvent event) |
MuleEvent |
ExceptionHandlingMessageProcessor.process(MuleEvent event) |
MuleEvent |
AsyncInterceptingMessageProcessor.process(MuleEvent event) |
MuleEvent |
SecurityFilterMessageProcessor.process(MuleEvent event) |
MuleEvent |
AbstractDynamicMessageProcessor.process(MuleEvent event) |
protected MuleEvent |
AbstractRequestResponseMessageProcessor.processBlocking(MuleEvent event) |
protected abstract MuleEvent |
AbstractNonBlockingMessageProcessor.processBlocking(MuleEvent event) |
protected MuleEvent |
AbstractInterceptingMessageProcessorBase.processNext(MuleEvent event) |
protected MuleEvent |
AsyncInterceptingMessageProcessor.processNextTimed(MuleEvent event) |
protected MuleEvent |
AbstractRequestResponseMessageProcessor.processNonBlocking(MuleEvent event) |
protected MuleEvent |
AbstractRequestResponseMessageProcessor.processRequest(MuleEvent request)
Processes the request phase before the next message processor is invoked.
|
protected MuleEvent |
AbstractRequestResponseMessageProcessor.processResponse(MuleEvent response)
Deprecated.
|
protected MuleEvent |
ResponseMessageProcessorAdapter.processResponse(MuleEvent response,
MuleEvent request) |
protected MuleEvent |
AbstractRequestResponseMessageProcessor.processResponse(MuleEvent response,
MuleEvent request)
Processes the response phase after the next message processor and it's response phase have been invoked
|
Modifier and Type | Method and Description |
---|---|
protected abstract boolean |
AbstractFilteringMessageProcessor.accept(MuleEvent event) |
protected ReplyToHandler |
AbstractRequestResponseMessageProcessor.createReplyToHandler(MuleEvent request) |
protected MuleEvent |
InvokerMessageProcessor.createResultEvent(MuleEvent event,
Object result) |
protected void |
SedaStageInterceptingMessageProcessor.enqueue(MuleEvent event) |
protected Object[] |
InvokerMessageProcessor.evaluateArguments(MuleEvent event,
List<?> argumentTemplates) |
protected MessagingException |
AbstractFilteringMessageProcessor.filterFailureException(MuleEvent event,
Exception ex) |
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 |
AbstractNonBlockingMessageProcessor.isNonBlocking(MuleEvent event) |
protected boolean |
LaxSedaStageInterceptingMessageProcessor.isProcessAsync(MuleEvent event) |
protected boolean |
LaxAsyncInterceptingMessageProcessor.isProcessAsync(MuleEvent event) |
protected boolean |
AsyncInterceptingMessageProcessor.isProcessAsync(MuleEvent event) |
protected boolean |
BlockingProcessorExecutor.isUseEventCopy(MuleEvent result) |
MuleEvent |
InvokerMessageProcessor.process(MuleEvent event) |
MuleEvent |
AsyncDelegateMessageProcessor.process(MuleEvent event) |
MuleEvent |
IdempotentRedeliveryPolicy.process(MuleEvent event) |
MuleEvent |
NullMessageProcessor.process(MuleEvent event) |
MuleEvent |
StopFurtherMessageProcessingMessageProcessor.process(MuleEvent event) |
MuleEvent |
AbstractRequestResponseMessageProcessor.process(MuleEvent event) |
MuleEvent |
TransactionalInterceptingMessageProcessor.process(MuleEvent event) |
MuleEvent |
AbstractFilteringMessageProcessor.process(MuleEvent event) |
MuleEvent |
AbstractNonBlockingMessageProcessor.process(MuleEvent event) |
MuleEvent |
EndpointTransactionalInterceptingMessageProcessor.process(MuleEvent event) |
MuleEvent |
ExceptionHandlingMessageProcessor.process(MuleEvent event) |
MuleEvent |
AsyncInterceptingMessageProcessor.process(MuleEvent event) |
MuleEvent |
SecurityFilterMessageProcessor.process(MuleEvent event) |
MuleEvent |
AbstractDynamicMessageProcessor.process(MuleEvent event) |
protected MuleEvent |
AbstractRequestResponseMessageProcessor.processBlocking(MuleEvent event) |
protected abstract MuleEvent |
AbstractNonBlockingMessageProcessor.processBlocking(MuleEvent event) |
protected void |
AbstractRequestResponseMessageProcessor.processFinally(MuleEvent event,
MessagingException exception)
Used to perform post processing after both request and response phases have been completed.
|
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 |
AbstractRequestResponseMessageProcessor.processNonBlocking(MuleEvent event) |
protected abstract void |
AbstractNonBlockingMessageProcessor.processNonBlocking(MuleEvent event,
CompletionHandler completionHandler) |
protected MuleEvent |
AbstractRequestResponseMessageProcessor.processRequest(MuleEvent request)
Processes the request phase before the next message processor is invoked.
|
protected MuleEvent |
AbstractRequestResponseMessageProcessor.processResponse(MuleEvent response)
Deprecated.
|
protected MuleEvent |
ResponseMessageProcessorAdapter.processResponse(MuleEvent response,
MuleEvent request) |
protected MuleEvent |
AbstractRequestResponseMessageProcessor.processResponse(MuleEvent response,
MuleEvent request)
Processes the response phase after the next message processor and it's response phase have been invoked
|
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.
|
Constructor and Description |
---|
BlockingProcessorExecutor(MuleEvent event,
List<MessageProcessor> processors,
MessageProcessorExecutionTemplate messageProcessorExecutionTemplate,
boolean copyOnVoidEvent) |
NonBlockingProcessorExecutor(MuleEvent event,
List<MessageProcessor> processors,
MessageProcessorExecutionTemplate executionTemplate,
boolean copyOnVoidEvent) |
Modifier and Type | Method and Description |
---|---|
protected MuleEvent |
InterceptingChainLifecycleWrapper.doProcess(MuleEvent event) |
protected MuleEvent |
SimpleMessageProcessorChain.doProcess(MuleEvent event) |
protected abstract MuleEvent |
AbstractMessageProcessorChain.doProcess(MuleEvent event) |
protected MuleEvent |
DefaultMessageProcessorChain.doProcess(MuleEvent event) |
MuleEvent |
InterceptingChainLifecycleWrapper.process(MuleEvent event) |
MuleEvent |
AbstractMessageProcessorChain.process(MuleEvent event) |
MuleEvent |
SubflowInterceptingChainLifecycleWrapper.process(MuleEvent event) |
Modifier and Type | Method and Description |
---|---|
ProcessorExecutor |
ProcessorExecutorFactory.createProcessorExecutor(MuleEvent event,
List<MessageProcessor> processors,
MessageProcessorExecutionTemplate executionTemplate,
boolean copyOnVoidEvent) |
protected MuleEvent |
InterceptingChainLifecycleWrapper.doProcess(MuleEvent event) |
protected MuleEvent |
SimpleMessageProcessorChain.doProcess(MuleEvent event) |
protected abstract MuleEvent |
AbstractMessageProcessorChain.doProcess(MuleEvent event) |
protected MuleEvent |
DefaultMessageProcessorChain.doProcess(MuleEvent event) |
MuleEvent |
InterceptingChainLifecycleWrapper.process(MuleEvent event) |
MuleEvent |
AbstractMessageProcessorChain.process(MuleEvent event) |
MuleEvent |
SubflowInterceptingChainLifecycleWrapper.process(MuleEvent event) |
void |
NestedProcessorChain.setEvent(MuleEvent value)
Sets event
|
Constructor and Description |
---|
NestedProcessorChain(MuleEvent event,
MuleContext muleContext,
MessageProcessor chain) |
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
|
abstract MuleEvent |
AbstractCatchAllStrategy.doCatchMessage(MuleEvent event)
Deprecated.
|
MuleEvent |
ServiceCatchAllStrategy.doCatchMessage(MuleEvent event)
Deprecated.
|
MuleEvent |
LoggingCatchAllStrategy.doCatchMessage(MuleEvent event)
Deprecated.
|
MuleEvent |
ForwardingCatchAllStrategy.doCatchMessage(MuleEvent event)
Deprecated.
|
protected abstract MuleEvent |
AbstractUntilSuccessfulProcessingStrategy.doRoute(MuleEvent event) |
protected MuleEvent |
SynchronousUntilSuccessfulProcessingStrategy.doRoute(MuleEvent event) |
protected MuleEvent |
AsynchronousUntilSuccessfulProcessingStrategy.doRoute(MuleEvent event) |
MuleEvent |
EventGroup.getMessageCollectionEvent() |
MuleEvent |
Foreach.process(MuleEvent event) |
MuleEvent |
AbstractAggregator.process(MuleEvent event) |
MuleEvent |
AbstractSelectiveRouter.process(MuleEvent event) |
MuleEvent |
AbstractMatchingRouter.process(MuleEvent event) |
MuleEvent |
DynamicFirstSuccessful.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 |
ScatterGatherRouter.process(MuleEvent event) |
MuleEvent |
DynamicRoundRobin.process(MuleEvent event) |
MuleEvent |
Resequencer.process(MuleEvent event) |
MuleEvent |
WireTap.process(MuleEvent event) |
MuleEvent |
DynamicAll.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 |
RoundRobin.route(MuleEvent event)
Process the event using the next target route in sequence
|
MuleEvent |
UntilSuccessfulProcessingStrategy.route(MuleEvent event) |
protected MuleEvent |
UntilSuccessful.route(MuleEvent event) |
MuleEvent |
FirstSuccessful.route(MuleEvent event)
Route the given event to one of our targets
|
MuleEvent |
AbstractUntilSuccessfulProcessingStrategy.route(MuleEvent event) |
MuleEvent |
FirstSuccessfulRoutingStrategy.route(MuleEvent event,
List<MessageProcessor> messageProcessors) |
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) |
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
|
abstract MuleEvent |
AbstractCatchAllStrategy.doCatchMessage(MuleEvent event)
Deprecated.
|
MuleEvent |
ServiceCatchAllStrategy.doCatchMessage(MuleEvent event)
Deprecated.
|
MuleEvent |
LoggingCatchAllStrategy.doCatchMessage(MuleEvent event)
Deprecated.
|
MuleEvent |
ForwardingCatchAllStrategy.doCatchMessage(MuleEvent event)
Deprecated.
|
protected void |
Foreach.doProcess(MuleEvent event) |
protected abstract MuleEvent |
AbstractUntilSuccessfulProcessingStrategy.doRoute(MuleEvent event) |
protected MuleEvent |
SynchronousUntilSuccessfulProcessingStrategy.doRoute(MuleEvent event) |
protected MuleEvent |
AsynchronousUntilSuccessfulProcessingStrategy.doRoute(MuleEvent event) |
protected MessagingException |
MessageFilter.filterFailureException(MuleEvent event,
Exception ex) |
protected MuleException |
MessageFilter.filterUnacceptedException(MuleEvent event) |
protected String |
IdempotentSecureHashMessageFilter.getIdForEvent(MuleEvent event) |
protected String |
IdempotentMessageFilter.getIdForEvent(MuleEvent event) |
String |
DynamicRouteResolverAdapter.getRouteIdentifier(MuleEvent event) |
String |
IdentifiableDynamicRouteResolver.getRouteIdentifier(MuleEvent event)
Returns an identifier of the
DynamicRouteResolver . |
protected String |
IdempotentMessageFilter.getValueForEvent(MuleEvent event) |
protected boolean |
IdempotentMessageFilter.isNewMessage(MuleEvent event) |
protected boolean |
MessageChunkSplitter.isSplitRequired(MuleEvent event) |
MuleEvent |
Foreach.process(MuleEvent event) |
MuleEvent |
AbstractAggregator.process(MuleEvent event) |
MuleEvent |
AbstractSelectiveRouter.process(MuleEvent event) |
MuleEvent |
AbstractMatchingRouter.process(MuleEvent event) |
MuleEvent |
DynamicFirstSuccessful.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 |
ScatterGatherRouter.process(MuleEvent event) |
MuleEvent |
DynamicRoundRobin.process(MuleEvent event) |
MuleEvent |
Resequencer.process(MuleEvent event) |
MuleEvent |
WireTap.process(MuleEvent event) |
MuleEvent |
DynamicAll.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 |
RoundRobin.route(MuleEvent event)
Process the event using the next target route in sequence
|
MuleEvent |
UntilSuccessfulProcessingStrategy.route(MuleEvent event) |
protected MuleEvent |
UntilSuccessful.route(MuleEvent event) |
MuleEvent |
FirstSuccessful.route(MuleEvent event)
Route the given event to one of our targets
|
MuleEvent |
AbstractUntilSuccessfulProcessingStrategy.route(MuleEvent event) |
MuleEvent |
FirstSuccessfulRoutingStrategy.route(MuleEvent event,
List<MessageProcessor> messageProcessors) |
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) |
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> |
MapSplitter.splitMessage(MuleEvent event) |
protected abstract List<MuleMessage> |
AbstractSplitter.splitMessage(MuleEvent event) |
protected List<MuleMessage> |
ExpressionSplitter.splitMessage(MuleEvent event) |
protected List<MuleMessage> |
MessageChunkSplitter.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 |
EventGroup.initEventsStore(PartitionableObjectStore<MuleEvent> events) |
void |
AbstractAggregator.setEventGroupsObjectStore(PartitionableObjectStore<MuleEvent> eventGroupsObjectStore) |
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 |
EventCorrelatorCallback.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 |
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,
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 |
AbstractMessageSequenceSplitter.process(MuleEvent event) |
MuleEvent |
AbstractOutboundRouter.process(MuleEvent event) |
MuleEvent |
DefaultOutboundRouterCollection.process(MuleEvent event)
Deprecated.
|
protected abstract MuleEvent |
AbstractOutboundRouter.route(MuleEvent event) |
MuleEvent |
AbstractRecipientList.route(MuleEvent event) |
MuleEvent |
AbstractMessageSplitter.route(MuleEvent event) |
MuleEvent |
ExceptionBasedRouter.route(MuleEvent event)
Deprecated.
|
MuleEvent |
MessageChunkingRouter.route(MuleEvent event)
Deprecated.
|
MuleEvent |
AbstractSequenceRouter.route(MuleEvent event) |
MuleEvent |
ChainingRouter.route(MuleEvent event)
Deprecated.
|
MuleEvent |
TransformerRouter.route(MuleEvent event)
Deprecated.
|
MuleEvent |
FilteringOutboundRouter.route(MuleEvent event) |
MuleEvent |
EndpointSelector.route(MuleEvent event)
Deprecated.
|
MuleEvent |
OutboundPassThroughRouter.route(MuleEvent event)
Deprecated.
|
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 |
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 boolean |
SequenceRouter.continueRoutingMessageAfter(MuleEvent event)
Deprecated.
Determines if the routing should continue after receiving a given
response from an 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> |
ExpressionRecipientList.getRecipients(MuleEvent event) |
protected abstract List<Object> |
AbstractRecipientList.getRecipients(MuleEvent event) |
protected List<Object> |
StaticRecipientList.getRecipients(MuleEvent event)
Deprecated.
|
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 |
AbstractMessageSequenceSplitter.process(MuleEvent event) |
MuleEvent |
AbstractOutboundRouter.process(MuleEvent event) |
MuleEvent |
DefaultOutboundRouterCollection.process(MuleEvent event)
Deprecated.
|
protected List<MuleEvent> |
AbstractMessageSequenceSplitter.processParts(MessageSequence<?> seq,
MuleEvent originalEvent) |
protected abstract MuleEvent |
AbstractOutboundRouter.route(MuleEvent event) |
MuleEvent |
AbstractRecipientList.route(MuleEvent event) |
MuleEvent |
AbstractMessageSplitter.route(MuleEvent event) |
MuleEvent |
ExceptionBasedRouter.route(MuleEvent event)
Deprecated.
|
MuleEvent |
MessageChunkingRouter.route(MuleEvent event)
Deprecated.
|
MuleEvent |
AbstractSequenceRouter.route(MuleEvent event) |
MuleEvent |
ChainingRouter.route(MuleEvent event)
Deprecated.
|
MuleEvent |
TransformerRouter.route(MuleEvent event)
Deprecated.
|
MuleEvent |
FilteringOutboundRouter.route(MuleEvent event) |
MuleEvent |
EndpointSelector.route(MuleEvent event)
Deprecated.
|
MuleEvent |
OutboundPassThroughRouter.route(MuleEvent event)
Deprecated.
|
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 |
AbstractAsyncRequestReplyRequester.sendAsyncRequest(MuleEvent event) |
protected void |
SimpleAsyncRequestReplyRequester.sendAsyncRequest(MuleEvent event) |
protected void |
SimpleAsyncRequestReplyRequester.setAsyncReplyProperties(MuleEvent event) |
protected abstract boolean |
AbstractReplyToPropertyRequestReplyReplier.shouldProcessEvent(MuleEvent event) |
protected boolean |
ReplyToPropertyRequestReplyReplier.shouldProcessEvent(MuleEvent event) |
protected boolean |
AsyncReplyToPropertyRequestReplyReplier.shouldProcessEvent(MuleEvent event) |
Modifier and Type | Method and Description |
---|---|
MuleEvent |
DefaultMuleAuthentication.getEvent() |
Modifier and Type | Method and Description |
---|---|
void |
AbstractEndpointSecurityFilter.authenticate(MuleEvent event)
Deprecated.
|
void |
UsernamePasswordAuthenticationFilter.authenticate(MuleEvent event)
Authenticates the current message.
|
abstract void |
AbstractAuthenticationFilter.authenticate(MuleEvent event) |
protected abstract void |
AbstractEndpointSecurityFilter.authenticateInbound(MuleEvent event)
Deprecated.
|
protected abstract void |
AbstractEndpointSecurityFilter.authenticateOutbound(MuleEvent event)
Deprecated.
|
void |
AbstractEndpointSecurityFilter.doFilter(MuleEvent event)
Deprecated.
|
abstract void |
AbstractSecurityFilter.doFilter(MuleEvent event) |
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 |
BaseOAuth2Manager.restoreAuthorizationEvent(String eventId)
Recovers a MuleEvent from the object store.
|
MuleEvent |
OAuth2Manager.restoreAuthorizationEvent(String eventId)
Recovers a MuleEvent from the object store.
|
Modifier and Type | Method and Description |
---|---|
OAuth2Adapter |
BaseOAuth2Manager.createAdapter(MuleEvent event,
String verifier)
Create a new adapter using the specified verifier and insert it into the pool.
|
C |
OAuth2Manager.createAdapter(MuleEvent event,
String verifier)
Create a new adapter using the specified verifier and insert it into the pool.
|
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 |
BaseOAuth2Manager.storeAuthorizationEvent(MuleEvent event)
This method is expected to receive the
MuleEvent corresponding to
the execution of an OAuth2 authorize processor. |
void |
OAuth2Manager.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 |
BaseOAuth2AuthorizeMessageProcessor.doProcess(MuleEvent event)
Starts the OAuth authorization process
|
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 |
BaseOAuth1UnauthorizeMessageProcessor.doProcess(MuleEvent event)
Unauthorize the connector
|
protected MuleEvent |
BaseOAuth1AuthorizeMessageProcessor.doProcess(MuleEvent event)
Starts the OAuth authorization process
|
protected MuleEvent |
BaseOAuth2UnauthorizeMessageProcessor.doProcess(MuleEvent event)
Unauthorize the connector
|
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 |
BaseOAuth2AuthorizeMessageProcessor.doProcess(MuleEvent event)
Starts the OAuth authorization process
|
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 |
BaseOAuth1UnauthorizeMessageProcessor.doProcess(MuleEvent event)
Unauthorize the connector
|
protected MuleEvent |
BaseOAuth1AuthorizeMessageProcessor.doProcess(MuleEvent event)
Starts the OAuth authorization process
|
protected MuleEvent |
BaseOAuth2UnauthorizeMessageProcessor.doProcess(MuleEvent event)
Unauthorize the connector
|
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 |
---|---|
protected MuleEvent |
ServiceProcessorExecutor.executeNext() |
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
|
MuleEvent |
ServiceOutboundMessageProcessor.process(MuleEvent event)
Deprecated.
|
MuleEvent |
ServiceSetEventRequestContextMessageProcessor.process(MuleEvent event)
Deprecated.
|
MuleEvent |
ServiceStatisticsMessageProcessor.process(MuleEvent event)
Deprecated.
|
MuleEvent |
ServiceOutboundStatisticsMessageProcessor.process(MuleEvent event)
Deprecated.
|
MuleEvent |
ServiceLoggingMessageProcessor.process(MuleEvent event)
Deprecated.
|
Modifier and Type | Method and Description |
---|---|
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
|
MuleEvent |
ServiceOutboundMessageProcessor.process(MuleEvent event)
Deprecated.
|
MuleEvent |
ServiceSetEventRequestContextMessageProcessor.process(MuleEvent event)
Deprecated.
|
MuleEvent |
ServiceStatisticsMessageProcessor.process(MuleEvent event)
Deprecated.
|
MuleEvent |
ServiceOutboundStatisticsMessageProcessor.process(MuleEvent event)
Deprecated.
|
MuleEvent |
ServiceLoggingMessageProcessor.process(MuleEvent event)
Deprecated.
|
protected void |
ServiceInternalMessageProcessor.processReplyTo(MuleEvent event,
MuleEvent result,
ReplyToHandler replyToHandler,
Object replyTo)
Deprecated.
|
Constructor and Description |
---|
ServiceProcessorExecutor(MuleEvent event,
List<MessageProcessor> processors,
MessageProcessorExecutionTemplate messageProcessorExecutionTemplate,
boolean copyOnVoidEvent) |
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 |
AssertionMessageProcessor.process(MuleEvent event) |
MuleEvent |
ResponseAssertionMessageProcessor.process(MuleEvent event) |
MuleEvent |
InvocationCountMessageProcessor.process(MuleEvent event) |
MuleEvent |
ResponseAssertionMessageProcessor.processRequest(MuleEvent event) |
MuleEvent |
ResponseAssertionMessageProcessor.processResponse(MuleEvent event) |
Modifier and Type | Method and Description |
---|---|
protected void |
QuietExceptionStrategy.doHandleException(Exception e,
MuleEvent event) |
MuleEvent |
AssertionMessageProcessor.process(MuleEvent event) |
MuleEvent |
ResponseAssertionMessageProcessor.process(MuleEvent event) |
MuleEvent |
InvocationCountMessageProcessor.process(MuleEvent event) |
MuleEvent |
ResponseAssertionMessageProcessor.processRequest(MuleEvent event) |
MuleEvent |
ResponseAssertionMessageProcessor.processResponse(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
|
protected MuleEvent |
FunctionalTestCase.runFlowNonBlocking(String flowName)
Runs the given non blocking flow with a default event
|
protected MuleEvent |
FunctionalTestCase.runFlowNonBlocking(String flowName,
MuleEvent event)
Runs the given non blocking flow with a default event
|
protected MuleEvent |
FunctionalTestCase.runFlowNonBlocking(String flowName,
Object payload)
Runs the given non blocking flow with a given payload
|
Modifier and Type | Method and Description |
---|---|
protected MuleEvent |
FunctionalTestCase.runFlow(String flowName,
MuleEvent event)
Executes the given flow with the given
event |
protected MuleEvent |
FunctionalTestCase.runFlowNonBlocking(String flowName,
MuleEvent event)
Runs the given non blocking flow with a default event
|
protected void |
FunctionalTestCase.testFlow(String flowName,
MuleEvent event)
Looks up the given flow in the registry and processes it with the given event.
|
protected void |
FunctionalTestCase.testFlowNonBlocking(String flowName,
MuleEvent event)
Runs the given flow before ensuring all assertions defined in the flow configuration were met.
|
Modifier and Type | Method and Description |
---|---|
void |
FlowExecutionListener.addListener(Callback<MuleEvent> callback) |
Modifier and Type | Method and Description |
---|---|
MuleEvent |
FlowTraceUtils.FlowStackAsserter.process(MuleEvent event) |
MuleEvent |
FlowTraceUtils.FlowStackAsyncAsserter.process(MuleEvent event) |
Modifier and Type | Method and Description |
---|---|
MuleEvent |
FlowTraceUtils.FlowStackAsserter.process(MuleEvent event) |
MuleEvent |
FlowTraceUtils.FlowStackAsyncAsserter.process(MuleEvent event) |
Modifier and Type | Method and Description |
---|---|
boolean |
ConstraintFilter.accept(MuleEvent event) |
boolean |
ManualConstraint.accept(MuleEvent event) |
boolean |
BatchConstraint.accept(MuleEvent event) |
Modifier and Type | Method and Description |
---|---|
MuleEvent |
AbstractTransformer.process(MuleEvent event) |
MuleEvent |
CompositeConverter.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 |
AbstractTransformer.process(MuleEvent event) |
MuleEvent |
CompositeConverter.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 |
SetPayloadMessageProcessor.process(MuleEvent event) |
MuleEvent |
CombineCollectionsTransformer.process(MuleEvent event) |
Modifier and Type | Method and Description |
---|---|
MuleEvent |
SetPayloadMessageProcessor.process(MuleEvent event) |
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) |
protected abstract MuleEvent |
TransactedPollingMessageReceiver.processMessage(Object message) |
MuleEvent |
AbstractMessageReceiver.routeEvent(MuleEvent muleEvent) |
MuleEvent |
AbstractTransportMessageProcessTemplate.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 void |
AbstractMessageDispatcher.doSendNonBlocking(MuleEvent event,
CompletionHandler<MuleMessage,Exception> completionHandler) |
void |
AbstractConnector.fireNotification(ServerNotification notification,
MuleEvent event)
Fires a server notification to all registered listeners
on the
MuleContext of the given 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.
|
boolean |
AbstractConnector.isEnableMessageEvents(MuleEvent event)
Indicates if notifications are enabled for the given
event |
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 |
AbstractMessageReceiver.routeEvent(MuleEvent muleEvent) |
MuleEvent |
AbstractTransportMessageProcessTemplate.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 |
RetrieveMessageRequester.doDispatch(MuleEvent event) |
protected void |
SmtpMessageDispatcher.doDispatch(MuleEvent event) |
protected MuleMessage |
RetrieveMessageRequester.doSend(MuleEvent event) |
protected MuleMessage |
SmtpMessageDispatcher.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,
MessageProcessor failingMessageProcessor) |
RestServiceException(Message message,
MuleEvent event,
MessageProcessor failingMessageProcessor) |
RestServiceException(Message message,
MuleEvent event,
Throwable cause,
MessageProcessor failingMessageProcessor) |
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 |
---|---|
MuleEvent |
JdbcMessageReceiver.processMessage(Object message) |
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 |
SelectSqlStatementStrategy.executeStatement(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) |
Modifier and Type | Method and Description |
---|---|
protected MuleEvent |
XaTransactedJmsMessageReceiver.processMessage(Object msg) |
Modifier and Type | Method and Description |
---|---|
protected void |
JmsMessageDispatcher.applyOutboundTransformers(MuleEvent event) |
protected MessageConsumer |
JmsMessageDispatcher.createReplyToConsumer(Message jmsMessage,
MuleEvent event,
Session session,
Destination replyTo,
boolean topic) |
protected void |
JmsMessageDispatcher.doDispatch(MuleEvent event) |
protected MuleMessage |
JmsMessageDispatcher.doSend(MuleEvent event) |
protected void |
JmsMessageDispatcher.doSendNonBlocking(MuleEvent event,
CompletionHandler<MuleMessage,Exception> completionHandler) |
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 |
JmsMessageDispatcher.processMessage(Message msg,
MuleEvent event)
This method is called once the JMS message is created.
|
protected void |
JmsReplyToHandler.processMessage(Message replyToMessage,
MuleEvent event) |
void |
JmsReplyToHandler.processReplyTo(MuleEvent event,
MuleMessage returnMessage,
Object replyTo) |
protected String |
JmsMessageDispatcher.resolveJmsCorrelationId(MuleEvent event)
Resolve the value of correlationID that should be used for the JMS Message.
|
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 Object |
UpdateExpressionWatermark.getUpdatedValue(MuleEvent event)
Returns the new watermark value by evaluating
UpdateExpressionWatermark.updateExpression on the
flowVar of the given name |
protected abstract Object |
Watermark.getUpdatedValue(MuleEvent event)
This method is executed once the flow containing the poll has been executed.
|
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) |
void |
SftpClient.storeFile(String fileName,
MuleEvent event,
OutputHandler outputHandler) |
void |
SftpClient.storeFile(String fileName,
MuleEvent event,
OutputHandler outputHandler,
SftpClient.WriteMode mode) |
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 |
LocalSocketTcpMessageDispatcher.doDispatch(MuleEvent event) |
protected void |
TcpMessageDispatcher.doDispatch(MuleEvent event) |
protected MuleMessage |
LocalSocketTcpMessageDispatcher.doSend(MuleEvent event) |
protected MuleMessage |
TcpMessageDispatcher.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.processMessage(Object msg) |
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) |
AbstractMuleEventWork(MuleEvent event,
boolean copyEvent)
Constructor allowing event copying to be disabled.
|
ProcessingMuleEventWork(MessageProcessor messageProcessor,
MuleEvent muleEvent) |
Copyright © 2003–2016 MuleSoft, Inc.. All rights reserved.