Package | Description |
---|---|
org.mule.construct | |
org.mule.endpoint.outbound | |
org.mule.interceptor | |
org.mule.lifecycle.processor | |
org.mule.module.atom.routing | |
org.mule.module.cxf | |
org.mule.module.db.internal.processor | |
org.mule.module.scripting.filter | |
org.mule.processor | |
org.mule.routing |
Defines the core routing patterns supported by mule.
|
org.mule.routing.outbound |
Outbound router implementation as described in the Enterprise Integration Patterns book.
|
org.mule.routing.requestreply | |
org.mule.service | |
org.mule.service.processor |
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 | 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 | 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 |
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 | Class and Description |
---|---|
class |
ScriptFilter |
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 |
AbstractAsyncRequestReplyRequester |
class |
AbstractReplyToPropertyRequestReplyReplier |
class |
AsyncReplyToPropertyRequestReplyReplier |
class |
ReplyToPropertyRequestReplyReplier |
class |
SimpleAsyncRequestReplyRequester |
class |
SimpleRequestReplyReplier |
Modifier and Type | Class and Description |
---|---|
class |
ForwardingConsumer
Deprecated.
|
Modifier and Type | Class and Description |
---|---|
class |
ServiceAsyncRequestReplyRequestor
Deprecated.
|
class |
ServiceInternalMessageProcessor
Deprecated.
|
class |
ServiceOutboundMessageProcessor
Deprecated.
|
Copyright © 2003–2016 MuleSoft, Inc.. All rights reserved.