Modifier and Type | Method and Description |
---|---|
MessageProcessor |
MessagingException.getFailingMessageProcessor() |
MessageProcessor |
MessageProcessorAnnotationParser.parseMessageProcessor(Annotation annotation)
Will create a Mule Router according to the annotation.
|
Constructor and Description |
---|
MessagingException(Message message,
MuleEvent event,
MessageProcessor failingMessageProcessor) |
MessagingException(Message message,
MuleEvent event,
Throwable cause,
MessageProcessor failingMessageProcessor) |
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 |
---|---|
HttpCallback |
HttpCallbackFactory.createCallback(HttpCallbackAdapter adapter,
String authCodeRegex,
FetchAccessTokenMessageProcessor fetchAccessTokenMessageProcessor,
MessageProcessor listener,
MuleContext muleContext,
FlowConstruct flowConstruct)
returns a new callback that has not been started
|
Modifier and Type | Interface and Description |
---|---|
interface |
Component
A
Component component processes a MuleEvent by invoking the
component instance that has been configured, optionally returning a result. |
interface |
InterfaceBinding |
interface |
JavaComponent
JavaComponent is a Java Component implementation used to
invoke Java component implementations. |
Modifier and Type | Method and Description |
---|---|
MessageProcessor |
ConnectorOperationProvider.getMessageProcessor(String url,
OperationOptions operationOptions,
MessageExchangePattern exchangePattern)
A
MessageProcessor that contains the behaviour for the URL |
MessageProcessor |
ConnectorOperationLocator.locateConnectorOperation(String url,
OperationOptions operationOptions,
MessageExchangePattern exchangePattern)
Lookup for an operation from a connector
|
Modifier and Type | Method and Description |
---|---|
List<MessageProcessor> |
Pipeline.getMessageProcessors() |
Modifier and Type | Method and Description |
---|---|
String |
MessageProcessorPathResolver.getProcessorPath(MessageProcessor processor) |
Modifier and Type | Method and Description |
---|---|
void |
Pipeline.setMessageProcessors(List<MessageProcessor> messageProcessors) |
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 | Interface and Description |
---|---|
interface |
OutboundEndpoint |
Modifier and Type | Method and Description |
---|---|
MessageProcessor |
EndpointMessageProcessorChainFactory.createInboundMessageProcessorChain(InboundEndpoint endpoint,
FlowConstruct flowConstruct,
MessageProcessor target) |
MessageProcessor |
EndpointMessageProcessorChainFactory.createOutboundMessageProcessorChain(OutboundEndpoint endpoint,
MessageProcessor target) |
Modifier and Type | Method and Description |
---|---|
List<MessageProcessor> |
ImmutableEndpoint.getMessageProcessors() |
List<MessageProcessor> |
ImmutableEndpoint.getResponseMessageProcessors() |
Modifier and Type | Method and Description |
---|---|
void |
EndpointBuilder.addMessageProcessor(MessageProcessor messageProcessor) |
void |
EndpointBuilder.addResponseMessageProcessor(MessageProcessor responseMessageProcessor) |
MessageProcessor |
EndpointMessageProcessorChainFactory.createInboundMessageProcessorChain(InboundEndpoint endpoint,
FlowConstruct flowConstruct,
MessageProcessor target) |
MessageProcessor |
EndpointMessageProcessorChainFactory.createOutboundMessageProcessorChain(OutboundEndpoint endpoint,
MessageProcessor target) |
Modifier and Type | Method and Description |
---|---|
void |
EndpointBuilder.setMessageProcessors(List<MessageProcessor> messageProcessors) |
void |
EndpointBuilder.setResponseMessageProcessors(List<MessageProcessor> responseMessageProcessors) |
Constructor and Description |
---|
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 | Interface and Description |
---|---|
interface |
Interceptor
Interceptor is based on a similar concept of servlet filters and
works much the same way. |
Modifier and Type | Interface and Description |
---|---|
interface |
InterceptingMessageProcessor
Processes
MuleEvent 's intercepting another listener
MessageProcessor . |
interface |
MessageProcessorChain |
interface |
MessageRouter
A
MessageProcessor that routes messages to zero or more destination
message processors. |
interface |
RequestReplyReplierMessageProcessor
Processes a
MuleEvent 's by invoking the next MessageProcessor and
then rather than returning the result to this processors MessageSource
sending it via a seperate reply MessageProcessor , |
Modifier and Type | Class and Description |
---|---|
class |
LoggerMessageProcessor
MessageProcessor implementation that logs the current element of a value evaluated from it using
an expression evaluator.
|
Modifier and Type | Method and Description |
---|---|
MessageProcessor |
MessageProcessorBuilder.build() |
MessageProcessor |
CloneableMessageProcessor.clone()
Creates a new instance cloned from the current one
|
MessageProcessor |
DefaultMessageProcessorPathElement.getMessageProcessor() |
MessageProcessor |
MessageProcessorPathElement.getMessageProcessor() |
static MessageProcessor |
MessageProcessors.lifecyleAwareMessageProcessorWrapper(MessageProcessor mp) |
Modifier and Type | Method and Description |
---|---|
List<MessageProcessor> |
MessageProcessorChain.getMessageProcessors() |
Modifier and Type | Method and Description |
---|---|
MessageProcessorPathElement |
DefaultMessageProcessorPathElement.addChild(MessageProcessor mp) |
MessageProcessorPathElement |
MessageProcessorPathElement.addChild(MessageProcessor mp) |
void |
MessageRouter.addRoute(MessageProcessor processor)
Adds a new message processor to the list of routes
|
MessageProcessorChainBuilder |
MessageProcessorChainBuilder.chain(MessageProcessor... processors) |
DynamicPipelineBuilder |
DynamicPipelineBuilder.injectAfter(MessageProcessor... messageProcessors)
Helper builder for injecting message processors to be executed
after the ones specified in the flow.
|
DynamicPipelineBuilder |
DynamicPipelineBuilder.injectBefore(MessageProcessor... messageProcessors)
Helper builder for injecting message processors to be executed
before the ones specified in the flow.
|
static MessageProcessor |
MessageProcessors.lifecyleAwareMessageProcessorWrapper(MessageProcessor mp) |
void |
MessageRouter.removeRoute(MessageProcessor processor)
Removes a message processor from the list of routes
|
void |
RequestReplyReplierMessageProcessor.setReplyProcessor(MessageProcessor replyMessageProcessor) |
static MessageProcessorChain |
MessageProcessors.singletonChain(MessageProcessor mp) |
Modifier and Type | Method and Description |
---|---|
void |
ProcessingStrategy.configureProcessors(List<MessageProcessor> processors,
StageNameSource nameSource,
MessageProcessorChainBuilder chainBuilder,
MuleContext muleContext) |
DynamicPipelineBuilder |
DynamicPipelineBuilder.injectAfter(List<MessageProcessor> messageProcessors)
Helper builder for injecting message processors to be executed
after the ones specified in the flow.
|
DynamicPipelineBuilder |
DynamicPipelineBuilder.injectBefore(List<MessageProcessor> messageProcessors)
Helper builder for injecting message processors to be executed
before the ones specified in the flow.
|
Constructor and Description |
---|
DefaultMessageProcessorPathElement(MessageProcessor messageProcessor,
String name) |
Modifier and Type | Interface and Description |
---|---|
interface |
MatchableMessageProcessor |
interface |
MatchableMessageRouter |
interface |
MatchingRouter
Routes the message to zero or more
MatchableMessageProcessor s. |
interface |
OutboundRouter
OutboundRouter is used to control outbound routing behaviour for an
event. |
interface |
OutboundRouterCatchAllStrategy
Deprecated.
|
interface |
OutboundRouterCollection
Deprecated.
|
interface |
SelectiveRouter
Routes the event to
MessageProcessor s using a Filter to
evaluate the event being processed and determine if a given route should be used. |
Modifier and Type | Field and Description |
---|---|
protected MessageProcessor |
RoutingException.route |
Modifier and Type | Method and Description |
---|---|
MessageProcessor |
RoutingException.getRoute() |
Modifier and Type | Method and Description |
---|---|
List<MessageProcessor> |
OutboundRouter.getRoutes()
Gets a list of MessageProcessor instances associated with this router
|
Modifier and Type | Method and Description |
---|---|
void |
SelectiveRouter.addRoute(MessageProcessor processor,
Filter filter) |
void |
SelectiveRouter.removeRoute(MessageProcessor processor) |
void |
SelectiveRouter.setDefaultRoute(MessageProcessor processor) |
void |
SelectiveRouter.updateRoute(MessageProcessor processor,
Filter filter) |
Constructor and Description |
---|
FilterUnacceptedException(Message message,
MuleEvent event,
Filter filter,
MessageProcessor failingMessageProcessor) |
FilterUnacceptedException(Message message,
MuleEvent event,
MessageProcessor failingMessageProcessor) |
Constructor and Description |
---|
EncryptionNotSupportedException(Message message,
MuleEvent event,
Throwable cause,
MessageProcessor failingMessageProcessor) |
NotPermittedException(Message message,
MuleEvent event,
Throwable cause,
MessageProcessor failingMessageProcessor) |
NotPermittedException(Message message,
Throwable cause,
MessageProcessor failingMessageProcessor) |
SecurityException(Message message,
MuleEvent event,
Throwable cause,
MessageProcessor failingMessageProcessor) |
Modifier and Type | Method and Description |
---|---|
MessageProcessor |
Service.getOutboundMessageProcessor()
Deprecated.
Outbound Routers control how events are published by a service once.
|
Modifier and Type | Method and Description |
---|---|
void |
Service.setOutboundMessageProcessor(MessageProcessor processor)
Deprecated.
Outbound message processor controls how events are published by a service once the
event has been processed.
|
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 |
---|---|
void |
MessageSource.setListener(MessageProcessor listener)
Set the MessageProcessor listener on a message source which will be invoked
when a message is received or generated.
|
Modifier and Type | Interface and Description |
---|---|
interface |
Converter
Defines a
Transformer that is a data type converters, ie: convert
data from a type to another without modifying the meaning of the data. |
interface |
DiscoverableTransformer
A interface to denote that a transformer is discoverable.
|
interface |
MessageTransformer
A transformer intended to transform Mule messages rather than arbitrary objects
|
interface |
Transformer
Transformer can be chained together to covert message payloads
from one object type to another. |
Modifier and Type | Interface and Description |
---|---|
interface |
MessageDispatcher
Combine
MessageDispatching with
various lifecycle methods for the actual instances doing message sending. |
Modifier and Type | Method and Description |
---|---|
void |
Connector.registerListener(InboundEndpoint endpoint,
MessageProcessor listener,
FlowConstruct flowConstruct)
Registers a MessageProcessor listener which will listen to new message
received from a specific transport channel and then processed by the endpoint.
|
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 | Class and Description |
---|---|
class |
AbstractComponent
|
class |
AbstractJavaComponent
Abstract implementation of JavaComponent adds JavaComponent specifics like
EntryPointResolverSet and ObjectFactory . |
class |
DefaultInterfaceBinding |
class |
DefaultJavaComponent
Default implementation of
JavaComponent . |
class |
PooledJavaComponent
PooledJavaComponent implements pooling. |
class |
SimpleCallableJavaComponent
Simple
JavaComponent implementation to be used when
LifecycleAdapter is not required because i) the object instance implements
Callable and so entry-point resolution is required and ii) component bindings
are not used.An ObjectFactory can be set but must return object
instances that implement Callable . |
Modifier and Type | Class and Description |
---|---|
class |
PassThroughComponent
Deprecated.
|
Modifier and Type | Class and Description |
---|---|
class |
ContentBasedRouter
Deprecated.
|
Modifier and Type | Method and Description |
---|---|
static Message |
CoreMessages.errorInvokingMessageProcessorAsynchronously(MessageProcessor processor) |
static Message |
CoreMessages.errorInvokingMessageProcessorWithinTransaction(MessageProcessor processor,
TransactionConfig transactionConfig) |
static Message |
CoreMessages.errorSchedulingMessageProcessorForAsyncInvocation(MessageProcessor processor) |
static Message |
CoreMessages.failedToRouterViaEndpoint(MessageProcessor target) |
Modifier and Type | Field and Description |
---|---|
protected MessageProcessor |
PollingMessageSourceFactoryBean.messageProcessor |
Modifier and Type | Method and Description |
---|---|
protected MessageProcessor |
FlowRefFactoryBean.createDynamicReferenceMessageProcessor(String name) |
MessageProcessor |
FlowRefFactoryBean.getObject() |
protected MessageProcessor |
FlowRefFactoryBean.getReferencedFlow(String name,
FlowConstruct flowConstruct) |
protected MessageProcessor |
FlowRefFactoryBean.lookupReferencedFlowInApplicationContext(String name) |
Modifier and Type | Method and Description |
---|---|
void |
PollingMessageSourceFactoryBean.setMessageProcessor(MessageProcessor messageProcessor) |
void |
ValidatorFactoryBean.setMessageProcessor(MessageProcessor processor) |
void |
SimpleServiceFactoryBean.setMessageProcessor(MessageProcessor component) |
void |
BridgeFactoryBean.setMessageProcessor(MessageProcessor processor) |
Modifier and Type | Method and Description |
---|---|
void |
MessageProcessorFilterPairFactoryBean.setMessageProcessors(List<MessageProcessor> messageProcessors) |
void |
ScatterGatherRouterFactoryBean.setMessageProcessors(List<MessageProcessor> messageProcessors) |
Modifier and Type | Class and Description |
---|---|
class |
AnnotatedTransformerProxy
Creates a Mule
Transformer proxy around a transform method. |
Modifier and Type | Method and Description |
---|---|
MessageProcessor |
MuleConnectorOperationLocator.locateConnectorOperation(String url,
OperationOptions operationOptions,
MessageExchangePattern exchangePattern) |
Modifier and Type | Class and Description |
---|---|
class |
AbstractPipeline.ProcessIfPipelineStartedMessageProcessor |
class |
DynamicPipelineMessageProcessor
Experimental implementation that supports a single dynamic pipeline due to restrictions
imposed by intercepting message processors and their lifecycle.
|
class |
Flow
This implementation of
AbstractPipeline adds the following functionality:
Rejects inbound events when Flow is not started
Gathers statistics and processing time data
Implements MessagePorcessor allowing direct invocation of the pipeline
Supports the optional configuration of a ProcessingStrategy that determines how message
processors are processed. |
Modifier and Type | Field and Description |
---|---|
protected MessageProcessor |
AbstractPipeline.pipeline |
Modifier and Type | Field and Description |
---|---|
protected List<MessageProcessor> |
AbstractPipeline.messageProcessors |
protected List<MessageProcessor> |
AbstractConfigurationPattern.responseTransformers |
protected List<MessageProcessor> |
AbstractConfigurationPattern.transformers |
Modifier and Type | Method and Description |
---|---|
protected MessageProcessor |
AbstractPipeline.createPipeline()
Creates a
MessageProcessor that will process messages from the configured MessageSource
. |
Modifier and Type | Method and Description |
---|---|
List<MessageProcessor> |
AbstractPipeline.getMessageProcessors() |
Modifier and Type | Method and Description |
---|---|
String |
AbstractPipeline.getProcessorPath(MessageProcessor processor) |
void |
DynamicPipelineMessageProcessor.setListener(MessageProcessor next) |
Modifier and Type | Method and Description |
---|---|
void |
AbstractPipeline.setMessageProcessors(List<MessageProcessor> messageProcessors) |
Constructor and Description |
---|
AbstractConfigurationPattern(String name,
MuleContext muleContext,
List<MessageProcessor> transformers,
List<MessageProcessor> responseTransformers) |
AbstractConfigurationPattern(String name,
MuleContext muleContext,
List<MessageProcessor> transformers,
List<MessageProcessor> responseTransformers) |
Bridge(String name,
MuleContext muleContext,
MessageSource messageSource,
OutboundEndpoint outboundEndpoint,
List<MessageProcessor> transformers,
List<MessageProcessor> responseTransformers,
MessageExchangePattern exchangePattern,
boolean transacted) |
Bridge(String name,
MuleContext muleContext,
MessageSource messageSource,
OutboundEndpoint outboundEndpoint,
List<MessageProcessor> transformers,
List<MessageProcessor> responseTransformers,
MessageExchangePattern exchangePattern,
boolean transacted) |
SimpleService(String name,
MuleContext muleContext,
MessageSource messageSource,
List<MessageProcessor> transformers,
List<MessageProcessor> responseTransformers,
Component component,
SimpleService.Type type) |
SimpleService(String name,
MuleContext muleContext,
MessageSource messageSource,
List<MessageProcessor> transformers,
List<MessageProcessor> responseTransformers,
Component component,
SimpleService.Type type) |
Modifier and Type | Field and Description |
---|---|
protected List<MessageProcessor> |
AbstractFlowConstructBuilder.responseTransformers |
protected List<MessageProcessor> |
AbstractFlowConstructBuilder.transformers |
Modifier and Type | Class and Description |
---|---|
class |
FlowConstructStatisticsMessageProcessor |
Modifier and Type | Field and Description |
---|---|
protected MessageProcessor |
AsyncMessageNotification.messageProcessor |
Modifier and Type | Method and Description |
---|---|
MessageProcessor |
AsyncMessageNotification.getMessageProcessor() |
MessageProcessor |
MessageProcessorNotification.getProcessor() |
Modifier and Type | Method and Description |
---|---|
Map<String,Object> |
MessageProcessingFlowTraceManager.getContextInfo(MuleEvent muleEvent,
MessageProcessor lastProcessed) |
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) |
Modifier and Type | Method and Description |
---|---|
protected String |
ExpressionEvaluatorSupport.getAccessTokenId(MuleEvent event,
MessageProcessor processor,
OAuth2Manager<?> oauthManager) |
Modifier and Type | Class and Description |
---|---|
class |
ExpressionLanguageComponent |
Modifier and Type | Class and Description |
---|---|
class |
DefaultOutboundEndpoint |
class |
DynamicOutboundEndpoint
An Outbound endpoint who's URI is a template used to created new non dynamic
endpoints based on the current message.
|
class |
DynamicURIOutboundEndpoint
Allows EndpointURI to be set and changed dynamically by wrapping up an immutable
endpoint instance.
|
Modifier and Type | Field and Description |
---|---|
protected List<MessageProcessor> |
AbstractEndpointBuilder.messageProcessors |
protected List<MessageProcessor> |
AbstractEndpointBuilder.responseMessageProcessors |
Modifier and Type | Method and Description |
---|---|
protected List<MessageProcessor> |
AbstractEndpointBuilder.addResponseTransformerProcessors(EndpointURI endpointURI) |
protected List<MessageProcessor> |
AbstractEndpointBuilder.addTransformerProcessors(EndpointURI endpointURI) |
protected List<MessageProcessor> |
DefaultEndpointMessageProcessorChainFactory.createInboundMessageProcessors(InboundEndpoint endpoint)
Override this method to change the default MessageProcessors.
|
protected List<MessageProcessor> |
DefaultEndpointMessageProcessorChainFactory.createInboundResponseMessageProcessors(InboundEndpoint endpoint)
Override this method to change the default MessageProcessors.
|
protected List<MessageProcessor> |
DefaultEndpointMessageProcessorChainFactory.createOutboundMessageProcessors(OutboundEndpoint endpoint)
Override this method to change the default MessageProcessors.
|
protected List<MessageProcessor> |
DefaultEndpointMessageProcessorChainFactory.createOutboundResponseMessageProcessors(OutboundEndpoint endpoint)
Override this method to change the default MessageProcessors.
|
List<MessageProcessor> |
AbstractEndpoint.getMessageProcessors() |
List<MessageProcessor> |
DynamicURIInboundEndpoint.getMessageProcessors() |
List<MessageProcessor> |
DynamicOutboundEndpoint.getMessageProcessors() |
List<MessageProcessor> |
DynamicURIOutboundEndpoint.getMessageProcessors() |
List<MessageProcessor> |
AbstractEndpointBuilder.getMessageProcessors() |
List<MessageProcessor> |
AbstractEndpoint.getResponseMessageProcessors() |
List<MessageProcessor> |
DynamicURIInboundEndpoint.getResponseMessageProcessors() |
List<MessageProcessor> |
DynamicOutboundEndpoint.getResponseMessageProcessors() |
List<MessageProcessor> |
DynamicURIOutboundEndpoint.getResponseMessageProcessors() |
List<MessageProcessor> |
AbstractEndpointBuilder.getResponseMessageProcessors() |
Modifier and Type | Method and Description |
---|---|
void |
AbstractEndpointBuilder.addMessageProcessor(MessageProcessor messageProcessor) |
void |
AbstractEndpointBuilder.addResponseMessageProcessor(MessageProcessor messageProcessor) |
MessageProcessor |
DefaultEndpointMessageProcessorChainFactory.createInboundMessageProcessorChain(InboundEndpoint endpoint,
FlowConstruct flowConstruct,
MessageProcessor target) |
MessageProcessor |
DefaultEndpointMessageProcessorChainFactory.createOutboundMessageProcessorChain(OutboundEndpoint endpoint,
MessageProcessor target) |
void |
DynamicURIInboundEndpoint.setListener(MessageProcessor listener) |
void |
DefaultInboundEndpoint.setListener(MessageProcessor listener) |
Modifier and Type | Method and Description |
---|---|
protected InboundEndpoint |
AbstractEndpointBuilder.createInboundEndpoint(EndpointURI endpointURI,
List<MessageProcessor> mergedProcessors,
List<MessageProcessor> mergedResponseProcessors,
Connector connector) |
protected InboundEndpoint |
AbstractEndpointBuilder.createInboundEndpoint(EndpointURI endpointURI,
List<MessageProcessor> mergedProcessors,
List<MessageProcessor> mergedResponseProcessors,
Connector connector) |
protected OutboundEndpoint |
AbstractEndpointBuilder.createOutboundEndpoint(EndpointURI endpointURI,
List<MessageProcessor> messageProcessors,
List<MessageProcessor> responseMessageProcessors,
Connector connector) |
protected OutboundEndpoint |
AbstractEndpointBuilder.createOutboundEndpoint(EndpointURI endpointURI,
List<MessageProcessor> messageProcessors,
List<MessageProcessor> responseMessageProcessors,
Connector connector) |
void |
AbstractEndpointBuilder.setMessageProcessors(List<MessageProcessor> newMessageProcessors) |
void |
AbstractEndpointBuilder.setResponseMessageProcessors(List<MessageProcessor> newResponseMessageProcessors) |
Constructor and Description |
---|
AbstractEndpoint(Connector connector,
EndpointURI endpointUri,
String name,
Map properties,
TransactionConfig transactionConfig,
boolean deleteUnacceptedMessages,
MessageExchangePattern messageExchangePattern,
int responseTimeout,
String initialState,
String endpointEncoding,
String endpointBuilderName,
MuleContext muleContext,
RetryPolicyTemplate retryPolicyTemplate,
AbstractRedeliveryPolicy redeliveryPolicy,
EndpointMessageProcessorChainFactory messageProcessorsFactory,
List<MessageProcessor> messageProcessors,
List<MessageProcessor> responseMessageProcessors,
boolean disableTransportTransformer,
String endpointMimeType) |
AbstractEndpoint(Connector connector,
EndpointURI endpointUri,
String name,
Map properties,
TransactionConfig transactionConfig,
boolean deleteUnacceptedMessages,
MessageExchangePattern messageExchangePattern,
int responseTimeout,
String initialState,
String endpointEncoding,
String endpointBuilderName,
MuleContext muleContext,
RetryPolicyTemplate retryPolicyTemplate,
AbstractRedeliveryPolicy redeliveryPolicy,
EndpointMessageProcessorChainFactory messageProcessorsFactory,
List<MessageProcessor> messageProcessors,
List<MessageProcessor> responseMessageProcessors,
boolean disableTransportTransformer,
String endpointMimeType) |
DefaultInboundEndpoint(Connector connector,
EndpointURI endpointUri,
String name,
Map properties,
TransactionConfig transactionConfig,
boolean deleteUnacceptedMessage,
MessageExchangePattern messageExchangePattern,
int responseTimeout,
String initialState,
String endpointEncoding,
String endpointBuilderName,
MuleContext muleContext,
RetryPolicyTemplate retryPolicyTemplate,
AbstractRedeliveryPolicy redeliveryPolicy,
EndpointMessageProcessorChainFactory messageProcessorsFactory,
List<MessageProcessor> messageProcessors,
List<MessageProcessor> responseMessageProcessors,
boolean disableTransportTransformer,
String mimeType) |
DefaultInboundEndpoint(Connector connector,
EndpointURI endpointUri,
String name,
Map properties,
TransactionConfig transactionConfig,
boolean deleteUnacceptedMessage,
MessageExchangePattern messageExchangePattern,
int responseTimeout,
String initialState,
String endpointEncoding,
String endpointBuilderName,
MuleContext muleContext,
RetryPolicyTemplate retryPolicyTemplate,
AbstractRedeliveryPolicy redeliveryPolicy,
EndpointMessageProcessorChainFactory messageProcessorsFactory,
List<MessageProcessor> messageProcessors,
List<MessageProcessor> responseMessageProcessors,
boolean disableTransportTransformer,
String mimeType) |
DefaultOutboundEndpoint(Connector connector,
EndpointURI endpointUri,
String name,
Map properties,
TransactionConfig transactionConfig,
boolean deleteUnacceptedMessage,
MessageExchangePattern messageExchangePattern,
int responseTimeout,
String initialState,
String endpointEncoding,
String endpointBuilderName,
MuleContext muleContext,
RetryPolicyTemplate retryPolicyTemplate,
AbstractRedeliveryPolicy redeliveryPolicy,
String responsePropertiesList,
EndpointMessageProcessorChainFactory messageProcessorsFactory,
List<MessageProcessor> messageProcessors,
List<MessageProcessor> responseMessageProcessors,
boolean disableTransportTransformer,
String endpointMimeType) |
DefaultOutboundEndpoint(Connector connector,
EndpointURI endpointUri,
String name,
Map properties,
TransactionConfig transactionConfig,
boolean deleteUnacceptedMessage,
MessageExchangePattern messageExchangePattern,
int responseTimeout,
String initialState,
String endpointEncoding,
String endpointBuilderName,
MuleContext muleContext,
RetryPolicyTemplate retryPolicyTemplate,
AbstractRedeliveryPolicy redeliveryPolicy,
String responsePropertiesList,
EndpointMessageProcessorChainFactory messageProcessorsFactory,
List<MessageProcessor> messageProcessors,
List<MessageProcessor> responseMessageProcessors,
boolean disableTransportTransformer,
String endpointMimeType) |
Modifier and Type | Class and Description |
---|---|
class |
InboundEndpointMimeTypeCheckingMessageProcessor
Verify that the inbound mime type is acceptable by this endpoint.
|
class |
InboundEndpointPropertyMessageProcessor
Sets the inbound endpoint uri on as a property of the message using the following
key:
MuleProperties.MULE_ORIGINATING_ENDPOINT_PROPERTY . |
class |
InboundExceptionDetailsMessageProcessor
Sets error message properties as specified by the transport based on the exception
type of the exception payload.
|
class |
InboundLoggingMessageProcessor |
class |
InboundNotificationMessageProcessor
Publishes a
EndpointMessageNotification 's when a message is received. |
Modifier and Type | Class and Description |
---|---|
class |
OutboundEndpointMimeTypeCheckingMessageProcessor
Verify that the outbound mime type is acceptable by this endpoint.
|
class |
OutboundEndpointPropertyMessageProcessor
Sets the outbound endpoint uri on as a property of the message using the following key:
MuleProperties.MULE_ENDPOINT_PROPERTY . |
class |
OutboundEventTimeoutMessageProcessor |
class |
OutboundLoggingMessageProcessor |
class |
OutboundNotificationMessageProcessor
Publishes a
EndpointMessageNotification 's when a message is sent or dispatched. |
class |
OutboundResponsePropertiesMessageProcessor
Propagates properties from request message to response message as defined by
OutboundEndpoint.getResponseProperties() . |
class |
OutboundRootMessageIdPropertyMessageProcessor
Sets the outbound root message id on as a property of the message using the following key:
MuleProperties.MULE_ROOT_MESSAGE_ID_PROPERTY . |
class |
OutboundSessionHandlerMessageProcessor
Stores session information on the outbound message.
|
class |
OutboundTxRollbackMessageProcessor
MessageProcessor implementation that stops outbound flow is the current
transaction has been rolled back.
|
Modifier and Type | Class and Description |
---|---|
class |
MessageEnricher
The
Message Enricher allows the current message to be augmented using data from a seperate
resource. |
Modifier and Type | Method and Description |
---|---|
protected List<MessageProcessor> |
MessageEnricher.getOwnedMessageProcessors() |
Modifier and Type | Method and Description |
---|---|
void |
MessageEnricher.setEnrichmentMessageProcessor(MessageProcessor enrichmentProcessor) |
void |
MessageEnricher.setMessageProcessor(MessageProcessor enrichmentProcessor)
For spring
|
Modifier and Type | Class and Description |
---|---|
class |
RedeliveryExceeded |
Modifier and Type | Field and Description |
---|---|
protected List<MessageProcessor> |
AbstractExceptionListener.messageProcessors |
Modifier and Type | Method and Description |
---|---|
List<MessageProcessor> |
RedeliveryExceeded.getMessageProcessors() |
List<MessageProcessor> |
AbstractExceptionListener.getMessageProcessors() |
protected List<MessageProcessor> |
AbstractExceptionListener.getOwnedMessageProcessors() |
protected List<MessageProcessor> |
RollbackMessagingExceptionStrategy.getOwnedMessageProcessors() |
Modifier and Type | Method and Description |
---|---|
void |
AbstractExceptionListener.addEndpoint(MessageProcessor processor) |
Map<String,Object> |
MessagingExceptionLocationProvider.getContextInfo(MuleEvent event,
MessageProcessor lastProcessed) |
protected String |
MessagingExceptionLocationProvider.getProcessorPath(MuleEvent event,
MessageProcessor lastProcessed) |
boolean |
AbstractExceptionListener.removeMessageProcessor(MessageProcessor processor) |
protected void |
AbstractExceptionListener.routeException(MuleEvent event,
MessageProcessor target,
Throwable t)
Deprecated.
|
Modifier and Type | Method and Description |
---|---|
void |
RedeliveryExceeded.setMessageProcessors(List<MessageProcessor> processors) |
void |
AbstractExceptionListener.setMessageProcessors(List<MessageProcessor> processors) |
Modifier and Type | Method and Description |
---|---|
MuleEvent |
MessageProcessorExecutionTemplate.execute(MessageProcessor messageProcessor,
MuleEvent event) |
MuleEvent |
MessageProcessorExecutionInterceptor.execute(MessageProcessor messageProcessor,
MuleEvent event) |
MuleEvent |
ExceptionToMessagingExceptionExecutionInterceptor.execute(MessageProcessor messageProcessor,
MuleEvent event) |
Modifier and Type | Method and Description |
---|---|
protected MessageProcessor |
MessageProcessorExpressionEvaluator.lookupMessageProcessor(String processorName,
MuleContext muleContext) |
Modifier and Type | Class and Description |
---|---|
class |
AbstractExpressionTransformer
This transformer will evaluate one or more expressions on the current message and return the
results as an Array.
|
class |
BeanBuilderTransformer
This transformer uses the returnClass to create the return object and then will populate the bean
with arguments defined as expressions
|
class |
ExpressionTransformer
This transformer will evaluate one or more expressions on the current message and return the
results as an Array.
|
Modifier and Type | Class and Description |
---|---|
class |
AbstractEnvelopeInterceptor
EnvelopeInterceptor is an intercepter that will fire before and after
an event is received. |
class |
InterceptorStack
Maintains a list of interceptors that can be applied to components.
|
class |
LoggingInterceptor
LoggingInterceptor is a simple interceptor that logs a message before
and after the event processing. |
class |
ProcessingTimeInterceptor
Calculate and record the processing time for a message processing chain
|
class |
TimerInterceptor
TimerInterceptor simply times and displays the time taken to process
an event. |
Constructor and Description |
---|
ProcessingTimeInterceptor(MessageProcessor next,
FlowConstruct fc) |
Modifier and Type | Class and Description |
---|---|
class |
ProcessIfStartedMessageProcessor |
class |
ProcessIfStartedWaitIfPausedMessageProcessor |
class |
ProcessIfStartedWaitIfSyncPausedMessageProcessor |
Modifier and Type | Class and Description |
---|---|
class |
SedaService
Deprecated.
|
Modifier and Type | Method and Description |
---|---|
protected MessageProcessor |
SedaService.getServiceStartedAssertingMessageProcessor()
Deprecated.
|
Modifier and Type | Class and Description |
---|---|
class |
AbderaServiceComponent
This component receives requests from Mule and passes them off to Abdera.
|
Modifier and Type | Class and Description |
---|---|
class |
FeedSplitter
An inbound router that will split a Feed into entries.
|
Modifier and Type | Class and Description |
---|---|
class |
AtomEntryBuilderTransformer |
class |
BaseToOutputHandler
Converts Abdera model elements which extend
Base to OutputHandlers. |
class |
ObjectToFeed
ObjectToInputStream converts serilaizable object to a input stream but
treats java.lang.String differently by converting to bytes using
the String.getBytes() method. |
Modifier and Type | Class and Description |
---|---|
class |
ProcessComponent
A service backed by the execution of a business process such as jBPM.
|
class |
RulesComponent
A service backed by a Business Rules engine such as Drools.
|
Modifier and Type | Class and Description |
---|---|
class |
CxfInboundMessageProcessor
The CxfInboundMessageProcessor performs inbound CXF processing, sending an event
through the CXF service, then on to the next MessageProcessor.
|
class |
CxfOutboundMessageProcessor
The CxfOutboundMessageProcessor performs outbound CXF processing, sending an event
through the CXF client, then on to the next MessageProcessor.
|
Modifier and Type | Method and Description |
---|---|
MessageProcessor |
CxfOutboundMessageProcessor.clone() |
Modifier and Type | Class and Description |
---|---|
class |
AbstractWebServiceWrapperComponent |
class |
WebServiceWrapperComponent
Deprecated.
|
Modifier and Type | Class and Description |
---|---|
class |
FlowConfiguringMessageProcessor
Wraps a
MessageProcessorBuilder and configures it lazily so it can
be injected with the FlowConstruct . |
Modifier and Type | Method and Description |
---|---|
MessageProcessor |
FlowConfiguringMessageProcessor.getWrappedMessageProcessor()
The MessageProcessor that this class built.
|
Modifier and Type | Method and Description |
---|---|
void |
FlowConfiguringMessageProcessor.setListener(MessageProcessor listener) |
Constructor and Description |
---|
WebServiceSecurityException(MuleEvent event,
Throwable cause,
MessageProcessor failingMessageProcessor) |
Modifier and Type | Method and Description |
---|---|
MessageProcessor |
BulkUpdateMessageProcessorFactoryBean.getObject() |
Modifier and Type | Class and Description |
---|---|
class |
AbstractBulkUpdateMessageProcessor
Defines a base class for single query bulk update operations
|
class |
AbstractDbMessageProcessor
Base class for database message processors.
|
class |
AbstractSingleQueryDbMessageProcessor
Base class for message processors processing only one query
|
class |
BulkExecuteMessageProcessor
Executes an queries in bulk mode on a database
*
Accepted queries are any query with no parameters and returning an update count as result.
|
class |
DynamicBulkUpdateMessageProcessor
Executes an update dynamic query in bulk mode on a database
*
A dynamic update query can be update, insert or delete query or a stored procedure
taking input parameters only and returning an update count.
|
class |
ExecuteDdlMessageProcessor
Executes a DDL query on a database
Both database and bulk query are resolved, if required, using the
MuleEvent
being processed. |
class |
PreparedBulkUpdateMessageProcessor
Executes an update query in bulk mode on a database
*
An update query can be parametrized update, insert or delete query or a stored procedure
taking input parameters only and returning an update count.
|
class |
SelectMessageProcessor
Executes a select query on a database
Accepted queries are select queries or stored procedure queries taking input parameters
and returning only a resultSet.
|
class |
StoredProcedureMessageProcessor
Executes an stored procedure query on a database.
|
class |
UpdateMessageProcessor
Executes an update query on a database.
|
Constructor and Description |
---|
OperationMessageProcessorFactoryBean(String configurationInstanceProviderName,
org.mule.extension.introspection.Extension extension,
org.mule.extension.introspection.Operation operation,
ElementDescriptor element,
Map<String,List<MessageProcessor>> nestedOperations,
MuleContext muleContext) |
Modifier and Type | Class and Description |
---|---|
class |
OperationMessageProcessor
A
MessageProcessor capable of executing extension operations. |
Constructor and Description |
---|
NestedProcessorValueResolver(MessageProcessor messageProcessor) |
Modifier and Type | Method and Description |
---|---|
void |
DefaultHttpListener.setListener(MessageProcessor messageProcessor) |
Constructor and Description |
---|
HttpMessageProcessorTemplate(MuleEvent sourceMuleEvent,
MessageProcessor messageProcessor,
HttpResponseReadyCallback responseReadyCallback,
HttpResponseBuilder responseBuilder,
HttpResponseBuilder errorResponseBuilder) |
Modifier and Type | Class and Description |
---|---|
class |
DefaultHttpRequester |
Modifier and Type | Class and Description |
---|---|
class |
OneWayHttpRequesterAdapter
Adapts an HTTP operation to be one-way.
|
Modifier and Type | Method and Description |
---|---|
MessageProcessor |
HttpConnectorMessageProcessorProvider.getMessageProcessor(String url,
OperationOptions operationOptions,
MessageExchangePattern exchangePattern) |
Constructor and Description |
---|
OneWayHttpRequesterAdapter(MessageProcessor httpRequester) |
Modifier and Type | Class and Description |
---|---|
class |
JerseyResourcesComponent
Wraps a set of components which can get invoked by Jersey.
|
Modifier and Type | Method and Description |
---|---|
void |
JerseyResourcesComponent.setMessageProcessors(List<MessageProcessor> messageProcessors) |
Modifier and Type | Class and Description |
---|---|
class |
AbstractJsonTransformer
TODO
|
class |
AbstractToFromXmlTransformer
Superclass for transformers that convert JSON to and from XML
|
class |
JsonToObject
A transformer that will convert a JSON encoded object graph to a java object.
|
class |
JsonToXml
Convert JSON to an XML document string
|
class |
JsonXsltTransformer
Convert Json to Json using XSLT
|
class |
ObjectToJson
Converts a java object to a JSON encoded object that can be consumed by other languages such as
Javascript or Ruby.
|
class |
XmlToJson
Convert XML to a JSON string
|
Modifier and Type | Class and Description |
---|---|
class |
ValidateJsonSchemaMessageProcessor
A
MessageProcessor that uses a JsonSchemaValidator
to validate a json in the payload to a given schema |
Modifier and Type | Method and Description |
---|---|
static Flow |
DynamicFlowFactory.createDynamicFlow(MuleContext muleContext,
String flowName,
List<MessageProcessor> messageProcessors)
Creates a programmatic flow
|
Modifier and Type | Method and Description |
---|---|
protected MessageProcessor |
AutoAuthorizationCodeTokenRequestHandler.createRedirectUrlProcessor() |
protected abstract MessageProcessor |
AbstractAuthorizationCodeTokenRequestHandler.createRedirectUrlProcessor() |
Modifier and Type | Class and Description |
---|---|
class |
InvalidateOauthContextMessageProcessor
Clears the oauth context for a token manager and a resource owner id.
|
Modifier and Type | Class and Description |
---|---|
class |
ObjectToRssFeed
Converts an RSS data representation into a SyndFeed object
|
Modifier and Type | Class and Description |
---|---|
class |
ScriptComponent
A Script service backed by a JSR-223 compliant script engine such as
Groovy, JavaScript, or Rhino.
|
Modifier and Type | Class and Description |
---|---|
class |
ScriptFilter |
Modifier and Type | Class and Description |
---|---|
class |
ScriptTransformer
Runs a script to perform transformation on an object.
|
Modifier and Type | Class and Description |
---|---|
class |
ObjectToRemoteInvocationResultTransformer
Converts an Object to a Spring RemoteInvocationResult and then into a byte[].
|
class |
ObjectToRemoteInvocationTransformer
Transforms a byte[] into an ObjectInputStream and then into a Spring RemoteInvocation instance.
|
Modifier and Type | Class and Description |
---|---|
class |
SxcFilteringOutboundRouter
FilteringRouter is a router that accepts events based on a filter
set. |
Modifier and Type | Method and Description |
---|---|
void |
WSProxyFactoryBean.setMessageProcessor(MessageProcessor processor) |
Constructor and Description |
---|
WSProxy(String name,
MuleContext muleContext,
MessageSource messageSource,
OutboundEndpoint outboundEndpoint,
List<MessageProcessor> transformers,
List<MessageProcessor> responseTransformers) |
WSProxy(String name,
MuleContext muleContext,
MessageSource messageSource,
OutboundEndpoint outboundEndpoint,
List<MessageProcessor> transformers,
List<MessageProcessor> responseTransformers) |
WSProxy(String name,
MuleContext muleContext,
MessageSource messageSource,
OutboundEndpoint outboundEndpoint,
List<MessageProcessor> transformers,
List<MessageProcessor> responseTransformers,
String wsdlContents) |
WSProxy(String name,
MuleContext muleContext,
MessageSource messageSource,
OutboundEndpoint outboundEndpoint,
List<MessageProcessor> transformers,
List<MessageProcessor> responseTransformers,
String wsdlContents) |
WSProxy(String name,
MuleContext muleContext,
MessageSource messageSource,
OutboundEndpoint outboundEndpoint,
List<MessageProcessor> transformers,
List<MessageProcessor> responseTransformers,
URI wsdlUri) |
WSProxy(String name,
MuleContext muleContext,
MessageSource messageSource,
OutboundEndpoint outboundEndpoint,
List<MessageProcessor> transformers,
List<MessageProcessor> responseTransformers,
URI wsdlUri) |
Modifier and Type | Class and Description |
---|---|
class |
WSConsumer |
Modifier and Type | Method and Description |
---|---|
MessageProcessor |
WSConsumerConfig.createOutboundMessageProcessor()
Creates an outbound endpoint for the service address.
|
Constructor and Description |
---|
SoapFaultException(MuleEvent event,
QName faultCode,
QName subCode,
String message,
Element detail,
MessageProcessor failingMessageProcessor)
Deprecated.
|
SoapFaultException(MuleEvent event,
org.apache.cxf.binding.soap.SoapFault soapFault,
MessageProcessor failingMessageProcessor) |
Modifier and Type | Class and Description |
---|---|
class |
AbstractXmlTransformer
AbstractXmlTransformer offers some XSLT transform on a DOM (or
other XML-ish) object. |
class |
AbstractXStreamTransformer
AbstractXStreamTransformer is a base class for all XStream based
transformers. |
class |
DomDocumentToXml
DomDocumentToXml Transform a org.w3c.dom.Document to XML String |
class |
JXPathExtractor
Deprecated.
This feature is deprecated and will be removed in Mule 4.0. Use MEL for extracting information
out of a Java Object or the xpath3() MEL function in the case of an XML document
|
class |
ObjectToXml
ObjectToXml converts any object to XML using Xstream. |
class |
XmlPrettyPrinter |
class |
XMLStreamReaderToByteArray
Transforms an
XMLStreamReader to a byte array. |
class |
XmlToDomDocument
XmlToDomDocument transforms a XML String to org.w3c.dom.Document. |
class |
XmlToObject
XmlToObject converts xml created by the ObjectToXml transformer in to a
java object graph. |
class |
XmlToOutputHandler |
class |
XmlToXMLStreamReader |
class |
XPathExtractor
Simple transformer for using the JAXP XPath library to extract an XPath value from
an XPath expression.
|
class |
XQueryTransformer
The XQuery Module gives users the ability to perform XQuery transformations on XML messages in Mule
|
class |
XsltTransformer
XsltTransformer performs an XSLT transform on a DOM (or other XML-ish)
object. |
Modifier and Type | Class and Description |
---|---|
class |
JAXBMarshallerTransformer
Allows marshaling of Java objects to XML using JAXB 2.
|
class |
JAXBUnmarshallerTransformer
Allows un-marshaling of XML generated by JAXB to a Java object graph.
|
Modifier and Type | Interface and Description |
---|---|
interface |
NonBlockingMessageProcessor
A
NonBlockingMessageProcessor differs from other message processors in that it supports
both blocking and non-blocking processing. |
Modifier and Type | Class and Description |
---|---|
class |
AbstractDynamicMessageProcessor
Implementation of
MessageProcessor that dynamically chooses and uses
another MessageProcessor |
class |
AbstractFilteringMessageProcessor
Abstract
InterceptingMessageProcessor that can be easily be extended and
used for filtering message flow through a MessageProcessor chain. |
class |
AbstractInterceptingMessageProcessor
Abstract implementation of
InterceptingMessageProcessor that simply
provides an implementation of setNext and holds the next message processor as an
attribute. |
class |
AbstractInterceptingMessageProcessorBase
Abstract implementation that provides the infrastructure for intercepting message processors.
|
class |
AbstractNonBlockingMessageProcessor
Abstract implementation of
NonBlockingMessageProcessor that determines if processing should
be performed blocking or non-blocking.. |
class |
AbstractRedeliveryPolicy
Implement a redelivery policy for Mule.
|
class |
AbstractRequestResponseMessageProcessor
Base implementation of a
MessageProcessor that may performs processing during both the
request and response processing phases while supporting non-blocking execution. |
class |
AsyncDelegateMessageProcessor
Processes
MuleEvent 's asynchronously using a MuleWorkManager to schedule asynchronous
processing of MessageProcessor delegate configured the next MessageProcessor . |
class |
AsyncInterceptingMessageProcessor
Processes
MuleEvent 's asynchronously using a MuleWorkManager to
schedule asynchronous processing of the next MessageProcessor . |
class |
EndpointTransactionalInterceptingMessageProcessor
Wraps the invocation of the next
MessageProcessor with a transaction. |
class |
ExceptionHandlingMessageProcessor |
class |
IdempotentRedeliveryPolicy
Implement a retry policy for Mule.
|
class |
InvokerMessageProcessor
InvokerMessageProcessor invokes a specified method of an object. |
class |
LaxAsyncInterceptingMessageProcessor |
class |
LaxSedaStageInterceptingMessageProcessor
Processes
MuleEvent 's asynchronously using a MuleWorkManager to schedule asynchronous
processing of the next MessageProcessor . |
class |
NullMessageProcessor |
class |
ResponseMessageProcessorAdapter |
class |
SecurityFilterMessageProcessor
Filters the flow using the specified
SecurityFilter . |
class |
SedaStageInterceptingMessageProcessor
Processes
MuleEvent 's asynchronously using a MuleWorkManager to schedule asynchronous
processing of the next MessageProcessor . |
class |
StopFurtherMessageProcessingMessageProcessor |
class |
TransactionalInterceptingMessageProcessor
Wraps the invocation of the next
MessageProcessor with a transaction. |
Modifier and Type | Field and Description |
---|---|
protected MessageProcessor |
AbstractRedeliveryPolicy.deadLetterQueue |
protected MessageProcessor |
AsyncDelegateMessageProcessor.delegate |
protected MessageProcessor |
AbstractInterceptingMessageProcessorBase.next |
protected MessageProcessor |
ResponseMessageProcessorAdapter.responseProcessor |
protected MessageProcessor |
AsyncWorkListener.target |
protected MessageProcessor |
AbstractFilteringMessageProcessor.unacceptedMessageProcessor
The
MessageProcessor that should be used to handle messages that are not accepted by the filter. |
Modifier and Type | Field and Description |
---|---|
protected List<MessageProcessor> |
BlockingProcessorExecutor.processors |
protected List<MessageProcessor> |
AsyncDelegateMessageProcessor.processors |
Modifier and Type | Method and Description |
---|---|
MessageProcessor |
AbstractInterceptingMessageProcessorBase.getListener() |
MessageProcessor |
AbstractRedeliveryPolicy.getTheFailedMessageProcessor() |
MessageProcessor |
AbstractFilteringMessageProcessor.getUnacceptedMessageProcessor() |
protected MessageProcessor |
BlockingProcessorExecutor.nextProcessor() |
protected abstract MessageProcessor |
AbstractDynamicMessageProcessor.resolveMessageProcessor(MuleEvent event)
Determines which MessageProcessor should be used.
|
Modifier and Type | Method and Description |
---|---|
List<MessageProcessor> |
NullMessageProcessor.getMessageProcessors() |
protected List<MessageProcessor> |
AsyncDelegateMessageProcessor.getOwnedMessageProcessors() |
protected abstract List<MessageProcessor> |
AbstractMessageProcessorOwner.getOwnedMessageProcessors() |
protected List<MessageProcessor> |
AbstractMessageProcessorOwner.getOwnedObjects() |
Modifier and Type | Method and Description |
---|---|
protected void |
NonBlockingProcessorExecutor.preProcess(MessageProcessor processor) |
protected void |
BlockingProcessorExecutor.preProcess(MessageProcessor processor) |
void |
AsyncDelegateMessageProcessor.setDelegate(MessageProcessor delegate) |
void |
AbstractInterceptingMessageProcessorBase.setListener(MessageProcessor next) |
void |
IdempotentRedeliveryPolicy.setMessageProcessor(MessageProcessor processor) |
void |
ResponseMessageProcessorAdapter.setProcessor(MessageProcessor processor) |
void |
AbstractFilteringMessageProcessor.setUnacceptedMessageProcessor(MessageProcessor unacceptedMessageProcessor) |
Constructor and Description |
---|
AsyncDelegateMessageProcessor(MessageProcessor delegate,
ProcessingStrategy processingStrategy,
String name) |
AsyncWorkListener(MessageProcessor target) |
ResponseMessageProcessorAdapter(MessageProcessor responseProcessor) |
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 | Interface and Description |
---|---|
interface |
DynamicMessageProcessorContainer
Specific case of a
MessageProcessorContainer when its inner processors are dynamic (for instance, with a dynamically referenced subflow). |
interface |
SubFlowMessageProcessor
Marker interface for MessageProcessors that actually represent a subflow.
|
Modifier and Type | Class and Description |
---|---|
class |
AbstractMessageProcessorChain
Builder needs to return a composite rather than the first MessageProcessor in the chain.
|
class |
DefaultMessageProcessorChain |
class |
InterceptingChainLifecycleWrapper
Builder needs to return a composite rather than the first MessageProcessor in the chain.
|
class |
InterceptingChainLifecycleWrapperPathSkip
When adding path elements to the
MessageProcessor s, the chains add a level to this path. |
class |
SimpleMessageProcessorChain |
class |
SubflowInterceptingChainLifecycleWrapper
Generates message processor identfiers specific for subflows.
|
Modifier and Type | Field and Description |
---|---|
protected List<MessageProcessor> |
AbstractMessageProcessorChain.processors |
Modifier and Type | Method and Description |
---|---|
protected MessageProcessor |
AbstractMessageProcessorChainBuilder.initializeMessageProcessor(Object processor) |
Modifier and Type | Method and Description |
---|---|
List<MessageProcessor> |
InterceptingChainLifecycleWrapper.getMessageProcessors() |
List<MessageProcessor> |
AbstractMessageProcessorChain.getMessageProcessors() |
Modifier and Type | Method and Description |
---|---|
DefaultMessageProcessorChainBuilder |
DefaultMessageProcessorChainBuilder.chain(MessageProcessor... processors) |
DefaultMessageProcessorChainBuilder |
DefaultMessageProcessorChainBuilder.chainBefore(MessageProcessor processor) |
static MessageProcessorChain |
DefaultMessageProcessorChain.from(MessageProcessor... messageProcessors) |
static MessageProcessorChain |
DefaultMessageProcessorChain.from(MessageProcessor messageProcessor) |
protected boolean |
DefaultMessageProcessorChain.processorMayReturnNull(MessageProcessor processor) |
void |
NestedProcessorChain.setChain(MessageProcessor value)
Sets chain
|
Modifier and Type | Method and Description |
---|---|
DefaultMessageProcessorChainBuilder |
DefaultMessageProcessorChainBuilder.chain(List<MessageProcessor> processors) |
protected DefaultMessageProcessorChain |
DefaultMessageProcessorChainBuilder.createInnerChain(LinkedList<MessageProcessor> tempList) |
protected DefaultMessageProcessorChain |
SimpleMessageProcessorChainBuilder.createInnerChain(LinkedList<MessageProcessor> tempList) |
protected DefaultMessageProcessorChain |
DefaultMessageProcessorChainBuilder.createOuterChain(LinkedList<MessageProcessor> tempList) |
protected DefaultMessageProcessorChain |
SimpleMessageProcessorChainBuilder.createOuterChain(LinkedList<MessageProcessor> tempList) |
ProcessorExecutor |
ProcessorExecutorFactory.createProcessorExecutor(MuleEvent event,
List<MessageProcessor> processors,
MessageProcessorExecutionTemplate executionTemplate,
boolean copyOnVoidEvent) |
static MessageProcessorChain |
DefaultMessageProcessorChain.from(List<MessageProcessor> messageProcessors) |
Constructor and Description |
---|
DefaultMessageProcessorChain(MessageProcessor... processors) |
DefaultMessageProcessorChain(String name,
MessageProcessor... processors) |
NestedProcessorChain(MuleEvent event,
MuleContext muleContext,
MessageProcessor chain) |
SimpleMessageProcessorChain(MessageProcessor... processors) |
SimpleMessageProcessorChain(String name,
MessageProcessor... processors) |
Constructor and Description |
---|
AbstractMessageProcessorChain(String name,
List<MessageProcessor> processors) |
DefaultMessageProcessorChain(List<MessageProcessor> processors) |
DefaultMessageProcessorChain(String name,
List<MessageProcessor> processors) |
InterceptingChainLifecycleWrapper(MessageProcessorChain chain,
List<MessageProcessor> processors,
String name) |
InterceptingChainLifecycleWrapperPathSkip(MessageProcessorChain chain,
List<MessageProcessor> processors,
String name) |
SimpleMessageProcessorChain(List<MessageProcessor> processors) |
SimpleMessageProcessorChain(String name,
List<MessageProcessor> processors) |
SubflowInterceptingChainLifecycleWrapper(MessageProcessorChain chain,
List<MessageProcessor> processors,
String name) |
Modifier and Type | Method and Description |
---|---|
void |
NonBlockingProcessingStrategy.configureProcessors(List<MessageProcessor> processors,
StageNameSource nameSource,
MessageProcessorChainBuilder chainBuilder,
MuleContext muleContext) |
void |
SynchronousProcessingStrategy.configureProcessors(List<MessageProcessor> processors,
StageNameSource nameSource,
MessageProcessorChainBuilder chainBuilder,
MuleContext muleContext) |
void |
AsynchronousProcessingStrategy.configureProcessors(List<MessageProcessor> processors,
StageNameSource nameSource,
MessageProcessorChainBuilder chainBuilder,
MuleContext muleContext) |
void |
QueuedThreadPerProcessorProcessingStrategy.configureProcessors(List<MessageProcessor> processors,
StageNameSource nameSource,
MessageProcessorChainBuilder builder,
MuleContext muleContext) |
void |
ThreadPerProcessorProcessingStrategy.configureProcessors(List<MessageProcessor> processors,
StageNameSource nameSource,
MessageProcessorChainBuilder builder,
MuleContext muleContext) |
Modifier and Type | Class and Description |
---|---|
class |
AbstractAggregator
AbstractEventAggregator will aggregate a set of messages into a
single message. |
class |
AbstractCatchAllStrategy
Deprecated.
|
class |
AbstractCorrelationAggregator
AbstractCorrelationAggregatingMessageProcessor uses the CorrelationID
and CorrelationGroupSize properties of the MuleMessage to
manage message groups. |
class |
AbstractMatchingRouter
AbstractRouterCollection provides common method implementations of router collections for in
and outbound routers. |
class |
AbstractSelectiveRouter |
class |
AbstractSplitter
Splits a message invoking the next message processor one for each split part.
|
class |
ChoiceRouter
Routes the event to a single
MessageProcessor using a Filter
to evaluate the event being processed and find the first route that can be used. |
class |
CollectionSplitter
Splits a message that has a Collection, Iterable, MessageSequence or Iterator
payload invoking the next message processor one
for each item in it.
|
class |
DynamicAll
Routes a message through a set of routes that will be obtained
dynamically (per message) using a
DynamicRouteResolver . |
class |
DynamicFirstSuccessful
Routes a message through a set of routes that will be obtained
dynamically (per message) using a
DynamicRouteResolver . |
class |
DynamicRoundRobin
RoundRobin divides the messages it receives among its target routes in round-robin
fashion.
|
class |
ExpressionSplitter
Splits a message using the expression provided invoking the next message processor
one for each split part.
|
class |
FirstSuccessful
FirstSuccessful routes an event to the first target route that can accept it
without throwing or returning an exception.
|
class |
Foreach
` * The
Foreach MessageProcessor allows iterating over a collection payload, or any collection
obtained by an expression, generating a message for each element. |
class |
ForwardingCatchAllStrategy
Deprecated.
|
class |
IdempotentMessageFilter
IdempotentMessageFilter ensures that only unique messages are passed
on. |
class |
IdempotentSecureHashMessageFilter
IdempotentSecureHashMessageFilter ensures that only unique messages are
received by a service. |
class |
LoggingCatchAllStrategy
Deprecated.
|
class |
MapSplitter
Splits a message that has a map payload invoking the next message processor one
for each item in the map in order.
|
class |
MessageChunkAggregator |
class |
MessageChunkSplitter
A router that breaks up the current message onto smaller parts and sends them to
the same destination.
|
class |
MessageFilter
Implementation of
InterceptingMessageProcessor that filters message flow
using a Filter . |
class |
Resequencer
Resequencer is used to resequence events according to their dispatch
sequence in the correlation group. |
class |
RoundRobin
RoundRobin divides the messages it receives among its target routes in round-robin
fashion.
|
class |
ScatterGatherRouter
The
Scatter-Gather router will broadcast copies of the current
message to every endpoint registered with the router in parallel. |
class |
ServiceCatchAllStrategy
Deprecated.
|
class |
SimpleCollectionAggregator
This router will return all aggregated events as a
MuleMessageCollection . |
class |
UntilSuccessful
UntilSuccessful attempts to route a message to the message processor it contains.
|
class |
WireTap
The
WireTap MessageProcessor allows inspection of messages in a flow. |
Modifier and Type | Field and Description |
---|---|
protected MessageProcessor |
AbstractMatchingRouter.defaultRoute |
protected MessageProcessor |
WireTap.filteredTap |
protected MessageProcessor |
WireTap.tap |
Modifier and Type | Method and Description |
---|---|
MessageProcessor |
AbstractMatchingRouter.getDefaultRoute() |
MessageProcessor |
UntilSuccessfulConfiguration.getDlqMP() |
MessageProcessor |
UntilSuccessful.getDlqMP() |
MessageProcessor |
MessageProcessorFilterPair.getMessageProcessor() |
MessageProcessor |
UntilSuccessfulConfiguration.getRoute() |
MessageProcessor |
UntilSuccessful.getRoute() |
MessageProcessor |
UntilSuccessfulConfiguration.getRouter() |
MessageProcessor |
WireTap.getTap() |
Modifier and Type | Method and Description |
---|---|
protected List<MessageProcessor> |
Foreach.getOwnedMessageProcessors() |
protected List<MessageProcessor> |
ScatterGatherRouter.getOwnedMessageProcessors() |
protected List<MessageProcessor> |
WireTap.getOwnedMessageProcessors() |
List<MessageProcessor> |
DynamicRouteResolver.resolveRoutes(MuleEvent event)
Return a list of
MessageProcessor to route the message. |
List<MessageProcessor> |
DynamicRouteResolverAdapter.resolveRoutes(MuleEvent event) |
protected Collection<MessageProcessor> |
ChoiceRouter.selectProcessors(MuleEvent event) |
protected abstract Collection<MessageProcessor> |
AbstractSelectiveRouter.selectProcessors(MuleEvent event) |
Modifier and Type | Method and Description |
---|---|
void |
ScatterGatherRouter.addRoute(MessageProcessor processor)
Adds a new message processor to the list of routes
|
void |
AbstractSelectiveRouter.addRoute(MessageProcessor processor,
Filter filter) |
protected MuleEvent |
AbstractRoutingStrategy.createEventToRoute(MuleEvent routedEvent,
MuleMessage message,
MessageProcessor route)
Create a new event to be routed to the target MP
|
void |
ScatterGatherRouter.removeRoute(MessageProcessor processor)
Removes a message processor from the list of routes
|
void |
AbstractSelectiveRouter.removeRoute(MessageProcessor processor) |
protected MuleEvent |
AbstractRoutingStrategy.sendRequest(MuleEvent routedEvent,
MuleMessage message,
MessageProcessor route,
boolean awaitResponse)
Send message event to destination.
|
void |
AbstractMatchingRouter.setDefaultRoute(MessageProcessor defaultRoute) |
void |
AbstractSelectiveRouter.setDefaultRoute(MessageProcessor processor) |
void |
ForwardingCatchAllStrategy.setMessageProcessor(MessageProcessor processor)
Deprecated.
|
void |
WireTap.setMessageProcessor(MessageProcessor tap)
Deprecated.
|
void |
WireTap.setTap(MessageProcessor tap) |
void |
AbstractSelectiveRouter.updateRoute(MessageProcessor processor,
Filter filter) |
Modifier and Type | Method and Description |
---|---|
MuleEvent |
RoutingStrategy.route(MuleEvent event,
List<MessageProcessor> messageProcessors)
Routes
MuleEvent through a set of MessageProcessor |
MuleEvent |
FirstSuccessfulRoutingStrategy.route(MuleEvent event,
List<MessageProcessor> messageProcessors) |
MuleEvent |
RoundRobinRoutingStrategy.route(MuleEvent event,
List<MessageProcessor> messageProcessors) |
MuleEvent |
MulticastingRoutingStrategy.route(MuleEvent event,
List<MessageProcessor> messageProcessors) |
void |
Foreach.setMessageProcessors(List<MessageProcessor> messageProcessors) |
void |
ScatterGatherRouter.setRoutes(List<MessageProcessor> routes) |
Constructor and Description |
---|
AggregationException(EventGroup eventGroup,
MessageProcessor endpoint) |
AggregationException(EventGroup eventGroup,
MessageProcessor endpoint,
Throwable cause) |
AggregationException(Message message,
EventGroup eventGroup,
MessageProcessor endpoint) |
AggregationException(Message message,
EventGroup eventGroup,
MessageProcessor endpoint,
Throwable cause) |
MessageFilter(Filter filter,
boolean throwExceptionOnUnaccepted,
MessageProcessor messageProcessor) |
MessageProcessorFilterPair(MessageProcessor messageProcessor,
Filter filter) |
RoutingFailedMessagingException(Message message,
MuleEvent event,
MessageProcessor failingMessageProcessor) |
RoutingFailedMessagingException(Message message,
MuleEvent event,
Throwable cause,
MessageProcessor failingMessageProcessor) |
RoutingFailedMessagingException(MuleEvent event,
Throwable cause,
MessageProcessor failingMessageProcessor) |
Constructor and Description |
---|
EventCorrelator(EventCorrelatorCallback callback,
MessageProcessor timeoutMessageProcessor,
MessageInfoMapping messageInfoMapping,
MuleContext muleContext,
FlowConstruct flowConstruct,
PartitionableObjectStore correlatorStore,
String storePrefix,
ObjectStore<Long> processedGroups) |
Modifier and Type | Class and Description |
---|---|
class |
AbstractMessageSequenceSplitter
Base implementation of a
MuleMessage splitter, that converts its payload
in a MessageSequence , and process each element of it. |
class |
AbstractMessageSplitter
AbstractMessageSplitter is an outbound Message Splitter used to split
the contents of a received message into sub parts that can be processed by other
components. |
class |
AbstractOutboundRouter
AbstractOutboundRouter is a base router class that tracks statistics about message processing
through the router. |
class |
AbstractRecipientList
AbstractRecipientList is used to dispatch a single event to
multiple recipients over the same transport. |
class |
AbstractRoundRobinMessageSplitter
FilteringListMessageSplitter accepts a List as a message payload
then routes list elements as messages over an endpoint where the endpoint's filter
accepts the payload. |
class |
AbstractSequenceRouter
Defines a router that sequentially routes a given message to the list of
registered endpoints and returns the aggregate responses as the result.
|
class |
ChainingRouter
Deprecated.
|
class |
DefaultOutboundRouterCollection
Deprecated.
|
class |
EndpointSelector
Deprecated.
|
class |
ExceptionBasedRouter
Deprecated.
|
class |
ExpressionMessageSplitter
Deprecated.
|
class |
ExpressionRecipientList |
class |
FilteringOutboundRouter
FilteringRouter is a router that accepts events based on a filter
set. |
class |
ListMessageSplitter
Deprecated.
|
class |
MessageChunkingRouter
Deprecated.
|
class |
MulticastingRouter
Deprecated.
|
class |
OutboundPassThroughRouter
Deprecated.
|
class |
SequenceRouter
Deprecated.
|
class |
StaticRecipientList
Deprecated.
|
class |
TransformerRouter
Deprecated.
|
Modifier and Type | Field and Description |
---|---|
protected List<MessageProcessor> |
AbstractOutboundRouter.routes |
Modifier and Type | Method and Description |
---|---|
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
|
MessageProcessor |
AbstractOutboundRouter.getRoute(String name) |
protected MessageProcessor |
EndpointSelector.lookupEndpoint(String endpointName)
Deprecated.
|
Modifier and Type | Method and Description |
---|---|
protected List<MessageProcessor> |
AbstractOutboundRouter.getOwnedMessageProcessors() |
List<MessageProcessor> |
AbstractOutboundRouter.getRoutes() |
Modifier and Type | Method and Description |
---|---|
void |
OutboundPassThroughRouter.addRoute(MessageProcessor target)
Deprecated.
|
void |
FilteringOutboundRouter.addRoute(MessageProcessor target) |
void |
AbstractOutboundRouter.addRoute(MessageProcessor route) |
protected MuleEvent |
AbstractOutboundRouter.createEventToRoute(MuleEvent routedEvent,
MuleMessage message,
MessageProcessor route)
Create a new event to be routed to the target MP
|
protected MuleEvent |
AbstractOutboundRouter.doProcessRoute(MessageProcessor route,
MuleEvent event) |
void |
AbstractOutboundRouter.removeRoute(MessageProcessor route) |
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 void |
AbstractOutboundRouter.setMessageProperties(FlowConstruct service,
MuleMessage message,
MessageProcessor route) |
Modifier and Type | Method and Description |
---|---|
protected abstract SplitMessage |
AbstractMessageSplitter.getMessageParts(MuleMessage message,
List<MessageProcessor> endpoints)
Implementing classes should create a
SplitMessage instance and for
each part can associate an endpoint. |
protected SplitMessage |
AbstractRoundRobinMessageSplitter.getMessageParts(MuleMessage message,
List<MessageProcessor> endpoints)
Retrieves a specific message part for the given endpoint.
|
void |
AbstractOutboundRouter.setMessageProcessors(List<MessageProcessor> routes)
Deprecated.
|
void |
OutboundPassThroughRouter.setRoutes(List<MessageProcessor> endpoints)
Deprecated.
|
void |
AbstractOutboundRouter.setRoutes(List<MessageProcessor> routes) |
Modifier and Type | Class and Description |
---|---|
class |
AbstractAsyncRequestReplyRequester |
class |
AbstractReplyToPropertyRequestReplyReplier |
class |
AsyncReplyToPropertyRequestReplyReplier |
class |
ReplyToPropertyRequestReplyReplier |
class |
SimpleAsyncRequestReplyRequester |
class |
SimpleRequestReplyReplier |
Modifier and Type | Field and Description |
---|---|
protected MessageProcessor |
SimpleRequestReplyReplier.replyMessageProcessor |
protected MessageProcessor |
SimpleAsyncRequestReplyRequester.requestMessageProcessor |
Modifier and Type | Method and Description |
---|---|
void |
SimpleAsyncRequestReplyRequester.setMessageProcessor(MessageProcessor processor) |
void |
SimpleRequestReplyReplier.setReplyProcessor(MessageProcessor replyMessageProcessor) |
void |
AbstractReplyToPropertyRequestReplyReplier.setReplyProcessor(MessageProcessor replyMessageProcessor) |
Modifier and Type | Class and Description |
---|---|
class |
DefaultHttpCallback.FlowRefMessageProcessor |
Constructor and Description |
---|
DefaultHttpCallback(MessageProcessor callbackMessageProcessor,
MuleContext muleContext,
String callbackDomain,
Integer localPort,
Integer remotePort,
Boolean async) |
DefaultHttpCallback(MessageProcessor callbackMessageProcessor,
MuleContext muleContext,
String callbackDomain,
Integer localPort,
Integer remotePort,
Boolean async,
Object connector) |
DefaultHttpCallback(MessageProcessor callbackMessageProcessor,
MuleContext muleContext,
String callbackDomain,
Integer localPort,
Integer remotePort,
String callbackPath,
Boolean async) |
DefaultHttpCallback(MessageProcessor callbackMessageProcessor,
MuleContext muleContext,
String callbackDomain,
Integer localPort,
Integer remotePort,
String callbackPath,
Boolean async,
MessagingExceptionHandler exceptionHandler,
Object connector) |
DefaultHttpCallback(MessageProcessor callbackMessageProcessor,
MuleContext muleContext,
String callbackDomain,
Integer localPort,
Integer remotePort,
String callbackPath,
Boolean async,
Object connector) |
Constructor and Description |
---|
DefaultHttpCallback(List<MessageProcessor> callbackMessageProcessors,
MuleContext muleContext,
String callbackDomain,
Integer localPort,
Integer remotePort,
Boolean async) |
DefaultHttpCallback(List<MessageProcessor> callbackMessageProcessors,
MuleContext muleContext,
String callbackDomain,
Integer localPort,
Integer remotePort,
Boolean async,
Object connector) |
DefaultHttpCallback(List<MessageProcessor> callbackMessageProcessors,
MuleContext muleContext,
String callbackDomain,
Integer localPort,
Integer remotePort,
String callbackPath,
Boolean async) |
DefaultHttpCallback(List<MessageProcessor> callbackMessageProcessors,
MuleContext muleContext,
String callbackDomain,
Integer localPort,
Integer remotePort,
String callbackPath,
Boolean async,
MessagingExceptionHandler exceptionHandler) |
DefaultHttpCallback(List<MessageProcessor> callbackMessageProcessors,
MuleContext muleContext,
String callbackDomain,
Integer localPort,
Integer remotePort,
String callbackPath,
Boolean async,
MessagingExceptionHandler exceptionHandler,
Object connector) |
DefaultHttpCallback(List<MessageProcessor> callbackMessageProcessors,
MuleContext muleContext,
String callbackDomain,
Integer localPort,
Integer remotePort,
String callbackPath,
Boolean async,
Object connector) |
Modifier and Type | Class and Description |
---|---|
class |
CallbackContinuationMessageProcessor
This
MessageProcessor acts as a wrapper of another one in order to insert
it into a chain that it's not its own without being subject to its lifecycle. |
Modifier and Type | Method and Description |
---|---|
MessageProcessor |
DefaultRestoreAccessTokenCallback.getMessageProcessor()
Retrieves messageProcessor
|
MessageProcessor |
DefaultSaveAccessTokenCallback.getMessageProcessor()
Retrieves messageProcessor
|
Modifier and Type | Method and Description |
---|---|
HttpCallback |
DefaultHttpCallbackFactory.createCallback(HttpCallbackAdapter adapter,
String authCodeRegex,
FetchAccessTokenMessageProcessor fetchAccessTokenMessageProcessor,
MessageProcessor listener,
MuleContext muleContext,
FlowConstruct flowConstruct) |
void |
DefaultRestoreAccessTokenCallback.setMessageProcessor(MessageProcessor value)
Sets messageProcessor
|
void |
DefaultSaveAccessTokenCallback.setMessageProcessor(MessageProcessor value)
Sets messageProcessor
|
Constructor and Description |
---|
CallbackContinuationMessageProcessor(MessageProcessor continuation) |
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 |
ManagedAccessTokenProcessInterceptor.execute(ProcessCallback<T,OAuth2Adapter> processCallback,
OAuth2Adapter object,
MessageProcessor messageProcessor,
MuleEvent event) |
T |
RefreshTokenProcessInterceptor.execute(ProcessCallback<T,OAuth2Adapter> processCallback,
OAuth2Adapter object,
MessageProcessor messageProcessor,
MuleEvent event) |
Modifier and Type | Class and Description |
---|---|
class |
AbstractAuthorizeMessageProcessor |
class |
BaseOAuth1AuthorizeMessageProcessor |
class |
BaseOAuth1UnauthorizeMessageProcessor |
class |
BaseOAuth2AuthorizeMessageProcessor<T extends OAuth2Manager<OAuth2Adapter>> |
class |
BaseOAuth2UnauthorizeMessageProcessor<T extends OAuth2Manager<OAuth2Adapter>> |
class |
ExtractAuthorizationCodeMessageProcessor |
class |
FetchAccessTokenMessageProcessor |
class |
OAuth1FetchAccessTokenMessageProcessor |
class |
OAuth2FetchAccessTokenMessageProcessor |
Modifier and Type | Method and Description |
---|---|
MessageProcessor |
AbstractAuthorizeMessageProcessor.getListener() |
MessageProcessor |
AbstractListeningMessageProcessor.getMessageProcessor()
Retrieves messageProcessor
|
Modifier and Type | Method and Description |
---|---|
void |
AbstractListeningMessageProcessor.setListener(MessageProcessor listener)
Sets the message processor that will "listen" the events generated by this
message source
|
void |
AbstractAuthorizeMessageProcessor.setListener(MessageProcessor value)
Sets listener
|
Modifier and Type | Class and Description |
---|---|
class |
AbstractService
Deprecated.
|
class |
ForwardingConsumer
Deprecated.
|
Modifier and Type | Field and Description |
---|---|
protected MessageProcessor |
ServiceCompositeMessageSource.catchAllStrategy
Deprecated.
|
protected MessageProcessor |
AbstractService.outboundRouter
Deprecated.
|
Modifier and Type | Field and Description |
---|---|
protected List<MessageProcessor> |
ServiceCompositeMessageSource.processors
Deprecated.
|
Modifier and Type | Method and Description |
---|---|
MessageProcessor |
ServiceCompositeMessageSource.getCatchAllStrategy()
Deprecated.
|
MessageProcessor |
AbstractService.getOutboundMessageProcessor()
Deprecated.
|
protected MessageProcessor |
AbstractService.getServiceStartedAssertingMessageProcessor()
Deprecated.
|
Modifier and Type | Method and Description |
---|---|
List<MessageProcessor> |
ServiceCompositeMessageSource.getMessageProcessors()
Deprecated.
|
Modifier and Type | Method and Description |
---|---|
void |
ServiceCompositeMessageSource.addMessageProcessor(MessageProcessor processor)
Deprecated.
|
void |
ServiceCompositeMessageSource.setCatchAllStrategy(MessageProcessor catchAllStrategy)
Deprecated.
|
void |
AbstractService.setMessageProcessor(MessageProcessor processor)
Deprecated.
|
void |
AbstractService.setOutboundMessageProcessor(MessageProcessor processor)
Deprecated.
|
Modifier and Type | Method and Description |
---|---|
void |
ServiceCompositeMessageSource.setMessageProcessors(List<MessageProcessor> processors)
Deprecated.
|
Modifier and Type | Class and Description |
---|---|
class |
ServiceAsyncRequestReplyRequestor
Deprecated.
|
class |
ServiceInternalMessageProcessor
Deprecated.
|
class |
ServiceLoggingMessageProcessor
Deprecated.
|
class |
ServiceOutboundMessageProcessor
Deprecated.
|
class |
ServiceOutboundStatisticsMessageProcessor
Deprecated.
|
class |
ServiceSetEventRequestContextMessageProcessor
Deprecated.
|
class |
ServiceStatisticsMessageProcessor
Deprecated.
|
Constructor and Description |
---|
ServiceProcessorExecutor(MuleEvent event,
List<MessageProcessor> processors,
MessageProcessorExecutionTemplate messageProcessorExecutionTemplate,
boolean copyOnVoidEvent) |
Modifier and Type | Field and Description |
---|---|
protected MessageProcessor |
StartableCompositeMessageSource.listener |
Modifier and Type | Method and Description |
---|---|
void |
ClusterizableMessageSourceWrapper.setListener(MessageProcessor listener) |
void |
StartableCompositeMessageSource.setListener(MessageProcessor listener) |
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 | Class and Description |
---|---|
class |
AssertionMessageProcessor |
class |
InvocationCountMessageProcessor
Test message processor to keep count of number of invocations.
|
class |
ResponseAssertionMessageProcessor |
class |
StringAppendTestTransformer |
Modifier and Type | Method and Description |
---|---|
void |
ResponseAssertionMessageProcessor.setListener(MessageProcessor listener) |
Modifier and Type | Class and Description |
---|---|
class |
NoActionTransformer
Deprecated.
|
class |
ValidateResponse
Throws an exception if the message does not contain "success".
|
Modifier and Type | Class and Description |
---|---|
static class |
FlowTraceUtils.FlowStackAsserter |
static class |
FlowTraceUtils.FlowStackAsyncAsserter |
Modifier and Type | Method and Description |
---|---|
List<MessageProcessor> |
InboundEndpointWrapper.getMessageProcessors() |
List<MessageProcessor> |
InboundEndpointWrapper.getResponseMessageProcessors() |
Modifier and Type | Method and Description |
---|---|
void |
InboundEndpointWrapper.setListener(MessageProcessor listener) |
Modifier and Type | Class and Description |
---|---|
class |
AbstractDiscoverableTransformer |
class |
AbstractMessageAwareTransformer
Deprecated.
|
class |
AbstractMessageTransformer
AbstractMessageTransformer is a transformer that has a reference
to the current message. |
class |
AbstractTransformer
AbstractTransformer is a base class for all transformers. |
class |
CompositeConverter
Composes many converters to behave as a single one.
|
class |
TransformerChain
A referencable chain of transformers that can be used as a single transformer
|
class |
TransformerTemplate
TODO
|
Modifier and Type | Class and Description |
---|---|
class |
Base64Decoder
Base64Encoder transforms Base64 encoded data into strings or byte
arrays. |
class |
Base64Encoder
Base64Encoder transforms strings or byte arrays into Base64 encoded
string. |
class |
XmlEntityDecoder
Decodes a String or byte[] containing XML entities
|
class |
XmlEntityEncoder
Encodes a string with XML entities
|
Modifier and Type | Class and Description |
---|---|
class |
AbstractCompressionTransformer
AbstractCompressionTransformer is a base class for all transformers
that can compress or uncompress data when they performa message transformation. |
class |
GZipCompressTransformer
GZipCompressTransformer is a transformer compressing objects into
byte arrays. |
class |
GZipUncompressTransformer
GZipCompressTransformer will uncompress a byte[] or InputStream |
Modifier and Type | Class and Description |
---|---|
class |
AbstractEncryptionTransformer
EncryptionTransformer will transform an array of bytes or string
into an encrypted array of bytes |
class |
DecryptionTransformer
EncryptionTransformer will transform an encrypted array of bytes or
string into an decrypted array of bytes |
class |
EncryptionTransformer
EncryptionTransformer will transform an array of bytes or string
into an encrypted array of bytes |
Modifier and Type | Class and Description |
---|---|
class |
AbstractAddVariablePropertyTransformer |
class |
AbstractRemoveVariablePropertyTransformer |
class |
AddAttachmentTransformer |
class |
AddFlowVariableTransformer |
class |
AddPropertyTransformer |
class |
AddSessionVariableTransformer |
class |
AutoTransformer
A transformer that uses the transform discovery mechanism to convert the message payload.
|
class |
BeanToMap
Conversts a simple bean object to a Map.
|
class |
ByteArrayToHexString
Converts a Byte array to a Hex String.
|
class |
ByteArrayToMuleMessage
TODO
|
class |
ByteArrayToObject
ByteArrayToObject works in the same way as
ByteArrayToSerializable but checks if the byte array is a
serialised object and if not will return a String created from the bytes as the
returnType on the transformer. |
class |
ByteArrayToSerializable
ByteArrayToSerializable converts a serialized object to its object
representation |
class |
CombineCollectionsTransformer
Takes a payload which is a Collection of Collections and turns into a single List.
|
class |
CopyAttachmentsTransformer |
class |
CopyPropertiesTransformer |
class |
DataHandlerToInputStreamTransformer |
class |
GetBeanProperty
Looks up a property from a JavaBean using PropertyUtils.getProperty().
|
class |
HexStringToByteArray
Converts a Hex String to a Byte array
|
class |
MapLookup
MapLookup looks up and returns an object from a Map based on a key. |
class |
MapToBean
Creates and object of type
AbstractTransformer.getReturnClass() and populates values of a
Map as bean properties on the object. |
class |
MessagePropertiesTransformer
A configurable message transformer that allows users to add, overwrite, rename and delete
properties on the current message.
|
class |
MuleMessageToByteArray
TODO
|
class |
NumberToString
NumberToString converts a Number to a String. |
class |
ObjectArrayToString
ObjectArrayToString transformer is the opposite of
StringToObjectArray - it simply converts Object[] to a String in which each
element is separated by a configurable delimiter (default is a space). |
class |
ObjectToByteArray
ObjectToByteArray converts serilaizable object to a byte array but
treats java.lang.String differently by converting to bytes using
the String.getBytrs() method. |
class |
ObjectToInputStream
ObjectToInputStream converts Serializable objects to an InputStream
but treats java.lang.String , byte[] and
org.mule.api.transport.OutputHandler differently by using their
byte[] content rather thqn Serializing them. |
class |
ObjectToOutputHandler
ObjectToOutputHandler converts a byte array into a String. |
class |
ObjectToString
ObjectToString transformer is useful for debugging. |
class |
ParseTemplateTransformer
Loads a template and parses its content to resolve expressions.
|
class |
PropertyEditorTextToValueTransformer
PropertyEditorTextToValueTransformer adapts a PropertyEditor
instance allowing it to be used to transform from a String to another type in Mule |
class |
PropertyEditorValueToTextTransformer
PropertyEditorValueToTextTransformer adapts a PropertyEditor
instance allowing it to be used to transform from a specific type to a String. |
class |
RemoveAttachmentTransformer |
class |
RemoveFlowVariableTransformer |
class |
RemovePropertyTransformer |
class |
RemoveSessionVariableTransformer |
class |
SerializableToByteArray
SerializableToByteArray converts a serializable object or a String
to a byte array. |
class |
SetPayloadMessageProcessor
Modifies the payload of a
MuleMessage according to the provided value. |
class |
SetPayloadTransformer
Transformer that modifies the payload of the message according to the provided value.
|
class |
StringAppendTransformer |
class |
StringToBoolean
ByteArrayToSerializable converts a serialized object to its object
representation |
class |
StringToNumber
StringToNumber converts a String to a Number. |
class |
StringToObjectArray
StringToObjectArray converts a String into an object array. |
Modifier and Type | Class and Description |
---|---|
class |
AbstractMessageDispatcher
Abstract implementation of an outbound channel adaptors.
|
class |
UnsupportedMessageDispatcher |
Modifier and Type | Field and Description |
---|---|
protected MessageProcessor |
AbstractMessageReceiver.listener
MessageProcessor chain used to process messages once the transport
specific MessageReceiver has received transport message and created
the MuleEvent |
Modifier and Type | Method and Description |
---|---|
MessageProcessor |
AbstractConnector.createDispatcherMessageProcessor(OutboundEndpoint endpoint) |
Modifier and Type | Method and Description |
---|---|
void |
AbstractConnector.registerListener(InboundEndpoint endpoint,
MessageProcessor messageProcessorChain,
FlowConstruct flowConstruct) |
void |
AbstractMessageReceiver.setListener(MessageProcessor processor) |
Modifier and Type | Class and Description |
---|---|
class |
AjaxMessageDispatcher
Will dispatch Mule events to ajax clients available in Bayeux that are listening to this endpoint.
|
Modifier and Type | Class and Description |
---|---|
class |
EjbMessageDispatcher
Invokes a method on an EJB object stored in Jndi.
|
Modifier and Type | Class and Description |
---|---|
class |
SmtpMessageDispatcher
SmtpMessageDispatcher will dispatch Mule events as Mime email
messages over an SMTP gateway. |
Modifier and Type | Class and Description |
---|---|
class |
EmailMessageToString
EmailMessageToString extracts the text body of java mail Message and
returns a string. |
class |
MimeMessageToRfc822ByteArray |
class |
ObjectToMimeMessage
Transforms a
Message to a MuleMessage , with support for attachments |
class |
Rfc822ByteArraytoMimeMessage |
class |
StringToEmailMessage
StringToEmailMessage will convert a String to a JavaMail Message,
using the String as the contents. |
Modifier and Type | Class and Description |
---|---|
class |
FileMessageDispatcher
FileMessageDispatcher is used to read/write files to the filesystem |
Modifier and Type | Class and Description |
---|---|
class |
FileToByteArray
FileToByteArray reads the contents of a file as a byte array. |
class |
FileToString
FileToString reads file contents into a string. |
Modifier and Type | Class and Description |
---|---|
class |
FtpMessageDispatcher |
Modifier and Type | Class and Description |
---|---|
class |
HttpClientMessageDispatcher
HttpClientMessageDispatcher dispatches Mule events over HTTP. |
class |
HttpsClientMessageDispatcher |
Modifier and Type | Method and Description |
---|---|
MessageProcessor |
HttpConnector.createDispatcherMessageProcessor(OutboundEndpoint endpoint) |
Modifier and Type | Method and Description |
---|---|
void |
HttpConnector.registerListener(InboundEndpoint endpoint,
MessageProcessor listener,
FlowConstruct flowConstruct) |
Modifier and Type | Class and Description |
---|---|
class |
HttpResponseBuilder |
class |
RestServiceWrapper
This service can used to proxy REST style services as local Mule Components.
|
class |
StaticResourceMessageProcessor
A MessageProcessor that can be used by HTTP endpoints to serve static files from a directory on the
filesystem.
|
Modifier and Type | Method and Description |
---|---|
protected List<MessageProcessor> |
HttpResponseBuilder.getOwnedMessageProcessors() |
Modifier and Type | Method and Description |
---|---|
void |
HttpResponseBuilder.setMessageProcessor(MessageProcessor messageProcessor) |
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 |
HttpProxyFactoryBean.setMessageProcessor(MessageProcessor processor) |
Constructor and Description |
---|
HttpProxy(String name,
MuleContext muleContext,
MessageSource messageSource,
OutboundEndpoint outboundEndpoint,
List<MessageProcessor> transformers,
List<MessageProcessor> responseTransformers,
CachingStrategy cachingStrategy) |
HttpProxy(String name,
MuleContext muleContext,
MessageSource messageSource,
OutboundEndpoint outboundEndpoint,
List<MessageProcessor> transformers,
List<MessageProcessor> responseTransformers,
CachingStrategy cachingStrategy) |
Modifier and Type | Class and Description |
---|---|
class |
ServletTransformer
THIS CLASS IS UNSUPPORTED AND THE IMPLEMENTATION DOES NOT CONFORM TO THE SERVLET SPECIFICATION!
With that said, it can be used to make integration with libraries that only support servlets
easier.
|
Modifier and Type | Class and Description |
---|---|
class |
FormTransformer
Converts HTML forms POSTs into a Map of parameters.
|
class |
HttpClientMethodResponseToObject
HttpClientMethodResponseToObject transforms a http client response
to a DefaultMuleMessage. |
class |
HttpRequestBodyToParamMap |
class |
HttpResponseToString
Converts an Http Response object to String.
|
class |
MuleMessageToHttpResponse
Converts a
MuleMessage into an Http response. |
class |
ObjectToHttpClientMethodRequest
ObjectToHttpClientMethodRequest transforms a MuleMessage into a
HttpClient HttpMethod that represents an HttpRequest. |
class |
ServletRequestToOutputHandler
Adds support for converting a
HttpServletRequest into an OutputHandler |
Modifier and Type | Class and Description |
---|---|
class |
JdbcMessageDispatcher
The Jdbc Message dispatcher is responsible for executing SQL queries against a
database.
|
Modifier and Type | Method and Description |
---|---|
MessageProcessor |
JdbcConnector.createDispatcherMessageProcessor(OutboundEndpoint endpoint) |
Modifier and Type | Class and Description |
---|---|
class |
JmsMessageDispatcher
JmsMessageDispatcher is responsible for dispatching messages to JMS
destinations. |
Modifier and Type | Class and Description |
---|---|
class |
AbstractJmsTransformer
AbstractJmsTransformer is an abstract class that should be used for
all transformers where a JMS message will be the transformed or transformee
object. |
class |
JMSMessageToObject
JMSMessageToObject Will convert a javax.jms.Message
or sub-type into an object by extracting the message payload. |
class |
ObjectToJMSMessage
ObjectToJMSMessage will convert any object to a
javax.jms.Message or sub-type into an object. |
Modifier and Type | Field and Description |
---|---|
protected MessageProcessor |
MessageProcessorPollingMessageReceiver.sourceMessageProcessor
The poll message source, configured inside the poll element in the xml configuration.
|
Modifier and Type | Class and Description |
---|---|
class |
QuartzMessageDispatcher
Can schedule a Job with the Quartz scheduler.
|
Modifier and Type | Class and Description |
---|---|
class |
RmiMessageDispatcher
RmiMessageDispatcher will send transformed mule events over
RMI-JRMP. |
Modifier and Type | Class and Description |
---|---|
class |
HttpRequestToByteArray
Converts an
HttpServletRequest into an array of bytes by extracting
the payload of the request. |
class |
HttpRequestToInputStream
Converts a
HttpServletRequest into an InputStream . |
class |
HttpRequestToParameter |
class |
HttpRequestToParameterMap
Returns a simple Map of the parameters sent with the HTTP Request.
|
Modifier and Type | Class and Description |
---|---|
class |
SftpMessageDispatcher
SftpMessageDispatcher dispatches files via sftp to a remote sftp
service. |
Modifier and Type | Class and Description |
---|---|
class |
InputStreamToByteArray
TODO
|
Modifier and Type | Class and Description |
---|---|
class |
AxisMessageDispatcher
AxisMessageDispatcher is used to make soap requests via the Axis
soap client. |
Modifier and Type | Class and Description |
---|---|
class |
AxisWsdlMessageDispatcher
Creates and Axis client services from WSDL and invokes it.
|
Modifier and Type | Class and Description |
---|---|
class |
StdioMessageDispatcher
StdioMessageDispatcher is a simple stream dispatcher that obtains
a stream from the Stream Connector to write to. |
Modifier and Type | Method and Description |
---|---|
void |
StdioConnector.registerListener(InboundEndpoint endpoint,
MessageProcessor listener,
FlowConstruct flowConstruct) |
Modifier and Type | Class and Description |
---|---|
class |
LocalSocketTcpMessageDispatcher
LocalSocketTcpMessageDispatcher will send transformed Mule events
over TCP. |
class |
TcpMessageDispatcher
Send transformed Mule events over TCP.
|
Modifier and Type | Class and Description |
---|---|
class |
UdpMessageDispatcher
UdpMessageDispatcher is responsible for dispatching MuleEvents as
UDP packets on the network |
Modifier and Type | Class and Description |
---|---|
class |
VMMessageDispatcher
VMMessageDispatcher is used for providing in memory interaction between components. |
Modifier and Type | Class and Description |
---|---|
class |
XmppMessageDispatcher
Allows Mule events to be sent over Xmpp
|
Modifier and Type | Class and Description |
---|---|
class |
ObjectToXmppPacket
Creates an Xmpp message packet from a MuleMessage
|
class |
XmppPacketToObject |
Modifier and Type | Method and Description |
---|---|
static Map<MessageProcessor,String> |
NotificationUtils.buildPaths(MessageProcessorPathElement element)
Deprecated.
|
Map<MessageProcessor,String> |
NotificationUtils.FlowMap.getFlowMap() |
Modifier and Type | Method and Description |
---|---|
String |
NotificationUtils.PathResolver.resolvePath(MessageProcessor processor) |
String |
NotificationUtils.FlowMap.resolvePath(MessageProcessor processor) |
Modifier and Type | Method and Description |
---|---|
static void |
NotificationUtils.addMessageProcessorPathElements(List<MessageProcessor> processors,
MessageProcessorPathElement parentElement) |
Constructor and Description |
---|
NotificationUtils.FlowMap(Map<MessageProcessor,String> paths) |
Constructor and Description |
---|
ProcessingMuleEventWork(MessageProcessor messageProcessor,
MuleEvent muleEvent) |
Copyright © 2003–2016 MuleSoft, Inc.. All rights reserved.