Modifier and Type | Method and Description |
---|---|
MessageSource |
Pipeline.getMessageSource() |
Modifier and Type | Method and Description |
---|---|
void |
Pipeline.setMessageSource(MessageSource messageSource) |
Modifier and Type | Interface and Description |
---|---|
interface |
InboundEndpoint |
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 |
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 | Method and Description |
---|---|
void |
RequestReplyRequesterMessageProcessor.setReplySource(MessageSource replyMessageSource) |
Modifier and Type | Method and Description |
---|---|
MessageSource |
Service.getMessageSource()
Deprecated.
|
Modifier and Type | Method and Description |
---|---|
void |
Service.setMessageSource(MessageSource messageSource)
Deprecated.
|
Modifier and Type | Interface and Description |
---|---|
interface |
ClusterizableMessageSource
Defines a message source that runs in only one node of a cluster.
|
interface |
CompositeMessageSource
Composes multiple
MessageSource s. |
interface |
NonBlockingMessageSource
NonBlockingMessageSource's create instances of MuleEvent that contain a
ReplyToHandler
allowing for a response or error to be returned asynchronously by a different thread freeing up the request thread. |
Modifier and Type | Method and Description |
---|---|
List<MessageSource> |
CompositeMessageSource.getSources() |
Modifier and Type | Method and Description |
---|---|
void |
CompositeMessageSource.addSource(MessageSource messageSource) |
void |
CompositeMessageSource.removeSource(MessageSource messageSource) |
Modifier and Type | Interface and Description |
---|---|
interface |
MessageReceiver
MessageReceiver is used to receive data from an external system. |
Modifier and Type | Field and Description |
---|---|
protected List<MessageSource> |
CompositeMessageSourceFactoryBean.sources |
Modifier and Type | Method and Description |
---|---|
void |
AbstractFlowConstructFactoryBean.setMessageSource(MessageSource messageSource) |
Modifier and Type | Method and Description |
---|---|
void |
CompositeMessageSourceFactoryBean.setMessageSources(List<MessageSource> sources) |
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.
|
Modifier and Type | Field and Description |
---|---|
protected MessageSource |
AbstractPipeline.messageSource |
Modifier and Type | Method and Description |
---|---|
MessageSource |
AbstractPipeline.getMessageSource() |
Modifier and Type | Method and Description |
---|---|
void |
AbstractPipeline.setMessageSource(MessageSource messageSource) |
Constructor and Description |
---|
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) |
Validator(String name,
MuleContext muleContext,
MessageSource messageSource,
OutboundEndpoint outboundEndpoint,
Filter validationFilter,
String ackExpression,
String nackExpression) |
Validator(String name,
MuleContext muleContext,
MessageSource messageSource,
OutboundEndpoint outboundEndpoint,
Filter validationFilter,
String ackExpression,
String nackExpression,
String errorExpression) |
Modifier and Type | Field and Description |
---|---|
protected MessageSource |
AbstractFlowConstructBuilder.messageSource |
Modifier and Type | Method and Description |
---|---|
T |
AbstractFlowConstructBuilder.messageSource(MessageSource messageSource) |
Modifier and Type | Class and Description |
---|---|
class |
DefaultInboundEndpoint |
class |
DynamicURIInboundEndpoint
Allow's EndpointURI to be set and changed dynamically by wrapping up an immutable endpoint instance.
|
Modifier and Type | Class and Description |
---|---|
class |
OutboundResponsePropertiesMessageProcessor
Propagates properties from request message to response message as defined by
OutboundEndpoint.getResponseProperties() . |
class |
OutboundTxRollbackMessageProcessor
MessageProcessor implementation that stops outbound flow is the current
transaction has been rolled back.
|
Modifier and Type | Method and Description |
---|---|
MessageSource |
MessageProcessContext.getMessageSource() |
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. |
Modifier and Type | Class and Description |
---|---|
class |
ProcessIfStartedMessageProcessor |
class |
ProcessIfStartedWaitIfPausedMessageProcessor |
class |
ProcessIfStartedWaitIfSyncPausedMessageProcessor |
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 |
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 | Class and Description |
---|---|
class |
FlowConfiguringMessageProcessor
Wraps a
MessageProcessorBuilder and configures it lazily so it can
be injected with the FlowConstruct . |
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.
|
Modifier and Type | Interface and Description |
---|---|
interface |
HttpListener
Represents an listener for HTTP requests.
|
Modifier and Type | Class and Description |
---|---|
class |
DefaultHttpListener |
Modifier and Type | Method and Description |
---|---|
MessageSource |
HttpMessageProcessContext.getMessageSource() |
Modifier and Type | Class and Description |
---|---|
class |
ScriptFilter |
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,
String wsdlContents) |
WSProxy(String name,
MuleContext muleContext,
MessageSource messageSource,
OutboundEndpoint outboundEndpoint,
List<MessageProcessor> transformers,
List<MessageProcessor> responseTransformers,
URI wsdlUri) |
Modifier and Type | Class and Description |
---|---|
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 |
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 |
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 |
LaxAsyncInterceptingMessageProcessor |
class |
LaxSedaStageInterceptingMessageProcessor
Processes
MuleEvent 's asynchronously using a MuleWorkManager to schedule asynchronous
processing of the next MessageProcessor . |
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 | Class and Description |
---|---|
class |
AbstractAggregator
AbstractEventAggregator will aggregate a set of messages into a
single message. |
class |
AbstractCorrelationAggregator
AbstractCorrelationAggregatingMessageProcessor uses the CorrelationID
and CorrelationGroupSize properties of the MuleMessage to
manage message groups. |
class |
AbstractSplitter
Splits a message invoking the next message processor one for each split part.
|
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 |
ExpressionSplitter
Splits a message using the expression provided invoking the next message processor
one for each split part.
|
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 |
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 |
SimpleCollectionAggregator
This router will return all aggregated events as a
MuleMessageCollection . |
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. |
Modifier and Type | Class and Description |
---|---|
class |
AbstractReplyToPropertyRequestReplyReplier |
class |
AsyncReplyToPropertyRequestReplyReplier |
class |
ReplyToPropertyRequestReplyReplier |
class |
SimpleRequestReplyReplier |
Modifier and Type | Field and Description |
---|---|
protected MessageSource |
AbstractAsyncRequestReplyRequester.replyMessageSource |
Modifier and Type | Method and Description |
---|---|
void |
SimpleAsyncRequestReplyRequester.setMessageSource(MessageSource source)
Deprecated.
|
void |
AbstractAsyncRequestReplyRequester.setReplySource(MessageSource messageSource) |
protected void |
AbstractAsyncRequestReplyRequester.verifyReplyMessageSource(MessageSource messageSource) |
protected void |
SimpleAsyncRequestReplyRequester.verifyReplyMessageSource(MessageSource messageSource) |
Modifier and Type | Class and Description |
---|---|
class |
AbstractAuthorizeMessageProcessor |
class |
BaseOAuth1AuthorizeMessageProcessor |
class |
BaseOAuth2AuthorizeMessageProcessor<T extends OAuth2Manager<OAuth2Adapter>> |
Modifier and Type | Class and Description |
---|---|
class |
ForwardingConsumer
Deprecated.
|
class |
ServiceAsyncReplyCompositeMessageSource
Deprecated.
|
class |
ServiceCompositeMessageSource
Deprecated.
|
Modifier and Type | Field and Description |
---|---|
protected MessageSource |
AbstractService.messageSource
Deprecated.
|
Modifier and Type | Method and Description |
---|---|
MessageSource |
AbstractService.getMessageSource()
Deprecated.
|
Modifier and Type | Method and Description |
---|---|
void |
ServiceCompositeMessageSource.addSource(MessageSource source)
Deprecated.
|
void |
ServiceCompositeMessageSource.removeSource(MessageSource source)
Deprecated.
|
void |
AbstractService.setMessageSource(MessageSource inboundMessageSource)
Deprecated.
|
Modifier and Type | Method and Description |
---|---|
void |
ServiceCompositeMessageSource.setMessageSources(List<MessageSource> sources)
Deprecated.
|
Modifier and Type | Class and Description |
---|---|
class |
ServiceAsyncRequestReplyRequestor
Deprecated.
|
class |
ServiceInternalMessageProcessor
Deprecated.
|
class |
ServiceOutboundMessageProcessor
Deprecated.
|
Modifier and Type | Method and Description |
---|---|
protected void |
ServiceAsyncRequestReplyRequestor.verifyReplyMessageSource(MessageSource messageSource)
Deprecated.
|
Modifier and Type | Class and Description |
---|---|
class |
ClusterizableMessageSourceWrapper
Wraps a
ClusterizableMessageSource in order to manage the lifecycle
of the wrapped instance differently depending if the node is primary or not
inside a cluster. |
class |
StartableCompositeMessageSource
Implementation of
CompositeMessageSource that propagates both injection of FlowConstruct
and lifecycle to nested MessageSource s. |
Modifier and Type | Field and Description |
---|---|
protected List<MessageSource> |
StartableCompositeMessageSource.sources |
Modifier and Type | Method and Description |
---|---|
List<MessageSource> |
StartableCompositeMessageSource.getSources() |
Modifier and Type | Method and Description |
---|---|
void |
StartableCompositeMessageSource.addSource(MessageSource source) |
void |
StartableCompositeMessageSource.removeSource(MessageSource source) |
Modifier and Type | Method and Description |
---|---|
void |
StartableCompositeMessageSource.setMessageSources(List<MessageSource> sources) |
Modifier and Type | Class and Description |
---|---|
class |
ResponseAssertionMessageProcessor |
Modifier and Type | Class and Description |
---|---|
class |
InboundEndpointWrapper
Wraps an
InboundEndpoint enabling subclasses to override only those
methods which add extra behaviour. |
Modifier and Type | Class and Description |
---|---|
class |
AbstractMessageReceiver
AbstractMessageReceiver provides common methods for all Message
Receivers provided with Mule. |
class |
AbstractPollingMessageReceiver
AbstractPollingMessageReceiver implements a base class for polling
message receivers. |
class |
TransactedPollingMessageReceiver
The TransactedPollingMessageReceiver is an abstract receiver that handles polling
and transaction management.
|
Modifier and Type | Method and Description |
---|---|
protected MessageSource |
TransportMessageProcessContext.getMessageReceiver() |
MessageSource |
TransportMessageProcessContext.getMessageSource() |
Modifier and Type | Class and Description |
---|---|
class |
AjaxMessageReceiver
Registers a receiver service with Bayeux.
|
Modifier and Type | Class and Description |
---|---|
class |
EjbMessageReceiver
Will repeatedly call a method on an EJB object.
|
Modifier and Type | Class and Description |
---|---|
class |
RetrieveMessageReceiver
Poll a mailbox for messages, remove the messages and route them as events into
Mule.
|
Modifier and Type | Class and Description |
---|---|
class |
FileMessageReceiver
FileMessageReceiver is a polling listener that reads files from a
directory. |
Modifier and Type | Class and Description |
---|---|
class |
FtpMessageReceiver |
Modifier and Type | Class and Description |
---|---|
class |
HttpMessageReceiver
HttpMessageReceiver is a simple http server that can be used to
listen for HTTP requests on a particular port. |
class |
HttpsMessageReceiver |
class |
OldHttpMessageReceiver
HttpMessageReceiver is a simple http server that can be used to
listen for HTTP requests on a particular port. |
class |
OldHttpsMessageReceiver |
class |
PollingHttpMessageReceiver
Will poll an http URL and use the response as the input for a service request.
|
class |
PollingHttpsMessageReceiver |
Constructor and Description |
---|
HttpProxy(String name,
MuleContext muleContext,
MessageSource messageSource,
OutboundEndpoint outboundEndpoint,
List<MessageProcessor> transformers,
List<MessageProcessor> responseTransformers,
CachingStrategy cachingStrategy) |
Modifier and Type | Class and Description |
---|---|
class |
JdbcMessageReceiver
Implements
TransactedPollingMessageReceiver reading data from a database. |
Modifier and Type | Class and Description |
---|---|
class |
JmsMessageReceiver
Deprecated.
use
MultiConsumerJmsMessageReceiver (set by default). |
class |
MultiConsumerJmsMessageReceiver
In Mule an endpoint corresponds to a single receiver.
|
class |
SingleJmsMessageReceiver
Registers a single Jms MessageListener for an endpoint
|
class |
TransactedSingleResourceJmsMessageReceiver |
class |
XaTransactedJmsMessageReceiver |
Modifier and Type | Class and Description |
---|---|
class |
WebsphereTransactedJmsMessageReceiver |
Modifier and Type | Class and Description |
---|---|
class |
MulticastMessageReceiver |
Modifier and Type | Class and Description |
---|---|
class |
MessageProcessorPollingMessageReceiver
Polling
MessageSource . |
Modifier and Type | Class and Description |
---|---|
class |
QuartzMessageReceiver
Listens for Quartz sheduled events using the Receiver Job and fires events to the
service associated with this receiver.
|
Modifier and Type | Class and Description |
---|---|
class |
RmiCallbackMessageReceiver
TODO
|
class |
RmiMessageReceiver
Will repeatedly call a method on a Remote object.
|
Modifier and Type | Class and Description |
---|---|
class |
ServletMessageReceiver
ServletMessageReceiver is a receiver that is invoked from a Servlet
when an event is received. |
Modifier and Type | Class and Description |
---|---|
class |
JettyHttpMessageReceiver
JettyHttpMessageReceiver is a simple http server that can be used to
listen for http requests on a particular port |
Modifier and Type | Class and Description |
---|---|
class |
SftpMessageReceiver
SftpMessageReceiver polls and receives files from an sftp service
using jsch. |
Modifier and Type | Class and Description |
---|---|
class |
AxisMessageReceiver
AxisMessageReceiver is used to register a component as a service
with a Axis server. |
Modifier and Type | Class and Description |
---|---|
class |
SslMessageReceiver |
Modifier and Type | Class and Description |
---|---|
class |
StdioMessageReceiver
StdioMessageReceiver is a listener for events from Mule components
which then simply passes the events on to the target components. |
Modifier and Type | Class and Description |
---|---|
class |
ExceptionReturnTcpMessageReceiver
Extends
TcpMessageReceiver providing managing of protocol error conditions. |
class |
PollingTcpMessageReceiver
PollingTcpMessageReceiver acts like a TCP client polling for new
messages. |
class |
TcpMessageReceiver
TcpMessageReceiver acts like a TCP server to receive socket
requests. |
Modifier and Type | Class and Description |
---|---|
class |
UdpMessageReceiver
UdpMessageReceiver receives UDP message packets. |
Modifier and Type | Class and Description |
---|---|
class |
VMMessageReceiver
VMMessageReceiver is a listener for events from a Mule service which then simply passes
the events on to the target service. |
Modifier and Type | Class and Description |
---|---|
class |
XmppMessageReceiver
XmppMessageReceiver is responsible for receiving Mule events over XMPP. |
class |
XmppPollingMessageReceiver |
Copyright © 2003–2015 MuleSoft, Inc.. All rights reserved.