Modifier and Type | Class and Description |
---|---|
class |
DefaultMessageCollection
A
MuleMessage type that manages a collection of MuleMessage Objects. |
class |
DefaultMuleMessage
DefaultMuleMessage is a wrapper that contains a payload and properties
associated with the payload. |
Modifier and Type | Method and Description |
---|---|
MuleMessage |
DefaultMuleMessage.createInboundMessage() |
MuleMessage |
DefaultMessageCollection.createInboundMessage()
Copy an inbound message to an outbound one, moving all message properties and attachments
|
MuleMessage |
VoidMuleEvent.getMessage() |
MuleMessage |
DefaultMuleEventContext.getMessage()
Returns the message payload for this event
|
MuleMessage |
DefaultMuleEvent.getMessage() |
MuleMessage |
DefaultMessageCollection.getMessage(int index) |
MuleMessage[] |
DefaultMessageCollection.getMessagesAsArray() |
protected static MuleMessage |
RequestContext.internalRewriteEvent(MuleMessage message,
boolean safe)
Deprecated.
|
protected static MuleMessage |
RequestContext.newMessage(MuleMessage message,
boolean safe)
Deprecated.
|
MuleMessage |
DefaultMuleEventContext.requestEvent(EndpointURI endpointUri,
long timeout)
Requests a synchronous receive of an event on the service
|
MuleMessage |
DefaultMuleEventContext.requestEvent(InboundEndpoint endpoint,
long timeout)
Requests a synchronous receive of an event on the service
|
MuleMessage |
DefaultMuleEventContext.requestEvent(String endpointName,
long timeout)
Requests a synchronous receive of an event on the service
|
static MuleMessage |
RequestContext.safeMessageCopy(MuleMessage message)
Deprecated.
|
MuleMessage |
DefaultMuleEventContext.sendEvent(MuleMessage message)
Depending on the session state this methods either Passes an event
synchronously to the next available Mule component in the pool or via the
endpoint configured for the event
|
MuleMessage |
DefaultMuleEventContext.sendEvent(MuleMessage message,
EndpointURI endpointUri)
Depending on the session state this methods either Passes an event
synchronously to the next available Mule component in the pool or via the
endpointUri configured for the event
|
MuleMessage |
DefaultMuleEventContext.sendEvent(MuleMessage message,
OutboundEndpoint endpoint)
Depending on the session state this methods either Passes an event
synchronously to the next available Mule component in the pool or via the
endpoint configured for the event
|
MuleMessage |
DefaultMuleEventContext.sendEvent(MuleMessage message,
String endpointName)
Depending on the session state this methods either Passes an event
synchronously to the next available Mule component in the pool or via the
endpoint configured for the event
|
MuleMessage |
DefaultMuleEventContext.sendEvent(Object message)
This will send an event via the configured outbound router on the service
|
static MuleMessage |
OptimizedRequestContext.unsafeRewriteEvent(MuleMessage message)
Deprecated.
Sets a new message payload in the RequestContext but maintains all other
properties (session, endpoint, synchronous, etc.) from the previous event.
|
Modifier and Type | Method and Description |
---|---|
protected List<MuleMessage> |
DefaultMessageCollection.getMessageList() |
Modifier and Type | Method and Description |
---|---|
void |
DefaultMessageCollection.addMessage(MuleMessage message) |
void |
DefaultMessageCollection.addMessage(MuleMessage message,
int index) |
void |
DefaultMessageCollection.addMessages(MuleMessage[] messages) |
protected void |
DefaultMuleMessage.copyMessageProperties(MuleMessage muleMessage) |
void |
DefaultMuleEventContext.dispatchEvent(MuleMessage message)
This will dispatch an event asynchronously via the configured outbound
endpoint on the service for this session
|
void |
DefaultMuleEventContext.dispatchEvent(MuleMessage message,
EndpointURI endpointUri)
Depending on the session state this methods either Passes an event
asynchronously to the next available Mule component in the pool or via the
endpointUri configured for the event
|
void |
DefaultMuleEventContext.dispatchEvent(MuleMessage message,
OutboundEndpoint endpoint)
Depending on the session state this methods either Passes an event
asynchronously to the next available Mule component in the pool or via the
endpoint configured for the event
|
void |
DefaultMuleEventContext.dispatchEvent(MuleMessage message,
String endpointName)
Depending on the session state this methods either Passes an event
asynchronously to the next available Mule component in the pool or via the
endpoint configured for the event
|
protected static MuleMessage |
RequestContext.internalRewriteEvent(MuleMessage message,
boolean safe)
Deprecated.
|
protected static MuleMessage |
RequestContext.newMessage(MuleMessage message,
boolean safe)
Deprecated.
|
void |
DefaultMuleMessage.propagateRootId(MuleMessage parent) |
void |
DefaultMessageCollection.removedMessage(MuleMessage message) |
static MuleMessage |
RequestContext.safeMessageCopy(MuleMessage message)
Deprecated.
|
MuleMessage |
DefaultMuleEventContext.sendEvent(MuleMessage message)
Depending on the session state this methods either Passes an event
synchronously to the next available Mule component in the pool or via the
endpoint configured for the event
|
MuleMessage |
DefaultMuleEventContext.sendEvent(MuleMessage message,
EndpointURI endpointUri)
Depending on the session state this methods either Passes an event
synchronously to the next available Mule component in the pool or via the
endpointUri configured for the event
|
MuleMessage |
DefaultMuleEventContext.sendEvent(MuleMessage message,
OutboundEndpoint endpoint)
Depending on the session state this methods either Passes an event
synchronously to the next available Mule component in the pool or via the
endpoint configured for the event
|
MuleMessage |
DefaultMuleEventContext.sendEvent(MuleMessage message,
String endpointName)
Depending on the session state this methods either Passes an event
synchronously to the next available Mule component in the pool or via the
endpoint configured for the event
|
FutureMessageResult |
DefaultMuleEventContext.sendEventAsync(MuleMessage message,
EndpointURI endpointUri,
int timeout)
sends an event request via the configured outbound router for this service.
|
FutureMessageResult |
DefaultMuleEventContext.sendEventAsync(MuleMessage message,
int timeout)
sends an event request via the configured outbound router for this service.
|
FutureMessageResult |
DefaultMuleEventContext.sendEventAsync(MuleMessage message,
String endpointName,
int timeout)
sends an event request via the configured outbound router for this service.
|
void |
VoidMuleEvent.setMessage(MuleMessage message) |
void |
DefaultMuleEvent.setMessage(MuleMessage message) |
static MuleMessage |
OptimizedRequestContext.unsafeRewriteEvent(MuleMessage message)
Deprecated.
Sets a new message payload in the RequestContext but maintains all other
properties (session, endpoint, synchronous, etc.) from the previous event.
|
Modifier and Type | Method and Description |
---|---|
void |
DefaultMessageCollection.addMessages(List<MuleMessage> messages) |
Constructor and Description |
---|
DefaultMuleEvent(MuleMessage message,
InboundEndpoint endpoint,
FlowConstruct flowConstruct) |
DefaultMuleEvent(MuleMessage message,
InboundEndpoint endpoint,
FlowConstruct flowConstruct,
MuleSession session) |
DefaultMuleEvent(MuleMessage message,
InboundEndpoint endpoint,
FlowConstruct flowConstruct,
MuleSession session,
ReplyToHandler replyToHandler,
Object replyToDestination,
OutputStream outputStream) |
DefaultMuleEvent(MuleMessage message,
InboundEndpoint endpoint,
MuleSession session)
Deprecated.
|
DefaultMuleEvent(MuleMessage message,
InboundEndpoint endpoint,
MuleSession session,
ReplyToHandler replyToHandler,
OutputStream outputStream,
Object replyToDestination)
Deprecated.
|
DefaultMuleEvent(MuleMessage message,
MessageExchangePattern exchangePattern,
FlowConstruct flowConstruct)
Constructor used to create an event with no message source with minimal arguments
|
DefaultMuleEvent(MuleMessage message,
MessageExchangePattern exchangePattern,
FlowConstruct flowConstruct,
MuleSession session)
Constructor used to create an event with no message source with minimal arguments and a
MuleSession |
DefaultMuleEvent(MuleMessage message,
MessageExchangePattern exchangePattern,
FlowConstruct flowConstruct,
MuleSession session,
int timeout,
Credentials credentials,
OutputStream outputStream)
Constructor used to create an event with no message source with all additional arguments
|
DefaultMuleEvent(MuleMessage message,
MessageExchangePattern exchangePattern,
FlowConstruct flowConstruct,
MuleSession session,
OutputStream outputStream)
Constructor used to create an event with no message source with minimal arguments and
OutputStream
|
DefaultMuleEvent(MuleMessage message,
MessageExchangePattern exchangePattern,
MuleSession session)
Deprecated.
|
DefaultMuleEvent(MuleMessage message,
MessageExchangePattern exchangePattern,
MuleSession session,
int timeout,
Credentials credentials,
OutputStream outputStream)
Deprecated.
|
DefaultMuleEvent(MuleMessage message,
MessageExchangePattern exchangePattern,
MuleSession session,
OutputStream outputStream)
Deprecated.
|
DefaultMuleEvent(MuleMessage message,
MessageExchangePattern exchangePattern,
ReplyToHandler replyToHandler,
FlowConstruct flowConstruct)
Constructor used to create an event with no message source with minimal arguments and a
ReplyToHandler |
DefaultMuleEvent(MuleMessage message,
MuleEvent rewriteEvent)
A helper constructor used to rewrite an event payload
|
DefaultMuleEvent(MuleMessage message,
MuleEvent rewriteEvent,
boolean synchronus) |
DefaultMuleEvent(MuleMessage message,
MuleEvent rewriteEvent,
boolean synchronus,
boolean shareFlowVars) |
DefaultMuleEvent(MuleMessage message,
MuleEvent rewriteEvent,
boolean synchronus,
boolean shareFlowVars,
MessageExchangePattern messageExchangePattern)
Copy constructor to be used when synchronicity and
MessageExchangePattern both need changing. |
DefaultMuleEvent(MuleMessage message,
MuleEvent rewriteEvent,
FlowConstruct flowConstruct,
MuleSession session,
boolean synchronous) |
DefaultMuleEvent(MuleMessage message,
MuleEvent rewriteEvent,
FlowConstruct flowConstruct,
MuleSession session,
boolean synchronous,
boolean shareFlowVars,
MessageExchangePattern messageExchangePattern) |
DefaultMuleEvent(MuleMessage message,
MuleEvent rewriteEvent,
FlowConstruct flowConstruct,
MuleSession session,
boolean synchronous,
ReplyToHandler replyToHandler,
Object replyToDestination,
boolean shareFlowVars,
MessageExchangePattern messageExchangePattern) |
DefaultMuleEvent(MuleMessage message,
MuleEvent rewriteEvent,
MuleSession session)
A helper constructor used to rewrite an event payload
|
DefaultMuleEvent(MuleMessage message,
URI messageSourceURI,
MessageExchangePattern exchangePattern,
FlowConstruct flowConstruct,
MuleSession session)
Constructor used to create an event with a uri that idendifies the message source with minimal
arguments
|
DefaultMuleEvent(MuleMessage message,
URI messageSourceURI,
MessageExchangePattern exchangePattern,
FlowConstruct flowConstruct,
MuleSession session,
int timeout,
Credentials credentials,
OutputStream outputStream)
Constructor used to create an event with a identifiable message source with all additional arguments except
a
ReplyToHandler |
DefaultMuleEvent(MuleMessage message,
URI messageSourceURI,
MessageExchangePattern exchangePattern,
FlowConstruct flowConstruct,
MuleSession session,
int timeout,
Credentials credentials,
OutputStream outputStream,
ReplyToHandler replyToHandler)
Constructor used to create an event with a identifiable message source with all additional arguments
|
DefaultMuleEvent(MuleMessage message,
URI messageSourceURI,
MessageExchangePattern exchangePattern,
FlowConstruct flowConstruct,
MuleSession session,
OutputStream outputStream)
Constructor used to create an event with a uri that idendifies the message source with minimal
arguments and OutputStream
|
DefaultMuleEvent(MuleMessage message,
URI messageSourceURI,
MessageExchangePattern exchangePattern,
MuleSession session)
Deprecated.
|
DefaultMuleEvent(MuleMessage message,
URI messageSourceURI,
MessageExchangePattern exchangePattern,
MuleSession session,
int timeout,
Credentials credentials,
OutputStream outputStream)
Deprecated.
|
DefaultMuleEvent(MuleMessage message,
URI messageSourceURI,
MessageExchangePattern exchangePattern,
MuleSession session,
OutputStream outputStream)
Deprecated.
|
DefaultMuleEvent(MuleMessage message,
URI messageSourceURI,
String messageSourceName,
MessageExchangePattern exchangePattern,
FlowConstruct flowConstruct,
MuleSession session,
int timeout,
Credentials credentials,
OutputStream outputStream,
String encoding,
boolean transacted,
boolean synchronous,
Object replyToDestination,
ReplyToHandler replyToHandler) |
DefaultMuleEvent(MuleMessage message,
URI messageSourceURI,
String messageSourceName,
MessageExchangePattern exchangePattern,
MuleSession session,
int timeout,
Credentials credentials,
OutputStream outputStream,
String encoding,
boolean transacted,
boolean synchronous,
Object replyToDestination,
ReplyToHandler replyToHandler)
Deprecated.
|
DefaultMuleMessage(MuleMessage message) |
DefaultMuleMessage(Object message,
MuleMessage previous,
MuleContext muleContext) |
Modifier and Type | Interface and Description |
---|---|
interface |
MuleMessageCollection
An interface that defines a collection of Mule Messages and methods for working with the collection.
|
Modifier and Type | Field and Description |
---|---|
protected MuleMessage |
MessagingException.muleMessage
The MuleMessage being processed when the error occurred
|
Modifier and Type | Method and Description |
---|---|
MuleMessage |
MuleMessage.createInboundMessage()
Copy an inbound message to an outbound one, moving all message properties and attachments
|
MuleMessage |
MuleEvent.getMessage()
Returns the message payload for this event
|
MuleMessage |
MuleEventContext.getMessage()
Returns the message payload for this event
|
MuleMessage |
FutureMessageResult.getMessage() |
MuleMessage |
MuleMessageCollection.getMessage(int index) |
MuleMessage |
FutureMessageResult.getMessage(long timeout) |
MuleMessage[] |
MuleMessageCollection.getMessagesAsArray() |
MuleMessage |
MessagingException.getMuleMessage()
Deprecated.
use
#getEvent().getMessage() instead |
MuleMessage |
MuleEventContext.requestEvent(EndpointURI endpoint,
long timeout)
Deprecated.
|
MuleMessage |
MuleEventContext.requestEvent(InboundEndpoint endpoint,
long timeout)
Requests a synchronous receive of an event on the service.
|
MuleMessage |
MuleEventContext.requestEvent(String endpointName,
long timeout)
Requests a synchronous receive of an event on the service.
|
MuleMessage |
MuleEventContext.sendEvent(MuleMessage message)
Deprecated.
|
MuleMessage |
MuleEventContext.sendEvent(MuleMessage message,
EndpointURI endpoint)
Deprecated.
|
MuleMessage |
MuleEventContext.sendEvent(MuleMessage message,
OutboundEndpoint endpoint)
Depending on the session state this methods either Passes an event
synchronously to the next available Mule component in the pool or via the endpoint
configured for the event
|
MuleMessage |
MuleEventContext.sendEvent(MuleMessage message,
String endpointName)
Depending on the session state this methods either Passes an event
synchronously to the next available Mule component in the pool or via the endpoint
configured for the event
|
MuleMessage |
MuleEventContext.sendEvent(Object message)
Deprecated.
|
Modifier and Type | Method and Description |
---|---|
void |
MuleMessageCollection.addMessage(MuleMessage message) |
void |
MuleMessageCollection.addMessage(MuleMessage message,
int index) |
void |
MuleMessageCollection.addMessages(MuleMessage[] messages) |
void |
MuleEventContext.dispatchEvent(MuleMessage message)
Deprecated.
|
void |
MuleEventContext.dispatchEvent(MuleMessage message,
EndpointURI endpoint)
Deprecated.
|
void |
MuleEventContext.dispatchEvent(MuleMessage message,
OutboundEndpoint endpoint)
Depending on the session state this methods either Passes an event
asynchronously to the next available Mule component in the pool or via the endpoint
configured for the event
|
void |
MuleEventContext.dispatchEvent(MuleMessage message,
String endpointName)
Depending on the session state this methods either Passes an event
asynchronously to the next available Mule component in the pool or via the endpoint
configured for the event.
|
void |
MuleMessage.propagateRootId(MuleMessage parent)
copy the message root id from parent to child
|
void |
MuleMessageCollection.removedMessage(MuleMessage message) |
MuleMessage |
MuleEventContext.sendEvent(MuleMessage message)
Deprecated.
|
MuleMessage |
MuleEventContext.sendEvent(MuleMessage message,
EndpointURI endpoint)
Deprecated.
|
MuleMessage |
MuleEventContext.sendEvent(MuleMessage message,
OutboundEndpoint endpoint)
Depending on the session state this methods either Passes an event
synchronously to the next available Mule component in the pool or via the endpoint
configured for the event
|
MuleMessage |
MuleEventContext.sendEvent(MuleMessage message,
String endpointName)
Depending on the session state this methods either Passes an event
synchronously to the next available Mule component in the pool or via the endpoint
configured for the event
|
FutureMessageResult |
MuleEventContext.sendEventAsync(MuleMessage message,
EndpointURI endpoint,
int timeout)
sends an event request via the configured outbound router for this service.
|
FutureMessageResult |
MuleEventContext.sendEventAsync(MuleMessage message,
int timeout)
Deprecated.
|
FutureMessageResult |
MuleEventContext.sendEventAsync(MuleMessage message,
String endpointName,
int timeout)
sends an event request via the configured outbound router for this service.
|
void |
MuleEvent.setMessage(MuleMessage message) |
Modifier and Type | Method and Description |
---|---|
void |
MuleMessageCollection.addMessages(List<MuleMessage> messages) |
Constructor and Description |
---|
MessagingException(Message message,
MuleMessage muleMessage)
Deprecated.
use MessagingException(Message, MuleEvent)
|
MessagingException(Message message,
MuleMessage muleMessage,
Throwable cause)
Deprecated.
use MessagingException(Message, MuleEvent, Throwable)
|
Modifier and Type | Method and Description |
---|---|
MuleMessage |
LocalMuleClient.process(OutboundEndpoint endpoint,
MuleMessage message)
Sends an event synchronously to a endpointUri via a Mule server and a
resulting message is returned.
|
MuleMessage |
LocalMuleClient.process(OutboundEndpoint endpoint,
Object payload,
Map<String,Object> messageProperties)
Sends an event synchronously to a endpointUri via a Mule server and a
resulting message is returned.
|
MuleMessage |
MuleClient.process(String uri,
MessageExchangePattern mep,
MuleMessage message)
Processes a messsage with an outbound endpoint using the specified
MessageExchangePattern |
MuleMessage |
MuleClient.process(String uri,
MessageExchangePattern mep,
Object payload,
Map<String,Object> messageProperties)
Processes a message with an outbound endpoint using the specified
MessageExchangePattern |
MuleMessage |
LocalMuleClient.request(InboundEndpoint endpoint,
long timeout)
Will receive an event from an endpointUri determined by the URL.
|
MuleMessage |
MuleClient.request(String url,
long timeout)
Will receive an event from an endpointUri determined by the URL.
|
MuleMessage |
MuleClient.send(String url,
MuleMessage message)
Sends an event synchronously to a endpointUri via a Mule server and a
resulting message is returned.
|
MuleMessage |
MuleClient.send(String url,
MuleMessage message,
long timeout)
Deprecated.
use
MuleClient.send(String, org.mule.api.MuleMessage, OperationOptions) instead
Sends an event synchronously to a endpointUri via a mule server and a
resulting message is returned. |
MuleMessage |
MuleClient.send(String url,
MuleMessage message,
OperationOptions operationOptions)
Sends an event synchronously to a endpointUri via a Mule server and a
resulting message is returned.
|
MuleMessage |
MuleClient.send(String url,
Object payload,
Map<String,Object> messageProperties)
Deprecated.
use
MuleClient.send(String, org.mule.api.MuleMessage) instead
Sends an event synchronously to a endpointUri via a Mule server and a
resulting message is returned. |
MuleMessage |
MuleClient.send(String url,
Object payload,
Map<String,Object> messageProperties,
long timeout)
Deprecated.
use
MuleClient.send(String, org.mule.api.MuleMessage, OperationOptions)
Sends an event synchronously to a endpointUri via a mule server and a
resulting message is returned. |
Modifier and Type | Method and Description |
---|---|
void |
MuleClient.dispatch(String url,
MuleMessage message)
Dispatches an event asynchronously to a endpointUri via a Mule server.
|
void |
MuleClient.dispatch(String url,
MuleMessage message,
OperationOptions operationOptions)
Dispatches an event asynchronously to a endpointUri via a Mule server.
|
MuleMessage |
LocalMuleClient.process(OutboundEndpoint endpoint,
MuleMessage message)
Sends an event synchronously to a endpointUri via a Mule server and a
resulting message is returned.
|
MuleMessage |
MuleClient.process(String uri,
MessageExchangePattern mep,
MuleMessage message)
Processes a messsage with an outbound endpoint using the specified
MessageExchangePattern |
MuleMessage |
MuleClient.send(String url,
MuleMessage message)
Sends an event synchronously to a endpointUri via a Mule server and a
resulting message is returned.
|
MuleMessage |
MuleClient.send(String url,
MuleMessage message,
long timeout)
Deprecated.
use
MuleClient.send(String, org.mule.api.MuleMessage, OperationOptions) instead
Sends an event synchronously to a endpointUri via a mule server and a
resulting message is returned. |
MuleMessage |
MuleClient.send(String url,
MuleMessage message,
OperationOptions operationOptions)
Sends an event synchronously to a endpointUri via a Mule server and a
resulting message is returned.
|
Modifier and Type | Method and Description |
---|---|
protected static MuleMessage |
ServerNotification.cloneMessage(MuleMessage message) |
MuleMessage |
MuleMessageAware.getMessage() |
Modifier and Type | Method and Description |
---|---|
protected static MuleMessage |
ServerNotification.cloneMessage(MuleMessage message) |
Modifier and Type | Method and Description |
---|---|
T |
ProcessTemplate.execute(ProcessCallback<T,O> callback,
Filter filter,
MuleMessage message) |
T |
ProcessInterceptor.execute(ProcessCallback<T,O> callback,
O under,
Filter filter,
MuleMessage message) |
Modifier and Type | Method and Description |
---|---|
void |
ExpressionLanguage.enrich(String expression,
MuleMessage message,
TypedValue value)
Enriches a message
|
<T> T |
ExpressionLanguage.evaluate(String expression,
MuleMessage message)
Deprecated.
|
<T> T |
ExpressionLanguage.evaluate(String expression,
MuleMessage message,
Map<String,Object> vars)
Deprecated.
|
TypedValue |
ExpressionLanguage.evaluateTyped(String expression,
MuleMessage message) |
Modifier and Type | Method and Description |
---|---|
void |
ExpressionManager.enrich(String expression,
MuleMessage message,
Object object)
Deprecated.
|
void |
ExpressionEnricher.enrich(String expression,
MuleMessage message,
Object object)
Enriches the message with the object
|
void |
ExpressionManager.enrich(String expression,
String enricher,
MuleMessage message,
Object object)
Enriches the current message
|
void |
ExpressionManager.enrichTyped(String expression,
MuleMessage message,
TypedValue object)
Enriches the current message using a typed value
|
Object |
ExpressionManager.evaluate(String expression,
MuleMessage message)
Deprecated.
|
Object |
ExpressionEvaluator.evaluate(String expression,
MuleMessage message)
Extracts a single property from the message
|
Object |
ExpressionManager.evaluate(String expression,
MuleMessage message,
boolean failIfNull)
Deprecated.
|
Object |
ExpressionManager.evaluate(String expression,
String evaluator,
MuleMessage message,
boolean failIfNull)
Evaluates the given expression.
|
boolean |
ExpressionManager.evaluateBoolean(String expression,
MuleMessage message)
Deprecated.
|
boolean |
ExpressionManager.evaluateBoolean(String expression,
MuleMessage message,
boolean nullReturnsTrue,
boolean nonBooleanReturnsTrue)
Deprecated.
|
boolean |
ExpressionManager.evaluateBoolean(String expression,
String evaluator,
MuleMessage message)
Evaluates the given expression resolving the result of the evaluation to a boolean.
|
boolean |
ExpressionManager.evaluateBoolean(String expression,
String evaluator,
MuleMessage message,
boolean nullReturnsTrue,
boolean nonBooleanReturnsTrue)
Evaluates the given expression resolving the result of the evaluation to a boolean.
|
TypedValue |
ExpressionManager.evaluateTyped(String expression,
MuleMessage message) |
TypedValue |
ExpressionEvaluator.evaluateTyped(String expression,
MuleMessage message)
Extracts a single typed property from the message
|
TypedValue |
ExpressionManager.evaluateTyped(String expression,
String evaluator,
MuleMessage message,
boolean failIfNull)
Evaluates the given expression propagating dataType.
|
String |
ExpressionManager.parse(String expression,
MuleMessage message)
Deprecated.
|
String |
ExpressionManager.parse(String expression,
MuleMessage message,
boolean failIfNull)
Deprecated.
|
Modifier and Type | Method and Description |
---|---|
MuleMessage |
RetryContext.getFirstReturnMessage() |
MuleMessage[] |
RetryContext.getReturnMessages() |
Modifier and Type | Method and Description |
---|---|
void |
RetryContext.addReturnMessage(MuleMessage result) |
void |
RetryContext.setReturnMessages(MuleMessage[] returnMessages) |
Modifier and Type | Method and Description |
---|---|
String |
MessageInfoMapping.getCorrelationId(MuleMessage message) |
String |
MessageInfoMapping.getMessageId(MuleMessage message) |
boolean |
Matchable.isMatch(MuleMessage message)
Determines if the event should be processed
|
Modifier and Type | Method and Description |
---|---|
boolean |
Filter.accept(MuleMessage message)
Check a given message against this filter.
|
Modifier and Type | Method and Description |
---|---|
MuleMessage |
MuleMessageFactory.create(Object transportMessage,
MuleMessage previousMessage,
String encoding)
Deprecated.
|
MuleMessage |
MuleMessageFactory.create(Object transportMessage,
MuleMessage previousMessage,
String encoding,
MuleContext muleContext)
Creates a
MuleMessage instance by extracting the payload from
transportMessage . |
MuleMessage |
MuleMessageFactory.create(Object transportMessage,
String encoding)
Deprecated.
|
MuleMessage |
MuleMessageFactory.create(Object transportMessage,
String encoding,
MuleContext muleContext)
Creates a
MuleMessage instance from transportMessage by extracting
its payload and, if available, any relevant message properties and attachments. |
MuleMessage |
MessageReceiver.createMuleMessage(Object transportMessage) |
MuleMessage |
MessageDispatcher.createMuleMessage(Object transportMessage) |
MuleMessage |
MessageRequester.createMuleMessage(Object transportMessage) |
MuleMessage |
MessageReceiver.createMuleMessage(Object transportMessage,
String encoding) |
MuleMessage |
MessageDispatcher.createMuleMessage(Object transportMessage,
String encoding) |
MuleMessage |
MessageRequester.createMuleMessage(Object transportMessage,
String encoding) |
MuleMessage |
InternalMessageListener.onMessage(MuleMessage message,
Transaction trans,
boolean synchronous,
OutputStream outputStream) |
MuleMessage |
Connector.request(InboundEndpoint endpoint,
long timeout)
Make a specific request to the underlying transport
|
MuleMessage |
MessageRequesting.request(long timeout)
Make a specific request to the underlying transport
|
MuleMessage |
Connector.request(String uri,
long timeout)
Deprecated.
Use request(ImmutableEndpoint endpoint, long timeout)
|
MuleMessage |
MessageDispatching.send(MuleEvent event)
Sends an event from the endpoint to the external system
|
Modifier and Type | Method and Description |
---|---|
MuleMessage |
MuleMessageFactory.create(Object transportMessage,
MuleMessage previousMessage,
String encoding)
Deprecated.
|
MuleMessage |
MuleMessageFactory.create(Object transportMessage,
MuleMessage previousMessage,
String encoding,
MuleContext muleContext)
Creates a
MuleMessage instance by extracting the payload from
transportMessage . |
MuleMessage |
InternalMessageListener.onMessage(MuleMessage message,
Transaction trans,
boolean synchronous,
OutputStream outputStream) |
void |
ReplyToHandler.processReplyTo(MuleEvent event,
MuleMessage returnMessage,
Object replyTo) |
void |
ExceptionHandlingReplyToHandlerDecorator.processReplyTo(MuleEvent event,
MuleMessage returnMessage,
Object replyTo) |
MuleSession |
SessionHandler.retrieveSessionInfoFromMessage(MuleMessage message) |
void |
SessionHandler.retrieveSessionInfoFromMessage(MuleMessage message,
MuleSession session)
Deprecated.
Use retrieveSessionInfoFromMessage(MuleMessage message) instead
|
MuleEvent |
MessageReceiver.routeMessage(MuleMessage message) |
MuleEvent |
MessageReceiver.routeMessage(MuleMessage message,
Transaction trans) |
MuleEvent |
MessageReceiver.routeMessage(MuleMessage message,
Transaction trans,
OutputStream outputStream) |
void |
SessionHandler.storeSessionInfoToMessage(MuleSession session,
MuleMessage message) |
Modifier and Type | Method and Description |
---|---|
MuleMessage |
DefaultLocalMuleClient.process(OutboundEndpoint endpoint,
MuleMessage message) |
MuleMessage |
DefaultLocalMuleClient.process(OutboundEndpoint endpoint,
Object payload,
Map<String,Object> messageProperties) |
MuleMessage |
DefaultLocalMuleClient.process(String uri,
MessageExchangePattern mep,
MuleMessage message) |
MuleMessage |
DefaultLocalMuleClient.process(String uri,
MessageExchangePattern mep,
Object payload,
Map<String,Object> messageProperties) |
MuleMessage |
DefaultLocalMuleClient.request(InboundEndpoint endpoint,
long timeout) |
MuleMessage |
DefaultLocalMuleClient.request(String url,
long timeout) |
protected MuleMessage |
DefaultLocalMuleClient.returnMessage(MuleEvent event) |
MuleMessage |
DefaultLocalMuleClient.send(String url,
MuleMessage message) |
MuleMessage |
DefaultLocalMuleClient.send(String url,
MuleMessage message,
long timeout) |
MuleMessage |
DefaultLocalMuleClient.send(String url,
MuleMessage message,
OperationOptions operationOptions) |
MuleMessage |
DefaultLocalMuleClient.send(String url,
Object payload,
Map<String,Object> messageProperties) |
MuleMessage |
DefaultLocalMuleClient.send(String url,
Object payload,
Map<String,Object> messageProperties,
long timeout) |
Modifier and Type | Method and Description |
---|---|
protected MuleEvent |
DefaultLocalMuleClient.createMuleEvent(MuleMessage message,
OutboundEndpoint endpoint) |
protected MuleEvent |
DefaultLocalMuleClient.createRequestResponseMuleEvent(MuleMessage message) |
void |
DefaultLocalMuleClient.dispatch(String url,
MuleMessage message) |
void |
DefaultLocalMuleClient.dispatch(String url,
MuleMessage message,
OperationOptions operationOptions) |
MuleMessage |
DefaultLocalMuleClient.process(OutboundEndpoint endpoint,
MuleMessage message) |
MuleMessage |
DefaultLocalMuleClient.process(String uri,
MessageExchangePattern mep,
MuleMessage message) |
MuleMessage |
DefaultLocalMuleClient.send(String url,
MuleMessage message) |
MuleMessage |
DefaultLocalMuleClient.send(String url,
MuleMessage message,
long timeout) |
MuleMessage |
DefaultLocalMuleClient.send(String url,
MuleMessage message,
OperationOptions operationOptions) |
Modifier and Type | Method and Description |
---|---|
protected void |
AbstractComponent.fireComponentNotification(MuleMessage message,
int action) |
Modifier and Type | Method and Description |
---|---|
boolean |
ContentBasedRouter.isMatch(MuleMessage message)
Deprecated.
|
Modifier and Type | Method and Description |
---|---|
Object |
AnnotatedTransformerProxy.transformMessage(MuleMessage message,
String outputEncoding) |
Modifier and Type | Method and Description |
---|---|
MuleMessage |
ComponentMessageNotification.getSource() |
MuleMessage |
BaseConnectorMessageNotification.getSource() |
Modifier and Type | Method and Description |
---|---|
void |
NotificationHelper.fireNotification(MuleMessage message,
String uri,
FlowConstruct flowConstruct,
int action) |
Constructor and Description |
---|
BaseConnectorMessageNotification(MuleMessage resource,
String endpoint,
FlowConstruct flowConstruct,
int action) |
ComponentMessageNotification(MuleMessage message,
Component component,
FlowConstruct flowConstruct,
int action) |
ConnectorMessageNotification(MuleMessage resource,
String endpoint,
FlowConstruct flowConstruct,
int action) |
EndpointMessageNotification(MuleMessage resource,
ImmutableEndpoint endpoint,
FlowConstruct flowConstruct,
int action) |
RoutingNotification(MuleMessage resource,
String identifier,
int action) |
Modifier and Type | Method and Description |
---|---|
protected Object |
ExpressionEvaluatorSupport.evaluate(TemplateParser.PatternInfo patternInfo,
ExpressionManager expressionManager,
MuleMessage muleMessage,
Object source) |
protected Object |
ExpressionEvaluatorSupport.evaluateAndTransform(MuleContext muleContext,
MuleMessage muleMessage,
Type expectedType,
String expectedMimeType,
Object source) |
protected Object |
ExpressionEvaluatorSupport.transform(MuleContext muleContext,
MuleMessage message,
Type expectedType,
String expectedMimeType,
Object source) |
protected Object |
ExpressionEvaluatorSupport.transform(MuleMessage muleMessage,
Type expectedType,
Object source) |
Modifier and Type | Field and Description |
---|---|
protected MuleMessage |
MessageContext.message |
Constructor and Description |
---|
InboundAttachmentMapContext(MuleMessage message) |
MessageContext(MuleMessage message) |
MessagePropertyMapContext(MuleMessage message,
PropertyScope propertyScope) |
OutboundAttachmentMapContext(MuleMessage message) |
Modifier and Type | Method and Description |
---|---|
protected org.mule.mvel2.integration.VariableResolverFactory |
MVELExpressionLanguage.createVariableVariableResolverFactory(MuleMessage message)
Deprecated.
|
void |
MVELExpressionLanguage.enrich(String expression,
MuleMessage message,
TypedValue typedValue) |
<T> T |
MVELExpressionLanguage.evaluate(String expression,
MuleMessage message)
Deprecated.
|
<T> T |
MVELExpressionLanguage.evaluate(String expression,
MuleMessage message,
Map<String,Object> vars)
Deprecated.
|
TypedValue |
MVELExpressionLanguage.evaluateTyped(String expression,
MuleMessage message) |
Constructor and Description |
---|
MessageVariableResolverFactory(org.mule.mvel2.ParserConfiguration parserConfiguration,
MuleContext muleContext,
MuleMessage message) |
MessageVariableResolverFactory(org.mule.mvel2.ParserConfiguration parserConfiguration,
MuleContext muleContext,
MuleMessage message,
org.mule.mvel2.integration.VariableResolverFactory next)
Convenience constructor to allow for more concise creation of VariableResolverFactory chains without
and performance overhead incurred by using a builder.
|
VariableVariableResolverFactory(org.mule.mvel2.ParserConfiguration parserConfiguration,
MuleContext muleContext,
MuleMessage message)
Deprecated.
|
Modifier and Type | Method and Description |
---|---|
protected abstract boolean |
AbstractEnricherDataTypePropagator.doPropagate(MuleMessage message,
TypedValue typedValue,
org.mule.mvel2.ast.ASTNode node) |
protected boolean |
PropertyEnricherDataTypePropagator.doPropagate(MuleMessage message,
TypedValue typedValue,
org.mule.mvel2.ast.ASTNode node) |
protected boolean |
AbstractVariableEnricherDataTypePropagator.doPropagate(MuleMessage message,
TypedValue typedValue,
org.mule.mvel2.ast.ASTNode node) |
protected boolean |
PayloadEnricherDataTypePropagator.doPropagate(MuleMessage message,
TypedValue typedValue,
org.mule.mvel2.ast.ASTNode node) |
protected DataType |
AbstractVariableExpressionDataTypeResolver.getDataType(MuleMessage message,
org.mule.mvel2.ast.ASTNode node) |
protected DataType |
PropertyExpressionDataTypeResolver.getDataType(MuleMessage message,
org.mule.mvel2.ast.ASTNode node) |
protected DataType |
PayloadExpressionDataTypeResolver.getDataType(MuleMessage message,
org.mule.mvel2.ast.ASTNode node) |
protected abstract DataType |
AbstractExpressionDataTypeResolver.getDataType(MuleMessage message,
org.mule.mvel2.ast.ASTNode node) |
boolean |
AbstractEnricherDataTypePropagator.propagate(MuleMessage message,
TypedValue typedValue,
org.mule.mvel2.compiler.CompiledExpression compiledExpression) |
boolean |
EnricherDataTypePropagator.propagate(MuleMessage message,
TypedValue typedValue,
org.mule.mvel2.compiler.CompiledExpression compiledExpression)
Propagates
DataType on message enrichment |
void |
MvelEnricherDataTypePropagator.propagate(TypedValue typedValue,
MuleMessage message,
Serializable serializedExpression) |
DataType |
ExpressionDataTypeResolver.resolve(MuleMessage message,
org.mule.mvel2.compiler.CompiledExpression compiledExpression)
Resolves the data type form a given expression
|
DataType |
AbstractExpressionDataTypeResolver.resolve(MuleMessage message,
org.mule.mvel2.compiler.CompiledExpression compiledExpression) |
DataType |
MvelDataTypeResolver.resolve(Object value,
MuleMessage message,
Serializable serializedExpression)
Resolves expression data type
|
Modifier and Type | Method and Description |
---|---|
MuleMessage |
DynamicURIInboundEndpoint.request(long timeout) |
MuleMessage |
DefaultInboundEndpoint.request(long timeout) |
Modifier and Type | Method and Description |
---|---|
protected void |
InboundExceptionDetailsMessageProcessor.setExceptionDetails(MuleMessage message,
Connector connector,
Throwable exception)
This method is used to set any additional and possibly transport specific
information on the return message where it has an exception payload.
|
Modifier and Type | Method and Description |
---|---|
protected boolean |
OutboundEndpointPropertyMessageProcessor.ignoreProperty(MuleMessage message,
String key) |
Modifier and Type | Method and Description |
---|---|
protected void |
MessageEnricher.enrich(MuleMessage currentMessage,
MuleMessage enrichmentMessage,
String sourceExpressionArg,
String targetExpressionArg,
ExpressionManager expressionManager) |
Modifier and Type | Method and Description |
---|---|
protected void |
AbstractExceptionListener.closeStream(MuleMessage message) |
Modifier and Type | Method and Description |
---|---|
protected MuleMessage |
MessageProcessorExpressionEvaluator.evaluateProcessorArgument(MuleMessage message,
String processorArgExpression) |
Modifier and Type | Method and Description |
---|---|
void |
VariableExpressionEnricher.enrich(String expression,
MuleMessage message,
Object object) |
void |
DefaultExpressionManager.enrich(String expression,
MuleMessage message,
Object object) |
void |
MessageHeaderExpressionEnricher.enrich(String expression,
MuleMessage message,
Object object) |
void |
AttachmentExpressionEnricher.enrich(String expression,
MuleMessage message,
Object object) |
void |
DefaultExpressionManager.enrich(String expression,
String enricherName,
MuleMessage message,
Object object) |
void |
DefaultExpressionManager.enrichTyped(String expression,
MuleMessage message,
TypedValue object) |
Object |
MessagePayloadExpressionEvaluator.evaluate(String expression,
MuleMessage message) |
Object |
MuleContextExpressionEvaluator.evaluate(String expression,
MuleMessage message)
Extracts a single property from the message
|
Object |
EndpointInfoExpressionEvaluator.evaluate(String expression,
MuleMessage message) |
Object |
MessageExpressionEvaluator.evaluate(String expression,
MuleMessage message) |
Object |
MuleExpressionEvaluator.evaluate(String expression,
MuleMessage message)
Deprecated.
|
Object |
BaseAttachmentExpressionEvaluator.evaluate(String expression,
MuleMessage message) |
Object |
IllegalExpressionEvaluator.evaluate(String expression,
MuleMessage message) |
Object |
MapPayloadExpressionEvaluator.evaluate(String expression,
MuleMessage message) |
Object |
VariableExpressionEvaluator.evaluate(String expression,
MuleMessage message) |
Object |
DefaultExpressionManager.evaluate(String expression,
MuleMessage message)
Evaluates the given expression.
|
Object |
MessageHeadersListExpressionEvaluator.evaluate(String expression,
MuleMessage message) |
Object |
MessageProcessorExpressionEvaluator.evaluate(String expression,
MuleMessage message) |
Object |
MessageHeadersExpressionEvaluator.evaluate(String expression,
MuleMessage message) |
Object |
RegistryExpressionEvaluator.evaluate(String expression,
MuleMessage message) |
Object |
MessageHeaderExpressionEvaluator.evaluate(String expression,
MuleMessage message) |
Object |
OutboundAttachmentsExpressionEvaluator.evaluate(String expression,
MuleMessage message) |
Object |
MessageAttachmentsListExpressionEvaluator.evaluate(String expression,
MuleMessage message) |
Object |
StringExpressionEvaluator.evaluate(String expression,
MuleMessage message) |
Object |
FunctionExpressionEvaluator.evaluate(String name,
MuleMessage message) |
Object |
OutboundHeadersExpressionEvaluator.evaluate(String expression,
MuleMessage message) |
Object |
MessageAttachmentsExpressionEvaluator.evaluate(String expression,
MuleMessage message) |
Object |
DefaultExpressionManager.evaluate(String expression,
MuleMessage message,
boolean failIfNull) |
Object |
DefaultExpressionManager.evaluate(String expression,
String evaluator,
MuleMessage message,
boolean failIfNull)
Evaluates the given expression.
|
boolean |
DefaultExpressionManager.evaluateBoolean(String expression,
MuleMessage message) |
boolean |
DefaultExpressionManager.evaluateBoolean(String expression,
MuleMessage message,
boolean nullReturnsTrue,
boolean nonBooleanReturnsTrue) |
boolean |
DefaultExpressionManager.evaluateBoolean(String expression,
String evaluator,
MuleMessage message) |
boolean |
DefaultExpressionManager.evaluateBoolean(String expression,
String evaluator,
MuleMessage message,
boolean nullReturnsTrue,
boolean nonBooleanReturnsTrue) |
protected MuleMessage |
MessageProcessorExpressionEvaluator.evaluateProcessorArgument(MuleMessage message,
String processorArgExpression) |
TypedValue |
MessagePayloadExpressionEvaluator.evaluateTyped(String expression,
MuleMessage message) |
TypedValue |
MessageExpressionEvaluator.evaluateTyped(String expression,
MuleMessage message) |
TypedValue |
MuleExpressionEvaluator.evaluateTyped(String expression,
MuleMessage message)
Deprecated.
|
TypedValue |
IllegalExpressionEvaluator.evaluateTyped(String expression,
MuleMessage message) |
TypedValue |
VariableExpressionEvaluator.evaluateTyped(String expression,
MuleMessage message) |
TypedValue |
AbstractExpressionEvaluator.evaluateTyped(String expression,
MuleMessage message) |
TypedValue |
DefaultExpressionManager.evaluateTyped(String expression,
MuleMessage message) |
TypedValue |
MessageHeaderExpressionEvaluator.evaluateTyped(String expression,
MuleMessage message) |
TypedValue |
DefaultExpressionManager.evaluateTyped(String expression,
String evaluator,
MuleMessage message,
boolean failIfNull) |
protected abstract DataHandler |
BaseAttachmentExpressionEvaluator.getAttachment(MuleMessage message,
String attachmentName) |
protected DataHandler |
MessageAttachmentExpressionEvaluator.getAttachment(MuleMessage message,
String attachmentName) |
static Object |
ExpressionUtils.getProperty(String expression,
PropertyScope scope,
MuleMessage msg)
Gets a property or map/list of properties specified by an expression supporting
multiple return types as well as all and optional modifiers.
|
static <T> T |
ExpressionUtils.getProperty(String expression,
PropertyScope scope,
MuleMessage msg,
Class<T> type)
Gets a property or map/list of properties specific by an expression supporting multiple return types as well as all and optional modifiers
|
protected static <T> T |
ExpressionUtils.getPropertyInternal(String expression,
PropertyScope scope,
boolean parseScope,
MuleMessage msg,
Class<T> type)
Obtains a property or map/list of properties from a message using an expression that specifies which property or properties to evaluate.
|
static Object |
ExpressionUtils.getPropertyWithScope(String expression,
MuleMessage msg)
Gets a property or map/list of properties specific by an expression supporting multiple return types as well as all and optional modifiers
Handles scope-aware expressions like "#[header:INBOUND:foo]
|
static <T> T |
ExpressionUtils.getPropertyWithScope(String expression,
MuleMessage msg,
Class<T> type)
Gets a property or map/list of properties specific by an expression supporting multiple return types as well as all and optional modifiers
Handles scope-aware expressions like "#[header:INBOUND:foo]
|
static TypedValue |
ExpressionUtils.getTypedProperty(String expression,
MuleMessage msg) |
static TypedValue |
ExpressionUtils.getTypedProperty(String expression,
MuleMessage msg,
PropertyScope scope) |
String |
DefaultExpressionManager.parse(String expression,
MuleMessage message)
Evaluates expressions in a given string.
|
String |
DefaultExpressionManager.parse(String expression,
MuleMessage message,
boolean failIfNull)
Evaluates expressions in a given string.
|
Constructor and Description |
---|
InboundAttachmentsMap(MuleMessage message) |
OutboundAttachmentsMap(MuleMessage message) |
OutboundHeadersExpressionEvaluator.SendHeadersMap(MuleMessage message) |
Modifier and Type | Method and Description |
---|---|
Object |
ExpressionArgument.evaluate(MuleMessage message)
Evaluates this Expression against the passed in Message.
|
Object |
BeanBuilderTransformer.transformMessage(MuleMessage message,
String outputEncoding) |
Object |
ExpressionTransformer.transformMessage(MuleMessage message,
String outputEncoding) |
Modifier and Type | Method and Description |
---|---|
protected List<MuleMessage> |
FeedSplitter.splitMessage(MuleEvent event) |
Modifier and Type | Method and Description |
---|---|
boolean |
FeedLastUpdatedFilter.accept(MuleMessage message) |
boolean |
EntryLastUpdatedFilter.accept(MuleMessage message) |
boolean |
URIRouteFilter.accept(MuleMessage message) |
Constructor and Description |
---|
MuleRequestContext(org.apache.abdera.protocol.server.Provider context,
MuleEventContext event,
MuleMessage request,
String contextPath,
org.apache.abdera.i18n.iri.IRI baseIri) |
Modifier and Type | Method and Description |
---|---|
Object |
AtomEntryBuilderTransformer.transformMessage(MuleMessage message,
String outputEncoding) |
Modifier and Type | Method and Description |
---|---|
MuleMessage |
Rules.generateMessage(String endpoint,
Object payload,
Map messageProperties,
MessageExchangePattern exchangePattern) |
MuleMessage |
Process.generateMessage(String endpoint,
Object payload,
Map messageProperties,
MessageExchangePattern exchangePattern) |
MuleMessage |
MessageService.generateMessage(String endpoint,
Object payloadObject,
Map messageProperties,
MessageExchangePattern mep) |
Modifier and Type | Method and Description |
---|---|
protected MuleMessage |
RemoteDispatcher.dispatchAction(RemoteDispatcherNotification action,
boolean synchronous,
int timeout)
Deprecated.
|
protected MuleMessage |
RemoteDispatcher.doToRemote(String endpoint,
Object payload,
Map messageProperties,
boolean synchronous,
int timeout)
Deprecated.
|
protected MuleMessage |
RemoteDispatcher.doToRemoteComponent(String component,
Object payload,
Map messageProperties,
boolean synchronous)
Deprecated.
|
MuleMessage |
RemoteDispatcher.receiveRemote(String endpoint,
int timeout)
Deprecated.
|
MuleMessage |
MuleClient.request(String url,
List<?> transformers,
long timeout)
Will receive an event from an endpointUri determined by the URL
|
MuleMessage |
MuleClient.request(String url,
long timeout)
Will receive an event from an endpointUri determined by the URL.
|
MuleMessage |
MuleClient.request(String url,
String transformers,
long timeout)
Will receive an event from an endpointUri determined by the URL
|
MuleMessage |
MuleClient.send(String url,
MuleMessage message)
Sends an event synchronously to a endpointUri via a Mule server and a
resulting message is returned.
|
MuleMessage |
MuleClient.send(String url,
MuleMessage message,
int timeout)
Sends an event synchronously to a endpointUri via a mule server and a
resulting message is returned.
|
MuleMessage |
MuleClient.send(String url,
Object payload,
Map<String,Object> messageProperties)
Sends an event synchronously to a endpointUri via a Mule server and a
resulting message is returned.
|
MuleMessage |
MuleClient.send(String url,
Object payload,
Map<String,Object> messageProperties,
int timeout)
Sends an event synchronously to a endpointUri via a mule server and a
resulting message is returned.
|
MuleMessage |
MuleClient.sendDirect(String componentName,
String transformers,
MuleMessage message)
Deprecated.
|
MuleMessage |
MuleClient.sendDirect(String component,
String transformers,
Object payload,
Map<String,Object> messageProperties)
Deprecated.
|
MuleMessage |
RemoteDispatcher.sendRemote(String endpoint,
Object payload,
Map messageProperties)
Deprecated.
|
MuleMessage |
RemoteDispatcher.sendRemote(String endpoint,
Object payload,
Map messageProperties,
int timeout)
Deprecated.
|
MuleMessage |
RemoteDispatcher.sendToRemoteComponent(String component,
Object payload,
Map messageProperties)
Deprecated.
sends an event synchronously to a components on a remote Mule instance.
|
Modifier and Type | Method and Description |
---|---|
void |
MuleClient.dispatch(String url,
MuleMessage message)
Dispatches an event asynchronously to a endpointUri via a Mule server.
|
void |
MuleClient.dispatchDirect(String componentName,
MuleMessage message)
Deprecated.
|
protected MuleEvent |
MuleClient.getEvent(MuleMessage message,
MessageExchangePattern exchangePattern) |
MuleMessage |
MuleClient.send(String url,
MuleMessage message)
Sends an event synchronously to a endpointUri via a Mule server and a
resulting message is returned.
|
MuleMessage |
MuleClient.send(String url,
MuleMessage message,
int timeout)
Sends an event synchronously to a endpointUri via a mule server and a
resulting message is returned.
|
FutureMessageResult |
MuleClient.sendAsync(String url,
MuleMessage message)
Sends an event request to a URL, making the result of the event trigger
available as a Future result that can be accessed later by client code.
|
FutureMessageResult |
MuleClient.sendAsync(String url,
MuleMessage message,
int timeout)
Sends an event request to a URL, making the result of the event trigger
available as a Future result that can be accessed later by client code.
|
MuleMessage |
MuleClient.sendDirect(String componentName,
String transformers,
MuleMessage message)
Deprecated.
|
FutureMessageResult |
MuleClient.sendDirectAsync(String component,
String transformers,
MuleMessage message)
Deprecated.
|
protected void |
RemoteDispatcher.setCredentials(MuleMessage message)
Deprecated.
|
protected void |
RemoteDispatcher.updateContext(MuleMessage message,
ImmutableEndpoint endpoint,
boolean synchronous)
Deprecated.
|
Modifier and Type | Method and Description |
---|---|
protected Object |
RemoteDispatcherComponent.handleException(MuleMessage result,
Throwable e)
Deprecated.
Wraps an exception into a MuleMessage with an Exception payload and returns
the Xml representation of it
|
Modifier and Type | Method and Description |
---|---|
MuleMessage |
RemoteDispatcherNotification.getMessage()
Deprecated.
|
Constructor and Description |
---|
RemoteDispatcherNotification(MuleMessage message,
int action)
Deprecated.
|
RemoteDispatcherNotification(MuleMessage message,
int action,
String resourceIdentifier)
Deprecated.
|
Modifier and Type | Method and Description |
---|---|
static String |
HttpRequestPropertyManager.getBasePath(MuleMessage message) |
static String |
HttpRequestPropertyManager.getRequestPath(MuleMessage message) |
protected String |
CxfInboundMessageProcessor.getSoapAction(MuleMessage message) |
Modifier and Type | Method and Description |
---|---|
protected MuleMessage |
WebServiceWrapperComponent.doInvoke(MuleEvent event)
Deprecated.
|
Modifier and Type | Method and Description |
---|---|
protected boolean |
AbstractProxyGZIPInterceptor.isEncoded(MuleMessage message) |
Modifier and Type | Method and Description |
---|---|
protected InputStream |
MuleUniversalConduit.getResponseBody(org.apache.cxf.message.Message m,
MuleMessage result) |
Modifier and Type | Method and Description |
---|---|
MuleMessage |
MessageArgumentResolver.resolve(org.mule.extension.runtime.OperationContext operationContext) |
Modifier and Type | Method and Description |
---|---|
protected MultipartHttpEntity |
MuleEventToHttpRequest.createMultiPart(MuleMessage msg) |
Modifier and Type | Method and Description |
---|---|
MuleMessage |
MuleMessageService.generateMessage(String endpoint,
Object payloadObject,
Map messageProperties,
MessageExchangePattern mep) |
Modifier and Type | Method and Description |
---|---|
protected void |
JerseyResourcesComponent.copyProperties(MuleMessage message,
org.glassfish.jersey.server.ContainerRequest request) |
Modifier and Type | Method and Description |
---|---|
Object |
JsonExpressionEvaluator.evaluate(String expression,
MuleMessage message) |
Modifier and Type | Method and Description |
---|---|
boolean |
IsJsonFilter.accept(MuleMessage obj) |
Modifier and Type | Method and Description |
---|---|
boolean |
JsonSchemaJsonValidationFilter.accept(MuleMessage message)
Deprecated.
|
boolean |
JsonSchemaValidationFilter.accept(MuleMessage msg)
Deprecated.
|
boolean |
JsonSchemaXsdValidationFilter.accept(MuleMessage msg)
Deprecated.
|
Object |
JsonToObject.transformMessage(MuleMessage message,
String outputEncoding) |
Object |
ObjectToJson.transformMessage(MuleMessage message,
String outputEncoding) |
Object |
JsonXsltTransformer.transformMessage(MuleMessage message,
String enc)
run a JSON to JSON XSLT transformationn XML string
|
Modifier and Type | Method and Description |
---|---|
Object |
OgnlExpressionEvaluator.evaluate(String expression,
MuleMessage message) |
Modifier and Type | Method and Description |
---|---|
boolean |
OGNLFilter.accept(MuleMessage message) |
Modifier and Type | Method and Description |
---|---|
protected List<MuleMessage> |
FeedSplitter.splitMessage(MuleEvent event) |
Modifier and Type | Method and Description |
---|---|
boolean |
EntryLastUpdatedFilter.accept(MuleMessage message) |
boolean |
FeedLastUpdatedFilter.accept(MuleMessage message) |
protected com.sun.syndication.feed.synd.SyndEntry |
EntryLastUpdatedFilter.transformToSyndEntry(MuleMessage message) |
Modifier and Type | Method and Description |
---|---|
void |
Scriptable.populateBindings(Bindings bindings,
MuleMessage message) |
Modifier and Type | Method and Description |
---|---|
Object |
AbstractScriptExpressionEvaluator.evaluate(String expression,
MuleMessage message)
Extracts a single property from the message
|
Modifier and Type | Method and Description |
---|---|
boolean |
ScriptFilter.accept(MuleMessage message) |
Modifier and Type | Method and Description |
---|---|
Object |
ScriptTransformer.transformMessage(MuleMessage message,
String outputEncoding) |
Modifier and Type | Method and Description |
---|---|
static MuleMessage |
SxcFilteringOutboundRouter.getCurrentMessage() |
Modifier and Type | Method and Description |
---|---|
boolean |
SxcFilter.accept(MuleMessage msg) |
protected ReversibleXMLStreamReader |
SxcFilteringOutboundRouter.getXMLStreamReader(MuleMessage message)
Gets an XMLStreamReader for this message.
|
boolean |
SxcFilteringOutboundRouter.isMatch(MuleMessage message) |
boolean |
SxcFilteringOutboundRouter.testMatch(MuleMessage message) |
Modifier and Type | Method and Description |
---|---|
Object |
AbstractXPathExpressionEvaluator.evaluate(String expression,
MuleMessage message)
Deprecated.
Extracts a single property from the message
|
Object |
JXPathExpressionEvaluator.evaluate(String expression,
MuleMessage message)
Deprecated.
|
Object |
JaxpXPathExpressionEvaluator.evaluate(String expression,
MuleMessage message)
Deprecated.
Extracts a single property from the message
|
protected Object |
AbstractXPathExpressionEvaluator.getPayloadForXPath(MuleMessage message)
Deprecated.
|
protected Object |
BeanPayloadExpressionEvaluator.getPayloadForXPath(MuleMessage message)
Deprecated.
|
Modifier and Type | Method and Description |
---|---|
boolean |
IsXmlFilter.accept(MuleMessage obj) |
boolean |
JXPathFilter.accept(MuleMessage obj)
Deprecated.
|
boolean |
XPathFilter.accept(MuleMessage message) |
boolean |
JaxenFilter.accept(MuleMessage obj)
Deprecated.
|
boolean |
SchemaValidationFilter.accept(MuleMessage message)
Accepts the message if schema validation passes.
|
protected Source |
SchemaValidationFilter.loadSource(MuleMessage msg)
Load the source from the specified object.
|
Modifier and Type | Method and Description |
---|---|
protected void |
XQueryTransformer.bindParameters(javax.xml.xquery.XQPreparedExpression transformer,
MuleMessage message) |
protected void |
XsltTransformer.doTransform(MuleMessage message,
String outputEncoding,
Source sourceDoc,
Result result) |
protected Object |
XQueryTransformer.evaluateTransformParameter(String name,
Object value,
MuleMessage message)
Returns the value to be set for the parameter.
|
protected Object |
XsltTransformer.evaluateTransformParameter(String key,
Object value,
MuleMessage message)
Returns the value to be set for the parameter.
|
protected Object |
XsltTransformer.getDelayedResult(MuleMessage message,
String outputEncoding,
Source sourceDoc) |
Object |
XmlToOutputHandler.transformMessage(MuleMessage message,
String encoding) |
Object |
XmlToObject.transformMessage(MuleMessage message,
String outputEncoding) |
Object |
XmlToDomDocument.transformMessage(MuleMessage message,
String encoding) |
Object |
DomDocumentToXml.transformMessage(MuleMessage message,
String encoding) |
Object |
XmlToXMLStreamReader.transformMessage(MuleMessage message,
String encoding) |
Object |
ObjectToXml.transformMessage(MuleMessage message,
String outputEncoding) |
Object |
XQueryTransformer.transformMessage(MuleMessage message,
String outputEncoding) |
Object |
XsltTransformer.transformMessage(MuleMessage message,
String putputEncoding)
Transform, using XSLT, a XML String to another String.
|
Modifier and Type | Method and Description |
---|---|
protected Object |
InvokerMessageProcessor.evaluateExpressionCandidate(Object expressionCandidate,
MuleMessage message) |
Modifier and Type | Method and Description |
---|---|
MuleMessage |
DefaultRetryContext.getFirstReturnMessage() |
MuleMessage[] |
DefaultRetryContext.getReturnMessages() |
Modifier and Type | Method and Description |
---|---|
void |
DefaultRetryContext.addReturnMessage(MuleMessage result) |
void |
DefaultRetryContext.setReturnMessages(MuleMessage[] returnMessages) |
Modifier and Type | Method and Description |
---|---|
MuleMessage |
FutureRetryContext.getFirstReturnMessage() |
MuleMessage[] |
FutureRetryContext.getReturnMessages() |
Modifier and Type | Method and Description |
---|---|
void |
FutureRetryContext.addReturnMessage(MuleMessage result) |
void |
FutureRetryContext.setReturnMessages(MuleMessage[] returnMessages) |
Modifier and Type | Method and Description |
---|---|
static MuleMessage |
AbstractRoutingStrategy.cloneMessage(MuleEvent event,
MuleMessage message,
MuleContext muleContext) |
static MuleMessage |
AbstractRoutingStrategy.cloneMessage(MuleMessage message,
MuleContext muleContext)
Create a fresh copy of a message.
|
Modifier and Type | Method and Description |
---|---|
protected List<MuleMessage> |
MessageChunkSplitter.splitMessage(MuleEvent event) |
protected abstract List<MuleMessage> |
AbstractSplitter.splitMessage(MuleEvent event) |
protected List<MuleMessage> |
ExpressionSplitter.splitMessage(MuleEvent event) |
protected List<MuleMessage> |
MapSplitter.splitMessage(MuleEvent event) |
Modifier and Type | Method and Description |
---|---|
protected static void |
AbstractRoutingStrategy.assertNonConsumableMessage(MuleEvent event,
MuleMessage message)
Asserts that the
MuleMessage in the MuleEvent doesn't carry a consumable payload. |
static MuleMessage |
AbstractRoutingStrategy.cloneMessage(MuleEvent event,
MuleMessage message,
MuleContext muleContext) |
static MuleMessage |
AbstractRoutingStrategy.cloneMessage(MuleMessage message,
MuleContext muleContext)
Create a fresh copy of a message.
|
int |
EventGroup.ArrivalOrderMessageComparator.compare(MuleMessage message1,
MuleMessage message2) |
protected MuleEvent |
AbstractRoutingStrategy.createEventToRoute(MuleEvent routedEvent,
MuleMessage message,
MessageProcessor route)
Create a new event to be routed to the target MP
|
String |
MuleMessageInfoMapping.getCorrelationId(MuleMessage message) |
String |
ExpressionMessageInfoMapping.getCorrelationId(MuleMessage message) |
String |
MuleMessageInfoMapping.getMessageId(MuleMessage message) |
String |
ExpressionMessageInfoMapping.getMessageId(MuleMessage message) |
boolean |
FirstSuccessful.isMatch(MuleMessage message) |
boolean |
RoundRobin.isMatch(MuleMessage message) |
boolean |
UntilSuccessful.isMatch(MuleMessage message) |
static void |
AbstractRoutingStrategy.propagateMagicProperties(MuleMessage in,
MuleMessage out)
Propagates a number of internal system properties to handle correlation, session, etc.
|
protected MuleEvent |
AbstractRoutingStrategy.sendRequest(MuleEvent routedEvent,
MuleMessage message,
MessageProcessor route,
boolean awaitResponse)
Send message event to destination.
|
static void |
AbstractRoutingStrategy.validateMessageIsNotConsumable(MuleEvent event,
MuleMessage message)
Validates that the payload is not consumable so it can be copied.
|
Modifier and Type | Method and Description |
---|---|
Object |
CorrelationPropertiesExpressionEvaluator.evaluate(String name,
MuleMessage message) |
String |
CorrelationPropertiesExpressionEvaluator.getCorrelationId(MuleMessage message) |
String |
CorrelationPropertiesExpressionEvaluator.getMessageId(MuleMessage message) |
Modifier and Type | Method and Description |
---|---|
boolean |
AcceptAllFilter.accept(MuleMessage message) |
boolean |
ExceptionTypeFilter.accept(MuleMessage message)
Check a given message against this filter.
|
boolean |
WildcardFilter.accept(MuleMessage message) |
boolean |
ExpressionFilter.accept(MuleMessage message)
Check a given message against this filter.
|
boolean |
PayloadTypeFilter.accept(MuleMessage message) |
boolean |
RegExFilter.accept(MuleMessage message) |
boolean |
ConsumableMuleMessageFilter.accept(MuleMessage message) |
boolean |
EqualsFilter.accept(MuleMessage message) |
boolean |
MessagePropertyFilter.accept(MuleMessage message) |
Modifier and Type | Method and Description |
---|---|
boolean |
AndFilter.accept(MuleMessage message) |
boolean |
OrFilter.accept(MuleMessage message) |
boolean |
NotFilter.accept(MuleMessage message) |
Modifier and Type | Method and Description |
---|---|
protected MuleMessage |
AbstractOutboundRouter.cloneMessage(MuleEvent event,
MuleMessage message)
Creates a fresh copy of a
MuleMessage ensuring that the payload can be cloned (i.e. |
protected MuleMessage |
AbstractOutboundRouter.cloneMessage(MuleMessage message)
Create a fresh copy of a message.
|
Modifier and Type | Method and Description |
---|---|
protected MuleMessage |
AbstractOutboundRouter.cloneMessage(MuleEvent event,
MuleMessage message)
Creates a fresh copy of a
MuleMessage ensuring that the payload can be cloned (i.e. |
protected MuleMessage |
AbstractOutboundRouter.cloneMessage(MuleMessage message)
Create a fresh copy of a message.
|
protected MuleEvent |
AbstractOutboundRouter.createEventToRoute(MuleEvent routedEvent,
MuleMessage message,
MessageProcessor route)
Create a new event to be routed to the target MP
|
protected boolean |
ExceptionBasedRouter.exceptionPayloadAvailable(MuleMessage message)
Deprecated.
|
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.
|
protected OutboundEndpoint |
AbstractRecipientList.getRecipientEndpoint(MuleMessage message,
Object recipient) |
protected OutboundEndpoint |
AbstractRecipientList.getRecipientEndpointFromString(MuleMessage message,
String recipient) |
boolean |
TransformerRouter.isMatch(MuleMessage message)
Deprecated.
|
boolean |
FilteringOutboundRouter.isMatch(MuleMessage message) |
protected void |
ChainingRouter.processIntermediaryResult(MuleMessage localResult,
MuleMessage intermediaryResult)
Deprecated.
Process intermediary result of invocation.
|
protected void |
AbstractOutboundRouter.propagateMagicProperties(MuleMessage in,
MuleMessage out)
Propagates a number of internal system properties to handle correlation, session, etc.
|
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) |
protected List<Object> |
ExpressionMessageSplitter.splitMessage(MuleMessage message)
Deprecated.
|
protected List |
ListMessageSplitter.splitMessage(MuleMessage message)
Deprecated.
|
protected List |
AbstractRoundRobinMessageSplitter.splitMessage(MuleMessage message)
Method used just to split the message into parts.
|
Modifier and Type | Method and Description |
---|---|
protected void |
AbstractSecurityFilter.updatePayload(MuleMessage message,
Object payload,
MuleEvent event) |
Modifier and Type | Method and Description |
---|---|
P |
OAuthProcessTemplate.execute(ProcessCallback<P,Capabilities> processCallback,
Filter filter,
MuleMessage message) |
P |
ManagedAccessTokenProcessTemplate.execute(ProcessCallback<P,OAuth2Adapter> processCallback,
Filter filter,
MuleMessage message) |
T |
ProcessCallbackProcessInterceptor.execute(ProcessCallback<T,O> processCallback,
O object,
Filter filter,
MuleMessage message) |
T |
RetryProcessInterceptor.execute(ProcessCallback<T,O> processCallback,
O object,
Filter filter,
MuleMessage message) |
T |
ManagedAccessTokenProcessInterceptor.execute(ProcessCallback<T,OAuth2Adapter> processCallback,
OAuth2Adapter object,
Filter filter,
MuleMessage message) |
T |
RefreshTokenProcessInterceptor.execute(ProcessCallback<T,OAuth2Adapter> processCallback,
OAuth2Adapter object,
Filter filter,
MuleMessage event) |
Modifier and Type | Method and Description |
---|---|
protected <T> T |
AbstractSessionHandler.deserialize(MuleMessage message,
byte[] bytes) |
MuleSession |
LegacySessionHandler.retrieveSessionInfoFromMessage(MuleMessage message)
Deprecated.
|
MuleSession |
NullSessionHandler.retrieveSessionInfoFromMessage(MuleMessage message) |
MuleSession |
SerializeAndEncodeSessionHandler.retrieveSessionInfoFromMessage(MuleMessage message) |
MuleSession |
SerializeOnlySessionHandler.retrieveSessionInfoFromMessage(MuleMessage message) |
MuleSession |
SimpleSessionHandler.retrieveSessionInfoFromMessage(MuleMessage message) |
void |
LegacySessionHandler.retrieveSessionInfoFromMessage(MuleMessage message,
MuleSession session)
Deprecated.
Use retrieveSessionInfoFromMessage(MuleMessage message) instead
|
void |
NullSessionHandler.retrieveSessionInfoFromMessage(MuleMessage message,
MuleSession session)
Deprecated.
Use retrieveSessionInfoFromMessage(MuleMessage message) instead
|
void |
SerializeOnlySessionHandler.retrieveSessionInfoFromMessage(MuleMessage message,
MuleSession session)
Deprecated.
Use retrieveSessionInfoFromMessage(MuleMessage message) instead
|
void |
SimpleSessionHandler.retrieveSessionInfoFromMessage(MuleMessage message,
MuleSession session)
Deprecated.
Use retrieveSessionInfoFromMessage(MuleMessage message) instead
|
protected byte[] |
AbstractSessionHandler.serialize(MuleMessage message,
Object object) |
void |
LegacySessionHandler.storeSessionInfoToMessage(MuleSession session,
MuleMessage message)
Deprecated.
|
void |
NullSessionHandler.storeSessionInfoToMessage(MuleSession session,
MuleMessage message) |
void |
SerializeAndEncodeSessionHandler.storeSessionInfoToMessage(MuleSession session,
MuleMessage message) |
void |
SerializeOnlySessionHandler.storeSessionInfoToMessage(MuleSession session,
MuleMessage message) |
void |
SimpleSessionHandler.storeSessionInfoToMessage(MuleSession session,
MuleMessage message) |
Modifier and Type | Method and Description |
---|---|
protected String |
FunctionalTestComponent.append(String contents,
MuleMessage message)
Will append the value of
FunctionalTestComponent.getAppendString() to the contents of the message. |
Modifier and Type | Method and Description |
---|---|
MuleMessage |
InboundEndpointWrapper.request(long timeout) |
Modifier and Type | Field and Description |
---|---|
static DataType<MuleMessage> |
AbstractTransformer.MULE_MESSAGE_DATA_TYPE |
Modifier and Type | Method and Description |
---|---|
Object |
TransformerTemplate.TransformerCallback.doTransform(MuleMessage message) |
Object |
TransformerTemplate.OverwitePayloadCallback.doTransform(MuleMessage message) |
abstract Object |
AbstractMessageAwareTransformer.transform(MuleMessage message,
String outputEncoding)
Deprecated.
Subclasses implement this method.
|
Object |
AbstractMessageAwareTransformer.transformMessage(MuleMessage message,
String outputEncoding)
Deprecated.
Transform the message.
|
abstract Object |
AbstractMessageTransformer.transformMessage(MuleMessage message,
String outputEncoding)
Transform the message
|
Object |
TransformerTemplate.transformMessage(MuleMessage message,
String outputEncoding) |
Object |
TransformerChain.transformMessage(MuleMessage message,
String outputEncoding) |
Modifier and Type | Method and Description |
---|---|
boolean |
AbstractTransformer.isSourceTypeSupported(Class<MuleMessage> aClass,
boolean exactMatch)
|
Modifier and Type | Method and Description |
---|---|
protected void |
MessagePropertiesTransformer.addProperties(MuleMessage message) |
protected void |
MessagePropertiesTransformer.deleteProperties(MuleMessage message) |
protected void |
MessagePropertiesTransformer.renameInScope(String oldKey,
String newKey,
PropertyScope propertyScope,
MuleMessage message) |
protected void |
MessagePropertiesTransformer.renameProperties(MuleMessage message) |
Object |
CopyPropertiesTransformer.transformMessage(MuleMessage message,
String outputEncoding) |
Object |
AutoTransformer.transformMessage(MuleMessage message,
String outputEncoding) |
Object |
RemoveAttachmentTransformer.transformMessage(MuleMessage message,
String outputEncoding) |
Object |
MuleMessageToByteArray.transformMessage(MuleMessage message,
String outputEncoding) |
Object |
AbstractRemoveVariablePropertyTransformer.transformMessage(MuleMessage message,
String outputEncoding) |
Object |
AbstractAddVariablePropertyTransformer.transformMessage(MuleMessage message,
String outputEncoding) |
Object |
ParseTemplateTransformer.transformMessage(MuleMessage message,
String outputEncoding) |
Object |
MessagePropertiesTransformer.transformMessage(MuleMessage message,
String outputEncoding) |
Object |
CopyAttachmentsTransformer.transformMessage(MuleMessage message,
String outputEncoding) |
Object |
AddAttachmentTransformer.transformMessage(MuleMessage message,
String outputEncoding) |
Object |
SetPayloadTransformer.transformMessage(MuleMessage message,
String outputEncoding) |
Modifier and Type | Method and Description |
---|---|
MuleMessage |
AbstractMuleMessageFactory.create(Object transportMessage,
MuleMessage previousMessage,
String encoding)
|
MuleMessage |
AbstractMuleMessageFactory.create(Object transportMessage,
MuleMessage previousMessage,
String encoding,
MuleContext muleContext) |
MuleMessage |
AbstractMuleMessageFactory.create(Object transportMessage,
String encoding)
Deprecated.
|
MuleMessage |
AbstractMuleMessageFactory.create(Object transportMessage,
String encoding,
MuleContext muleContext) |
protected MuleMessage |
AbstractTransportMessageProcessTemplate.createMessageFromSource(Object message) |
MuleMessage |
AbstractTransportMessageHandler.createMuleMessage(Object transportMessage)
Uses this object's
MuleMessageFactory to create a new MuleMessage instance. |
MuleMessage |
AbstractTransportMessageHandler.createMuleMessage(Object transportMessage,
MuleMessage previousMessage,
String encoding)
Uses this object's
MuleMessageFactory to create a new MuleMessage instance. |
MuleMessage |
AbstractTransportMessageHandler.createMuleMessage(Object transportMessage,
String encoding)
Uses this object's
MuleMessageFactory to create a new MuleMessage instance. |
protected MuleMessage |
AbstractTransportMessageHandler.createNullMuleMessage()
Uses this object's
MuleMessageFactory to create a new MuleMessage instance. |
protected abstract MuleMessage |
AbstractMessageRequester.doRequest(long timeout)
Make a specific request to the underlying transport
|
protected MuleMessage |
UnsupportedMessageRequester.doRequest(long timeout) |
protected MuleMessage |
UnsupportedMessageDispatcher.doSend(MuleEvent event) |
protected abstract MuleMessage |
AbstractMessageDispatcher.doSend(MuleEvent event) |
protected MuleMessage |
AbstractMessageReceiver.handleUnacceptedFilter(MuleMessage message) |
protected MuleMessage |
AbstractReceiverWorker.postProcessMessage(MuleMessage message)
If a result is returned back this method will get called before the message is added to te list of
results (these are later passed to
AbstractReceiverWorker.handleResults(java.util.List) ) |
MuleMessage |
AbstractConnector.request(InboundEndpoint endpoint,
long timeout) |
MuleMessage |
AbstractMessageRequester.request(long timeout)
Make a specific request to the underlying transport
|
MuleMessage |
AbstractConnector.request(String uri,
long timeout)
Make a specific request to the underlying transport
|
Modifier and Type | Method and Description |
---|---|
protected abstract List<MuleMessage> |
TransactedPollingMessageReceiver.getMessages() |
Modifier and Type | Method and Description |
---|---|
protected void |
AbstractMessageRequester.applyInboundTransformers(MuleMessage message) |
MuleMessage |
AbstractMuleMessageFactory.create(Object transportMessage,
MuleMessage previousMessage,
String encoding)
|
MuleMessage |
AbstractMuleMessageFactory.create(Object transportMessage,
MuleMessage previousMessage,
String encoding,
MuleContext muleContext) |
protected MuleEvent |
AbstractTransportMessageProcessTemplate.createEventFromMuleMessage(MuleMessage muleMessage) |
protected MuleEvent |
AbstractMessageReceiver.createMuleEvent(MuleMessage message,
OutputStream outputStream) |
MuleMessage |
AbstractTransportMessageHandler.createMuleMessage(Object transportMessage,
MuleMessage previousMessage,
String encoding)
Uses this object's
MuleMessageFactory to create a new MuleMessage instance. |
protected MuleMessage |
AbstractMessageReceiver.handleUnacceptedFilter(MuleMessage message) |
protected MuleMessage |
AbstractReceiverWorker.postProcessMessage(MuleMessage message)
If a result is returned back this method will get called before the message is added to te list of
results (these are later passed to
AbstractReceiverWorker.handleResults(java.util.List) ) |
protected void |
AbstractReceiverWorker.preRouteMuleMessage(MuleMessage message)
This callback is called before a message is routed into Mule and can be used by the worker to set connection
specific properties to message before it gets routed
|
void |
DefaultReplyToHandler.processReplyTo(MuleEvent event,
MuleMessage returnMessage,
Object replyTo) |
protected void |
AbstractMessageReceiver.propagateRootMessageIdProperty(MuleMessage message) |
protected void |
AbstractTransportMessageProcessTemplate.propagateRootMessageIdProperty(MuleMessage message) |
MuleEvent |
AbstractMessageReceiver.routeMessage(MuleMessage message) |
MuleEvent |
AbstractMessageReceiver.routeMessage(MuleMessage message,
MuleSession session,
OutputStream outputStream) |
MuleEvent |
AbstractMessageReceiver.routeMessage(MuleMessage message,
MuleSession session,
Transaction trans,
OutputStream outputStream) |
MuleEvent |
AbstractMessageReceiver.routeMessage(MuleMessage message,
Transaction trans) |
MuleEvent |
AbstractMessageReceiver.routeMessage(MuleMessage message,
Transaction trans,
OutputStream outputStream) |
protected void |
AbstractConnector.setupDispatchReturn(OutboundEndpoint endpoint,
MessageDispatcher dispatcher,
MuleMessage result)
This method will return the dispatcher to the pool or, if the payload is an
inputstream, replace the payload with a new DelegatingInputStream which
returns the dispatcher to the pool when the stream is closed.
|
protected void |
AbstractConnector.setupRequestReturn(InboundEndpoint endpoint,
MessageRequester requester,
MuleMessage result)
This method will return the requester to the pool or, if the payload is an
inputstream, replace the payload with a new DelegatingInputStream which
returns the requester to the pool when the stream is closed.
|
protected void |
AbstractMessageReceiver.warnIfMuleClientSendUsed(MuleMessage message) |
protected void |
AbstractTransportMessageProcessTemplate.warnIfMuleClientSendUsed(MuleMessage message) |
Modifier and Type | Method and Description |
---|---|
protected MuleMessage |
AjaxMessageDispatcher.doSend(MuleEvent event) |
Modifier and Type | Method and Description |
---|---|
void |
AjaxReplyToHandler.processReplyTo(MuleEvent event,
MuleMessage returnMessage,
Object replyTo) |
Modifier and Type | Method and Description |
---|---|
protected MuleMessage |
RetrieveMessageRequester.doRequest(long timeout)
Make a specific request to the underlying transport.
|
protected MuleMessage |
RetrieveMessageRequester.doSend(MuleEvent event) |
protected MuleMessage |
SmtpMessageDispatcher.doSend(MuleEvent event) |
protected MuleMessage |
RetrieveMessageReceiver.handleUnacceptedFilter(MuleMessage message) |
Modifier and Type | Method and Description |
---|---|
protected void |
MailMuleMessageFactory.addAttachmentHeaders(String name,
Part part,
MuleMessage muleMessage) |
protected void |
MailMuleMessageFactory.addRecipientProperty(MuleMessage muleMessage,
Message mailMessage,
Message.RecipientType recipientType,
String property) |
protected MuleMessage |
RetrieveMessageReceiver.handleUnacceptedFilter(MuleMessage message) |
Modifier and Type | Method and Description |
---|---|
boolean |
AbstractMailFilter.accept(MuleMessage message) |
Modifier and Type | Method and Description |
---|---|
protected void |
ObjectToMimeMessage.addBodyPartHeaders(BodyPart part,
String name,
MuleMessage message) |
String |
StringToEmailMessage.evaluate(String value,
MuleMessage message) |
protected String |
StringToEmailMessage.lookupProperty(MuleMessage message,
String propName,
String defaultValue)
Searches in outbound, then invocation scope.
|
protected void |
StringToEmailMessage.setContent(Object payload,
Message msg,
String contentType,
MuleMessage message) |
protected void |
ObjectToMimeMessage.setContent(Object payload,
Message msg,
String contentType,
MuleMessage message) |
Object |
StringToEmailMessage.transformMessage(MuleMessage message,
String outputEncoding) |
Object |
ObjectToMimeMessage.transformMessage(MuleMessage message,
String outputEncoding) |
Modifier and Type | Method and Description |
---|---|
protected MuleMessage |
FileMessageRequester.doRequest(long timeout)
Will attempt to do a receive from a directory, if the endpointUri resolves to
a file name the file will be returned, otherwise the first file in the
directory according to the filename filter configured on the connector.
|
protected MuleMessage |
FileMessageDispatcher.doSend(MuleEvent event) |
Modifier and Type | Method and Description |
---|---|
String |
FilenameParser.getFilename(MuleMessage message,
String pattern) |
String |
ExpressionFilenameParser.getFilename(MuleMessage message,
String expression) |
protected String |
ExpressionFilenameParser.getFilename(MuleMessage message,
String expression,
TemplateParser parser) |
protected void |
FileMuleMessageFactory.setPropertiesFromFile(MuleMessage message,
File file) |
Modifier and Type | Method and Description |
---|---|
boolean |
FilenameWildcardFilter.accept(MuleMessage message) |
Modifier and Type | Method and Description |
---|---|
protected MuleMessage |
FtpMessageRequester.doRequest(long timeout)
Make a specific request to the underlying transport
|
protected MuleMessage |
FtpMessageDispatcher.doSend(MuleEvent event) |
Modifier and Type | Method and Description |
---|---|
protected void |
FtpMessageReceiver.postProcess(org.apache.commons.net.ftp.FTPClient client,
org.apache.commons.net.ftp.FTPFile file,
MuleMessage message) |
protected void |
FtpMessageRequester.postProcess(org.apache.commons.net.ftp.FTPClient client,
org.apache.commons.net.ftp.FTPFile file,
MuleMessage message) |
Modifier and Type | Method and Description |
---|---|
protected MuleMessage |
HttpMessageProcessTemplate.createMessageFromSource(Object message) |
protected MuleMessage |
HttpClientMessageRequester.doRequest(long timeout)
Make a specific request to the underlying transport
|
protected MuleMessage |
HttpClientMessageDispatcher.doSend(MuleEvent event) |
protected MuleMessage |
HttpClientMessageDispatcher.getResponseFromMethod(HttpMethod httpMethod,
ExceptionPayload ep) |
protected MuleMessage |
HttpClientMessageDispatcher.handleRedirect(HttpMethod method,
MuleEvent event) |
protected MuleMessage |
OldHttpMessageReceiver.handleUnacceptedFilter(MuleMessage message) |
protected MuleMessage |
HttpMessageReceiver.handleUnacceptedFilter(MuleMessage message) |
Modifier and Type | Method and Description |
---|---|
protected MessageReceiver |
OldHttpMessageReceiver.getTargetReceiver(MuleMessage message,
ImmutableEndpoint ep) |
protected MuleMessage |
OldHttpMessageReceiver.handleUnacceptedFilter(MuleMessage message) |
protected MuleMessage |
HttpMessageReceiver.handleUnacceptedFilter(MuleMessage message) |
void |
CookieWrapper.parse(MuleMessage message,
ExpressionManager expressionManager) |
void |
CacheControlHeader.parse(MuleMessage message,
ExpressionManager expressionManager)
Evaluates all the properties in case there are expressions
|
protected void |
OldHttpMessageReceiver.HttpWorker.preRouteMessage(MuleMessage message) |
protected void |
HttpMessageProcessTemplate.processRemoteAddresses(MuleMessage muleMessage)
For a given MuleMessage will set the
MULE_REMOTE_CLIENT_ADDRESS property taking into consideration
if the header X-Forwarded-For is present in the request or not. |
void |
HttpResponse.setBody(MuleMessage msg) |
protected void |
HttpClientMessageDispatcher.setPropertyFromEndpoint(MuleEvent event,
MuleMessage msg,
String prop) |
Modifier and Type | Method and Description |
---|---|
protected void |
HttpResponseBuilder.checkVersion(MuleMessage message) |
protected void |
HttpResponseBuilder.copyOutboundProperties(HttpResponse response,
MuleMessage message) |
protected void |
RestServiceWrapper.handleException(RestServiceException e,
MuleMessage result) |
protected boolean |
RestServiceWrapper.isErrorPayload(MuleMessage message) |
protected void |
HttpResponseBuilder.setBody(HttpResponse response,
MuleMessage message,
MuleEvent event) |
protected void |
HttpResponseBuilder.setCacheControl(HttpResponse response,
MuleMessage message) |
protected void |
HttpResponseBuilder.setContentType(HttpResponse response,
MuleMessage message) |
protected void |
HttpResponseBuilder.setCookies(HttpResponse response,
MuleMessage message) |
protected void |
HttpResponseBuilder.setHeaders(HttpResponse response,
MuleMessage message) |
Modifier and Type | Method and Description |
---|---|
Object |
CopyInboundToOutboundPropertiesTransformerCallback.doTransform(MuleMessage message) |
Modifier and Type | Method and Description |
---|---|
boolean |
HttpRequestWildcardFilter.accept(MuleMessage message) |
Modifier and Type | Method and Description |
---|---|
Object |
ServletTransformer.transformMessage(MuleMessage message,
String outputEncoding) |
Modifier and Type | Method and Description |
---|---|
protected HttpMethod |
ObjectToHttpClientMethodRequest.createDeleteMethod(MuleMessage message) |
protected HttpMethod |
ObjectToHttpClientMethodRequest.createGetMethod(MuleMessage msg,
String outputEncoding) |
protected HttpMethod |
ObjectToHttpClientMethodRequest.createHeadMethod(MuleMessage message) |
protected MultipartRequestEntity |
ObjectToHttpClientMethodRequest.createMultiPart(MuleMessage msg,
EntityEnclosingMethod method) |
protected HttpMethod |
ObjectToHttpClientMethodRequest.createOptionsMethod(MuleMessage message) |
protected HttpMethod |
ObjectToHttpClientMethodRequest.createPatchMethod(MuleMessage message,
String outputEncoding) |
protected HttpMethod |
ObjectToHttpClientMethodRequest.createPostMethod(MuleMessage msg,
String outputEncoding) |
protected HttpMethod |
ObjectToHttpClientMethodRequest.createPutMethod(MuleMessage msg,
String outputEncoding) |
protected HttpResponse |
MuleMessageToHttpResponse.createResponse(Object src,
String encoding,
MuleMessage msg) |
protected HttpMethod |
ObjectToHttpClientMethodRequest.createTraceMethod(MuleMessage message) |
protected String |
ObjectToHttpClientMethodRequest.detectHttpMethod(MuleMessage msg) |
protected String |
ObjectToHttpClientMethodRequest.getBodyParameterName(MuleMessage message) |
protected URI |
ObjectToHttpClientMethodRequest.getURI(MuleMessage message) |
protected void |
ObjectToHttpClientMethodRequest.setHeaders(HttpMethod httpMethod,
MuleMessage msg) |
protected void |
ObjectToHttpClientMethodRequest.setupEntityMethod(Object src,
String encoding,
MuleMessage msg,
EntityEnclosingMethod postMethod) |
Object |
FormTransformer.transformMessage(MuleMessage message,
String outputEncoding) |
Object |
HttpRequestBodyToParamMap.transformMessage(MuleMessage message,
String outputEncoding) |
Object |
ObjectToHttpClientMethodRequest.transformMessage(MuleMessage msg,
String outputEncoding) |
Object |
MuleMessageToHttpResponse.transformMessage(MuleMessage msg,
String outputEncoding) |
Modifier and Type | Method and Description |
---|---|
protected MuleMessage |
JdbcMessageRequester.doRequest(long timeout)
Make a specific request to the underlying transport
|
protected MuleMessage |
JdbcMessageRequester.doRequest(long timeout,
MuleEvent event)
Make a specific request to the underlying transport
Special case: The event is need when doReceive was called from doSend
|
protected MuleMessage |
JdbcMessageDispatcher.doSend(MuleEvent event) |
Modifier and Type | Method and Description |
---|---|
protected List<MuleMessage> |
JdbcMessageReceiver.createMuleMessages(List<Object> records)
Creates a mule message per each data record.
|
Modifier and Type | Method and Description |
---|---|
protected int |
JdbcMessageReceiver.executeAckStatement(Connection con,
MuleMessage muleMessage)
Executes the acknowledge SQL statement for a given message.
|
Object[] |
JdbcConnector.getParams(ImmutableEndpoint endpoint,
List paramNames,
MuleMessage message,
String query) |
protected Object |
JdbcConnector.getParamValue(ImmutableEndpoint endpoint,
MuleMessage message,
String param) |
Modifier and Type | Method and Description |
---|---|
protected int[] |
JdbcMessageReceiver.executeBatchAckStatement(Connection con,
List<MuleMessage> messages)
Executes the acknowledge SQL statement for a list of messages.
|
Modifier and Type | Method and Description |
---|---|
MuleMessage |
SqlStatementStrategyExecutor.execute(SqlStatementStrategy strategy,
JdbcConnector connector,
ImmutableEndpoint endpoint,
MuleEvent event,
long timeout,
Connection connection) |
MuleMessage |
SimpleUpdateSqlStatementStrategy.executeStatement(JdbcConnector connector,
ImmutableEndpoint endpoint,
MuleEvent event,
long timeout,
Connection connection) |
MuleMessage |
SqlStatementStrategy.executeStatement(JdbcConnector connector,
ImmutableEndpoint endpoint,
MuleEvent event,
long timeout,
Connection connection) |
MuleMessage |
SelectSqlStatementStrategy.executeStatement(JdbcConnector connector,
ImmutableEndpoint endpoint,
MuleEvent event,
long timeout,
Connection connection) |
Modifier and Type | Method and Description |
---|---|
protected MuleMessage |
JmsMessageDispatcher.createMessageWithJmsMessagePayload(Message jmsMessage) |
protected MuleMessage |
JmsMessageRequester.doRequest(long timeout)
Make a specific request to the underlying transport
|
protected MuleMessage |
JmsMessageDispatcher.doSend(MuleEvent event) |
Modifier and Type | Method and Description |
---|---|
protected List<MuleMessage> |
XaTransactedJmsMessageReceiver.getMessages() |
Modifier and Type | Method and Description |
---|---|
protected void |
JmsMuleMessageFactory.addCorrelationProperties(Message jmsMessage,
MuleMessage muleMessage,
Map<String,Object> messageProperties) |
protected void |
JmsMuleMessageFactory.addJMSReplyTo(MuleMessage muleMessage,
Message jmsMessage) |
protected void |
JmsMessageDispatcher.preTransformMessage(MuleMessage message)
This method is called before the current message is transformed.
|
void |
JmsReplyToHandler.processReplyTo(MuleEvent event,
MuleMessage returnMessage,
Object replyTo) |
Modifier and Type | Method and Description |
---|---|
boolean |
JmsPropertyFilter.accept(MuleMessage message) |
boolean |
JmsSelectorFilter.accept(MuleMessage message) |
Modifier and Type | Method and Description |
---|---|
static Message |
JmsMessages.messageMarkedForRedelivery(MuleMessage message) |
Modifier and Type | Method and Description |
---|---|
protected MuleMessage |
AbstractRedeliveryHandler.createMuleMessage(Message message,
MuleContext muleContext) |
Constructor and Description |
---|
MessageRedeliveredException(String messageId,
int redeliveryCount,
int maxRedelivery,
InboundEndpoint endpoint,
FlowConstruct flow,
MuleMessage muleMessage) |
Modifier and Type | Method and Description |
---|---|
void |
AbstractJmsTransformer.setJmsProperties(MuleMessage message,
Message msg) |
Object |
JMSMessageToObject.transformMessage(MuleMessage message,
String outputEncoding) |
Object |
ObjectToJMSMessage.transformMessage(MuleMessage message,
String outputEncoding) |
protected Message |
AbstractJmsTransformer.transformToMessage(MuleMessage message) |
Modifier and Type | Method and Description |
---|---|
void |
MessageProcessorPollingMessageReceiver.pollWith(MuleMessage request) |
Modifier and Type | Method and Description |
---|---|
protected MuleMessage |
QuartzMessageDispatcher.doSend(MuleEvent event) |
Modifier and Type | Method and Description |
---|---|
protected MuleEvent |
QuartzMessageReceiver.createMuleEvent(MuleMessage message,
OutputStream outputStream) |
Modifier and Type | Method and Description |
---|---|
org.quartz.Job |
CustomJobFromMessageConfig.getJob(MuleMessage message) |
JobConfig |
CustomJobFromMessageConfig.getJobConfig(MuleMessage message) |
Modifier and Type | Method and Description |
---|---|
MuleMessage |
RmiMessageDispatcher.doSend(MuleEvent event) |
Modifier and Type | Method and Description |
---|---|
protected MuleEvent |
MuleReceiverServlet.routeMessage(MessageReceiver receiver,
MuleMessage requestMessage,
HttpServletRequest request) |
protected void |
ServletMuleMessageFactory.setupEncoding(HttpServletRequest request,
MuleMessage message) |
protected void |
MuleReceiverServlet.setupRequestMessage(HttpServletRequest request,
MuleMessage requestMessage) |
protected void |
MuleReceiverServlet.setupRequestMessage(HttpServletRequest request,
MuleMessage requestMessage,
MessageReceiver receiver) |
protected void |
ServletMuleMessageFactory.setupSessionId(HttpServletRequest request,
MuleMessage message) |
void |
ServletResponseWriter.writeErrorResponse(HttpServletResponse servletResponse,
MuleMessage message,
int errorCode,
String errorMessage,
Map<String,String> httpHeaders)
Writes a servlet response with an error code based on a mule message.
|
protected void |
AbstractReceiverServlet.writeErrorResponseFromMessage(HttpServletResponse servletResponse,
MuleMessage message,
int errorCode,
String errorMessage) |
protected void |
AbstractReceiverServlet.writeResponse(HttpServletResponse servletResponse,
MuleMessage message) |
void |
ServletResponseWriter.writeResponse(HttpServletResponse servletResponse,
MuleMessage message,
Map<String,String> httpHeaders)
Writes a servlet response based on a mule message.
|
Modifier and Type | Method and Description |
---|---|
protected MuleMessage |
JettyMessageProcessTemplate.createMessageFromSource(Object message) |
Modifier and Type | Method and Description |
---|---|
Object |
HttpRequestToParameterMap.transformMessage(MuleMessage message,
String outputEncoding) |
Object |
HttpRequestToParameter.transformMessage(MuleMessage message,
String outputEncoding) |
Modifier and Type | Method and Description |
---|---|
protected MuleMessage |
SftpMessageRequester.doRequest(long timeout) |
protected MuleMessage |
SftpMessageDispatcher.doSend(MuleEvent event) |
protected MuleMessage |
SftpMessageReceiver.handleUnacceptedFilter(MuleMessage message)
SFTP-35
|
Modifier and Type | Method and Description |
---|---|
protected MuleMessage |
SftpMessageReceiver.handleUnacceptedFilter(MuleMessage message)
SFTP-35
|
Modifier and Type | Method and Description |
---|---|
void |
SftpNotifier.setMessage(MuleMessage message) |
Constructor and Description |
---|
SftpNotifier(SftpConnector connector,
MuleMessage message,
ImmutableEndpoint endpoint,
String serviceName) |
SftpTransportNotification(MuleMessage resource,
ImmutableEndpoint endpoint,
String resourceIdentifier,
int action,
String info,
long size) |
Modifier and Type | Method and Description |
---|---|
protected static MuleMessage |
AxisMessageDispatcher.createMessage(Object result,
org.apache.axis.client.Call call,
MuleContext muleContext) |
protected MuleMessage |
AxisMessageRequester.doRequest(long timeout)
Make a specific request to the underlying transport
|
protected MuleMessage |
AxisMessageDispatcher.doSend(MuleEvent event) |
MuleMessage |
AxisMessageRequester.request(String endpoint,
Object[] args) |
MuleMessage |
AxisMessageRequester.request(String endpoint,
SOAPEnvelope envelope) |
Modifier and Type | Method and Description |
---|---|
protected void |
AxisMessageDispatcher.setMessageContextAttachments(MuleMessage message,
org.apache.axis.MessageContext ctx) |
protected void |
AxisMessageDispatcher.setMessageContextProperties(MuleMessage message,
org.apache.axis.MessageContext ctx) |
Modifier and Type | Method and Description |
---|---|
protected static void |
AxisCleanAndAddProperties.populateProps(Map<String,Object> props,
MuleMessage currentMessage,
PropertyScope scope) |
Modifier and Type | Method and Description |
---|---|
protected void |
SslMessageReceiver.SslWorker.preRouteMuleMessage(MuleMessage message) |
Modifier and Type | Method and Description |
---|---|
protected MuleMessage |
StdioMessageDispatcher.doSend(MuleEvent event) |
Modifier and Type | Method and Description |
---|---|
OutputStream |
PromptStdioConnector.getOutputStream(ImmutableEndpoint endpoint,
MuleMessage message) |
Modifier and Type | Method and Description |
---|---|
protected MuleMessage |
TcpMessageRequester.doRequest(long timeout)
Make a specific request to the underlying transport
|
protected MuleMessage |
LocalSocketTcpMessageDispatcher.doSend(MuleEvent event) |
protected MuleMessage |
TcpMessageDispatcher.doSend(MuleEvent event) |
Modifier and Type | Method and Description |
---|---|
OutputStream |
TcpConnector.getOutputStream(ImmutableEndpoint endpoint,
MuleMessage message) |
protected void |
TcpMessageReceiver.TcpWorker.preRouteMuleMessage(MuleMessage message) |
Modifier and Type | Method and Description |
---|---|
protected MuleMessage |
UdpMessageRequester.doRequest(long timeout)
Make a specific request to the underlying transport
|
protected MuleMessage |
UdpMessageDispatcher.doSend(MuleEvent event) |
Modifier and Type | Method and Description |
---|---|
protected MuleMessage |
VMMessageRequester.doRequest(long timeout)
Make a specific request to the underlying transport
|
protected MuleMessage |
VMMessageDispatcher.doSend(MuleEvent event) |
MuleMessage |
VMMessageReceiver.onCall(MuleMessage message) |
Modifier and Type | Method and Description |
---|---|
protected List<MuleMessage> |
VMMessageReceiver.getFirstMessages() |
protected List<MuleMessage> |
VMMessageReceiver.getMessages()
It's impossible to process all messages in the receive transaction
|
Modifier and Type | Method and Description |
---|---|
MuleMessage |
VMMessageReceiver.onCall(MuleMessage message) |
void |
VMMessageReceiver.onMessage(MuleMessage message) |
Modifier and Type | Method and Description |
---|---|
protected MuleMessage |
XmppMessageRequester.doRequest(long timeout) |
protected MuleMessage |
XmppMessageDispatcher.doSend(MuleEvent event) |
Modifier and Type | Method and Description |
---|---|
boolean |
AbstractXmppFilter.accept(MuleMessage message) |
Modifier and Type | Method and Description |
---|---|
Object |
ObjectToXmppPacket.transformMessage(MuleMessage muleMessage,
String outputEncoding) |
Object |
XmppPacketToObject.transformMessage(MuleMessage muleMessage,
String outputEncoding) |
Modifier and Type | Method and Description |
---|---|
static String |
StringMessageUtils.headersToString(MuleMessage m) |
TypedValue |
AttributeEvaluator.resolveTypedValue(MuleMessage message) |
Object |
AttributeEvaluator.resolveValue(MuleMessage message) |
Copyright © 2003–2015 MuleSoft, Inc.. All rights reserved.