|
|||||||||||
| PREV NEXT | FRAMES NO FRAMES | ||||||||||
| Packages that use UMOMessage | |
| org.mule.components.builder | |
| org.mule.components.rest | |
| org.mule.components.script.jsr223 | |
| org.mule.extras.client | Simple interface for Mule clients to send and receive events from local or remote Mule Servers. |
| org.mule.impl | The Mule implementation of the Universal Message Objects(tm) API specification. |
| org.mule.impl.internal.admin | Admin components and Agents used to control and Monitor Mule |
| org.mule.impl.internal.notifications | Internal server notificationicationicationicationicationicationicationicationicationicationicationicationicationicationicationicationicationicationicationicationicationication types fired via the MuleManager. |
| org.mule.impl.model | |
| org.mule.impl.model.direct | |
| org.mule.impl.model.pipeline | |
| org.mule.impl.model.seda | |
| org.mule.impl.model.seda.optimised | |
| org.mule.interceptors | Contains default UMOInterceptor implementations that can be applied to Mule managed components. |
| org.mule.providers | Contains Abstract classes providing common functionality for all Mule providers. |
| org.mule.providers.dq | |
| org.mule.providers.email | Provides pop3, smtp and imap connectivity for Mule. |
| org.mule.providers.email.filters | |
| org.mule.providers.file | Provides file transport in the form of a directory listeners and file dispatchers. |
| org.mule.providers.file.filters | Filename filters used to filter on a listening directory. |
| org.mule.providers.ftp | |
| org.mule.providers.gs | Allows Mule to send and receive events the GigaSpaces Jini JavaSpace implementation. |
| org.mule.providers.gs.filters | |
| org.mule.providers.http | Provides http transport including proxy support. |
| org.mule.providers.http.servlet | |
| org.mule.providers.jbi | Allows JBI components to interact with Mule. |
| org.mule.providers.jbi.components | |
| org.mule.providers.jdbc | Provides jdbc transport. |
| org.mule.providers.jms | Provides Jms transport connectivity with support for all Jms features. |
| org.mule.providers.jms.filters | |
| org.mule.providers.jms.transformers | Contains transformers to convert to and from different javax.jms.Message types |
| org.mule.providers.oracle.jms | |
| org.mule.providers.quartz | |
| org.mule.providers.rmi | |
| org.mule.providers.soap.axis | Provides an Axis soap transport for Mule. |
| org.mule.providers.soap.glue | Provides an Glue soap transport for Mule. |
| org.mule.providers.soap.xfire | |
| org.mule.providers.space | Allows Mule to send and receive events via the Mule Space API. |
| org.mule.providers.stream | |
| org.mule.providers.tcp | Provides tcp connectivity for Mule. |
| org.mule.providers.udp | Provides Udp connectivity for Mule. |
| org.mule.providers.vm | A connector implementation allowing events to be passed between Mule sessions via in-memory queues. |
| org.mule.providers.xmpp | |
| org.mule.ra | A Resource Adapter implementation that allows a Mule instance to be deployed to a J2ee application server and exposes Mule services via the JCA connector architecture. |
| org.mule.routing | Defines the core routing patterns supported by mule. |
| org.mule.routing.filters | Filters are often used by routers to determine if the event should be accepted by the router. |
| org.mule.routing.filters.logic | Filters that allow other filters to be combined. |
| org.mule.routing.filters.xml | Filters that apply specifically to xml using xml querying mechanisms. |
| org.mule.routing.inbound | Inbound router implementation as described in the Enterprise Integration Patterns book. |
| org.mule.routing.outbound | Outbound router implementation as described in the Enterprise Integration Patterns book. |
| org.mule.routing.response | Response router implementations that enable asynchronous event processing in request /response messaging requests. |
| org.mule.samples.loanbroker | |
| org.mule.samples.loanbroker.esb | |
| org.mule.samples.loanbroker.esb.routers | |
| org.mule.samples.loanbroker.routers | |
| org.mule.samples.voipservice.routers | |
| org.mule.samples.voipservice.service | |
| org.mule.tck.testmodels.mule | |
| org.mule.test.usecases.service | |
| org.mule.umo | The Universal Message Object(tm) API provides a way for components to interact without needing to know about the protocol or delivery mechanisms of information passed between them |
| org.mule.umo.provider | Contains the interfaces that comprise a provider implementation. |
| org.mule.umo.routing | Interfaces that define inbound and outbound routing API. |
| org.mule.umo.security | Security API for authentication and authorisation. |
| Uses of UMOMessage in org.mule.components.builder |
| Methods in org.mule.components.builder with parameters of type UMOMessage | |
Object |
ReflectionMessageBuilder.buildMessage(UMOMessage request,
UMOMessage response)
|
Object |
MessageBuilder.buildMessage(UMOMessage request,
UMOMessage response)
|
| Constructors in org.mule.components.builder with parameters of type UMOMessage | |
MessageBuilderException(Message message,
UMOMessage umoMessage)
|
|
MessageBuilderException(Message message,
UMOMessage umoMessage,
Throwable cause)
|
|
MessageBuilderException(UMOMessage umoMessage,
Throwable cause)
|
|
| Uses of UMOMessage in org.mule.components.rest |
| Methods in org.mule.components.rest with parameters of type UMOMessage | |
protected boolean |
RestServiceWrapper.isErrorPayload(UMOMessage message)
|
protected void |
RestServiceWrapper.handleException(RestServiceException e,
UMOMessage result)
|
| Constructors in org.mule.components.rest with parameters of type UMOMessage | |
RestServiceException(Message message,
UMOMessage umoMessage)
|
|
RestServiceException(Message message,
UMOMessage umoMessage,
Throwable cause)
|
|
| Uses of UMOMessage in org.mule.components.script.jsr223 |
| Methods in org.mule.components.script.jsr223 with parameters of type UMOMessage | |
Object |
ScriptMessageBuilder.buildMessage(UMOMessage request,
UMOMessage response)
|
protected void |
ScriptMessageBuilder.populateNamespace(Namespace namespace,
UMOMessage request,
UMOMessage response)
|
| Uses of UMOMessage in org.mule.extras.client |
| Methods in org.mule.extras.client that return UMOMessage | |
UMOMessage |
MuleClient.sendDirect(String component,
String transformers,
Object payload,
Map messageProperties)
sends an event synchronously to a components |
UMOMessage |
MuleClient.sendDirect(String component,
String transformers,
UMOMessage message)
sends an event synchronously to a components |
UMOMessage |
MuleClient.send(String url,
Object payload,
Map messageProperties)
Sends an event synchronously to a endpointUri via a mule server and a resulting message is returned. |
UMOMessage |
MuleClient.send(String url,
UMOMessage message)
Sends an event synchronously to a endpointUri via a mule server and a resulting message is returned. |
UMOMessage |
MuleClient.send(String url,
Object payload,
Map messageProperties,
int timeout)
Sends an event synchronously to a endpointUri via a mule server and a resulting message is returned. |
UMOMessage |
MuleClient.send(String url,
UMOMessage message,
int timeout)
Sends an event synchronously to a endpointUri via a mule server and a resulting message is returned. |
UMOMessage |
MuleClient.receive(String url,
long timeout)
Will receive an event from an endpointUri determined by the url |
UMOMessage |
MuleClient.receive(String url,
String transformers,
long timeout)
Will receive an event from an endpointUri determined by the url |
UMOMessage |
MuleClient.receive(String url,
UMOTransformer transformer,
long timeout)
Will receive an event from an endpointUri determined by the url |
UMOMessage |
RemoteDispatcher.sendToRemoteComponent(String component,
Object payload,
Map messageProperties)
sends an event synchronously to a components on a remote Mule instance. |
UMOMessage |
RemoteDispatcher.sendRemote(String endpoint,
Object payload,
Map messageProperties,
int timeout)
|
UMOMessage |
RemoteDispatcher.sendRemote(String endpoint,
Object payload,
Map messageProperties)
|
UMOMessage |
RemoteDispatcher.receiveRemote(String endpoint,
int timeout)
|
protected UMOMessage |
RemoteDispatcher.doToRemoteComponent(String component,
Object payload,
Map messageProperties,
boolean synchronous)
|
protected UMOMessage |
RemoteDispatcher.doToRemote(String endpoint,
Object payload,
Map messageProperties,
boolean synchronous,
int timeout)
|
protected UMOMessage |
RemoteDispatcher.dispatchAction(AdminNotification action,
boolean synchronous,
int timeout)
|
UMOMessage |
AbstractEventTransformer.transform(Object src,
Method method)
|
| Methods in org.mule.extras.client with parameters of type UMOMessage | |
void |
MuleClient.dispatch(String url,
UMOMessage message)
Dispatches an event asynchronously to a endpointUri via a mule server. |
UMOMessage |
MuleClient.sendDirect(String component,
String transformers,
UMOMessage message)
sends an event synchronously to a components |
void |
MuleClient.dispatchDirect(String component,
UMOMessage message)
dispatches an event asynchronously to the components |
FutureMessageResult |
MuleClient.sendAsync(String url,
UMOMessage 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,
UMOMessage 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. |
FutureMessageResult |
MuleClient.sendDirectAsync(String component,
String transformers,
UMOMessage message)
sends an event to a components on a local Mule instance, while making the result of the event trigger available as a Future result that can be accessed later by client code. |
UMOMessage |
MuleClient.send(String url,
UMOMessage message)
Sends an event synchronously to a endpointUri via a mule server and a resulting message is returned. |
UMOMessage |
MuleClient.send(String url,
UMOMessage message,
int timeout)
Sends an event synchronously to a endpointUri via a mule server and a resulting message is returned. |
protected UMOEvent |
MuleClient.getEvent(UMOMessage message,
String uri,
boolean synchronous,
boolean streaming)
Packages a mule event for the current request |
protected void |
RemoteDispatcher.setCredentials(UMOMessage message)
|
protected void |
RemoteDispatcher.updateContext(UMOMessage message,
UMOEndpoint endpoint,
boolean synchronous)
|
| Uses of UMOMessage in org.mule.impl |
| Classes in org.mule.impl that implement UMOMessage | |
class |
MuleMessage
MuleMessage is a wrapper that contains a payload and properties
associated with the payload. |
| Methods in org.mule.impl that return UMOMessage | |
UMOMessage |
MuleEvent.getMessage()
|
UMOMessage |
DefaultLifecycleAdapter.intercept(Invocation invocation)
|
UMOMessage |
MuleSession.sendEvent(UMOMessage message,
String endpointName)
|
UMOMessage |
MuleSession.sendEvent(UMOMessage message)
|
UMOMessage |
MuleSession.sendEvent(UMOMessage message,
UMOImmutableEndpoint endpoint)
|
UMOMessage |
MuleSession.sendEvent(UMOEvent event)
|
UMOMessage |
MuleSession.receiveEvent(String endpointName,
long timeout)
|
UMOMessage |
MuleSession.receiveEvent(UMOImmutableEndpoint endpoint,
long timeout)
|
UMOMessage |
MuleEventContext.getMessage()
Returns the message payload for this event |
UMOMessage |
MuleEventContext.sendEvent(Object message)
This will send an event via the configured outbound router on the component |
UMOMessage |
MuleEventContext.sendEvent(UMOMessage message,
UMOEndpoint endpoint)
Depending on the session state this methods either Passes an event synchronously to the next available Mule UMO in the pool or via the endpoint configured for the event |
UMOMessage |
MuleEventContext.sendEvent(UMOMessage message)
Depending on the session state this methods either Passes an event synchronously to the next available Mule UMO in the pool or via the endpoint configured for the event |
UMOMessage |
MuleEventContext.sendEvent(UMOMessage message,
UMOEndpointURI endpointUri)
Depending on the session state this methods either Passes an event synchronously to the next available Mule UMO in the pool or via the endpointUri configured for the event |
UMOMessage |
MuleEventContext.sendEvent(UMOMessage message,
String endpointName)
Depending on the session state this methods either Passes an event synchronously to the next available Mule UMO in the pool or via the endpoint configured for the event |
UMOMessage |
MuleEventContext.receiveEvent(UMOEndpoint endpoint,
long timeout)
Requests a synchronous receive of an event on the component |
UMOMessage |
MuleEventContext.receiveEvent(String endpointName,
long timeout)
Requests a synchronous receive of an event on the component |
UMOMessage |
MuleEventContext.receiveEvent(UMOEndpointURI endpointUri,
long timeout)
Requests a synchronous receive of an event on the component |
UMOMessage |
InterceptorsInvoker.execute()
|
| Methods in org.mule.impl with parameters of type UMOMessage | |
void |
MuleSessionHandler.retrieveSessionInfoFromMessage(UMOMessage message,
UMOSession session)
|
void |
MuleSessionHandler.storeSessionInfoToMessage(UMOSession session,
UMOMessage message)
|
void |
MuleSession.dispatchEvent(UMOMessage message)
|
void |
MuleSession.dispatchEvent(UMOMessage message,
String endpointName)
|
void |
MuleSession.dispatchEvent(UMOMessage message,
UMOImmutableEndpoint endpoint)
|
UMOMessage |
MuleSession.sendEvent(UMOMessage message,
String endpointName)
|
UMOMessage |
MuleSession.sendEvent(UMOMessage message)
|
UMOMessage |
MuleSession.sendEvent(UMOMessage message,
UMOImmutableEndpoint endpoint)
|
protected void |
MuleSession.processResponse(UMOMessage response)
Once an event has been processed we need to romove certain properties so that they not propagated to the next request |
UMOEvent |
MuleSession.createOutboundEvent(UMOMessage message,
UMOImmutableEndpoint endpoint,
UMOEvent previousEvent)
|
UMOMessage |
MuleEventContext.sendEvent(UMOMessage message,
UMOEndpoint endpoint)
Depending on the session state this methods either Passes an event synchronously to the next available Mule UMO in the pool or via the endpoint configured for the event |
UMOMessage |
MuleEventContext.sendEvent(UMOMessage message)
Depending on the session state this methods either Passes an event synchronously to the next available Mule UMO in the pool or via the endpoint configured for the event |
UMOMessage |
MuleEventContext.sendEvent(UMOMessage message,
UMOEndpointURI endpointUri)
Depending on the session state this methods either Passes an event synchronously to the next available Mule UMO in the pool or via the endpointUri configured for the event |
FutureMessageResult |
MuleEventContext.sendEventAsync(UMOMessage message,
int timeout)
sends an event request via the configured outbound router for this component. |
FutureMessageResult |
MuleEventContext.sendEventAsync(UMOMessage message,
UMOEndpointURI endpointUri,
int timeout)
sends an event request via the configured outbound router for this component. |
FutureMessageResult |
MuleEventContext.sendEventAsync(UMOMessage message,
String endpointName,
int timeout)
sends an event request via the configured outbound router for this component. |
UMOMessage |
MuleEventContext.sendEvent(UMOMessage message,
String endpointName)
Depending on the session state this methods either Passes an event synchronously to the next available Mule UMO in the pool or via the endpoint configured for the event |
void |
MuleEventContext.dispatchEvent(UMOMessage message)
This will dispatch an event asynchronously via the configured outbound endpoint on the component for this session |
void |
MuleEventContext.dispatchEvent(UMOMessage message,
UMOEndpointURI endpointUri)
Depending on the session state this methods either Passes an event asynchronously to the next available Mule UMO in the pool or via the endpointUri configured for the event |
void |
MuleEventContext.dispatchEvent(UMOMessage message,
String endpointName)
Depending on the session state this methods either Passes an event asynchronously to the next available Mule UMO in the pool or via the endpoint configured for the event |
void |
MuleEventContext.dispatchEvent(UMOMessage message,
UMOEndpoint endpoint)
Depending on the session state this methods either Passes an event asynchronously to the next available Mule UMO in the pool or via the endpoint configured for the event |
void |
NullSessionHandler.retrieveSessionInfoFromMessage(UMOMessage message,
UMOSession session)
|
void |
NullSessionHandler.storeSessionInfoToMessage(UMOSession session,
UMOMessage message)
|
protected void |
DefaultComponentExceptionStrategy.logFatal(UMOMessage message,
Throwable t)
|
protected void |
DefaultComponentExceptionStrategy.routeException(UMOMessage message,
UMOImmutableEndpoint failedEndpoint,
Throwable t)
|
void |
DefaultExceptionStrategy.handleMessagingException(UMOMessage message,
Throwable t)
|
void |
DefaultExceptionStrategy.handleRoutingException(UMOMessage message,
UMOImmutableEndpoint endpoint,
Throwable t)
|
protected void |
AbstractExceptionListener.routeException(UMOMessage message,
UMOImmutableEndpoint failedEndpoint,
Throwable t)
Routes the current exception to an error endpoint such as a Dead Letter Queue (jms) This method is only invoked if there is a UMOMessage available to dispatch. |
protected Object |
AbstractExceptionListener.getErrorMessagePayload(UMOMessage message)
|
protected void |
AbstractExceptionListener.logFatal(UMOMessage message,
Throwable t)
Logs a fatal error message to the logging system. |
abstract void |
AbstractExceptionListener.handleMessagingException(UMOMessage message,
Throwable e)
A messaging exception is thrown when an excpetion occurs during normal message processing. |
abstract void |
AbstractExceptionListener.handleRoutingException(UMOMessage message,
UMOImmutableEndpoint endpoint,
Throwable e)
A routing exception is thrown when an excpetion occurs during normal message processing A RoutingException holds a reference to the current
message and te endpoint being routing to or from when the error occurred. |
static void |
RequestContext.rewriteEvent(UMOMessage message)
Sets a new message payload in the RequestContext but maintains all other properties (session, endpoint, synchronous, etc.) from the previous event. |
static void |
RequestContext.writeResponse(UMOMessage message)
|
| Constructors in org.mule.impl with parameters of type UMOMessage | |
MuleEvent(UMOMessage message,
UMOImmutableEndpoint endpoint,
UMOComponent component,
UMOEvent previousEvent)
Properties cache that only reads properties once from the inbound message and merges them with any properties on the endpoint. |
|
MuleEvent(UMOMessage message,
UMOImmutableEndpoint endpoint,
UMOSession session,
boolean synchronous)
|
|
MuleEvent(UMOMessage message,
UMOImmutableEndpoint endpoint,
UMOSession session,
boolean synchronous,
ResponseOutputStream outputStream)
Contructor. |
|
MuleEvent(UMOMessage message,
UMOImmutableEndpoint endpoint,
UMOSession session,
String eventId,
boolean synchronous)
Contructor. |
|
MuleEvent(UMOMessage message,
UMOEvent rewriteEvent)
A helper constructor used to rewrite an event payload |
|
FailedToQueueEventException(Message message,
UMOMessage umoMessage,
UMOComponent component)
|
|
FailedToQueueEventException(Message message,
UMOMessage umoMessage,
UMOComponent component,
Throwable cause)
|
|
FailedToQueueEventException(UMOMessage umoMessage,
UMOComponent component,
Throwable cause)
|
|
MuleSession(UMOMessage message,
UMOSessionHandler requestSessionHandler,
UMOComponent component)
|
|
MuleSession(UMOMessage message,
UMOSessionHandler requestSessionHandler)
|
|
InterceptorsInvoker(List interceptors,
MuleDescriptor descriptor,
UMOMessage message)
|
|
InterceptorsInvoker(List interceptors,
UMOImmutableDescriptor descriptor,
UMOMessage message)
|
|
| Uses of UMOMessage in org.mule.impl.internal.admin |
| Methods in org.mule.impl.internal.admin with parameters of type UMOMessage | |
protected String |
MuleManagerComponent.handleException(UMOMessage result,
Throwable e)
Wraps an execption into a MuleMessage with an Exception payload and returns the Xml representation of it |
| Uses of UMOMessage in org.mule.impl.internal.notifications |
| Methods in org.mule.impl.internal.notifications that return UMOMessage | |
UMOMessage |
AdminNotification.getMessage()
|
protected static UMOMessage |
MessageNotification.cloneMessage(UMOMessage message)
|
| Methods in org.mule.impl.internal.notifications with parameters of type UMOMessage | |
protected static UMOMessage |
MessageNotification.cloneMessage(UMOMessage message)
|
| Constructors in org.mule.impl.internal.notifications with parameters of type UMOMessage | |
AdminNotification(UMOMessage message,
int action,
String resourceIdentifier)
|
|
MessageNotification(UMOMessage resource,
UMOImmutableEndpoint endpoint,
String identifier,
int action)
|
|
| Uses of UMOMessage in org.mule.impl.model |
| Methods in org.mule.impl.model that return UMOMessage | |
UMOMessage |
AbstractComponent.sendEvent(UMOEvent event)
|
protected abstract UMOMessage |
AbstractComponent.doSend(UMOEvent event)
|
| Methods in org.mule.impl.model with parameters of type UMOMessage | |
protected ReplyToHandler |
DefaultMuleProxy.getReplyToHandler(UMOMessage message,
UMOImmutableEndpoint endpoint)
|
| Uses of UMOMessage in org.mule.impl.model.direct |
| Methods in org.mule.impl.model.direct that return UMOMessage | |
protected UMOMessage |
DirectComponent.doSend(UMOEvent event)
|
| Uses of UMOMessage in org.mule.impl.model.pipeline |
| Methods in org.mule.impl.model.pipeline that return UMOMessage | |
protected UMOMessage |
PipelineComponent.doSend(UMOEvent event)
|
| Uses of UMOMessage in org.mule.impl.model.seda |
| Methods in org.mule.impl.model.seda that return UMOMessage | |
UMOMessage |
SedaComponent.doSend(UMOEvent event)
|
| Uses of UMOMessage in org.mule.impl.model.seda.optimised |
| Methods in org.mule.impl.model.seda.optimised that return UMOMessage | |
protected UMOMessage |
OptimisedMuleProxy.invokeUmo(UMOEventContext context)
|
| Uses of UMOMessage in org.mule.interceptors |
| Methods in org.mule.interceptors that return UMOMessage | |
UMOMessage |
TimerInterceptor.intercept(Invocation invocation)
|
UMOMessage |
InterceptorStack.intercept(Invocation invocation)
|
UMOMessage |
EnvelopeInterceptor.intercept(Invocation invocation)
|
abstract UMOMessage |
MessageNormalizerInterceptor.before(Invocation invocation)
This method is invoked before the event is processed |
abstract UMOMessage |
MessageNormalizerInterceptor.after(Invocation invocation)
This method is invoked after the event has been processed |
UMOMessage |
MessageNormalizerInterceptor.intercept(Invocation invocation)
|
UMOMessage |
JXPathNormalizerInterceptor.before(Invocation invocation)
This method is invoked before the event is processed |
UMOMessage |
JXPathNormalizerInterceptor.after(Invocation invocation)
This method is invoked after the event has been processed |
| Uses of UMOMessage in org.mule.providers |
| Methods in org.mule.providers that return UMOMessage | |
UMOMessage |
AbstractMessageDispatcher.send(UMOEvent event)
|
UMOMessage |
AbstractMessageDispatcher.receive(UMOEndpointURI endpointUri,
long timeout)
Make a specific request to the underlying transport |
UMOMessage |
AbstractMessageDispatcher.receive(UMOImmutableEndpoint endpoint,
long timeout)
Make a specific request to the underlying transport |
protected abstract UMOMessage |
AbstractMessageDispatcher.doSend(UMOEvent event)
|
protected abstract UMOMessage |
AbstractMessageDispatcher.doReceive(UMOImmutableEndpoint endpoint,
long timeout)
Make a specific request to the underlying transport |
UMOMessage |
InternalMessageListener.onMessage(UMOMessage message,
UMOTransaction trans,
boolean synchronous,
OutputStream outputStream)
|
UMOMessage |
AbstractMessageReceiver.routeMessage(UMOMessage message)
|
UMOMessage |
AbstractMessageReceiver.routeMessage(UMOMessage message,
boolean synchronous)
|
UMOMessage |
AbstractMessageReceiver.routeMessage(UMOMessage message,
UMOTransaction trans,
boolean synchronous)
|
UMOMessage |
AbstractMessageReceiver.routeMessage(UMOMessage message,
OutputStream outputStream)
|
UMOMessage |
AbstractMessageReceiver.routeMessage(UMOMessage message,
boolean synchronous,
OutputStream outputStream)
|
UMOMessage |
AbstractMessageReceiver.routeMessage(UMOMessage message,
UMOTransaction trans,
boolean synchronous,
OutputStream outputStream)
|
protected UMOMessage |
AbstractMessageReceiver.handleUnacceptedFilter(UMOMessage message)
|
protected UMOMessage |
AbstractMessageReceiver.applyResponseTransformer(UMOMessage returnMessage)
|
| Methods in org.mule.providers with parameters of type UMOMessage | |
void |
DefaultReplyToHandler.processReplyTo(UMOEvent event,
UMOMessage returnMessage,
Object replyTo)
|
OutputStream |
AbstractMessageDispatcher.getOutputStream(UMOImmutableEndpoint endpoint,
UMOMessage message)
Well get the output stream (if any) for this type of transport. |
UMOMessage |
InternalMessageListener.onMessage(UMOMessage message,
UMOTransaction trans,
boolean synchronous,
OutputStream outputStream)
|
void |
ReplyToHandler.processReplyTo(UMOEvent event,
UMOMessage returnMessage,
Object replyTo)
|
protected void |
AbstractMessageReceiver.setExceptionDetails(UMOMessage message,
Throwable exception)
This method is used to set any additional aand possibly transport specific information on the return message where it has an exception payload. |
UMOMessage |
AbstractMessageReceiver.routeMessage(UMOMessage message)
|
UMOMessage |
AbstractMessageReceiver.routeMessage(UMOMessage message,
boolean synchronous)
|
UMOMessage |
AbstractMessageReceiver.routeMessage(UMOMessage message,
UMOTransaction trans,
boolean synchronous)
|
UMOMessage |
AbstractMessageReceiver.routeMessage(UMOMessage message,
OutputStream outputStream)
|
UMOMessage |
AbstractMessageReceiver.routeMessage(UMOMessage message,
boolean synchronous,
OutputStream outputStream)
|
UMOMessage |
AbstractMessageReceiver.routeMessage(UMOMessage message,
UMOTransaction trans,
boolean synchronous,
OutputStream outputStream)
|
protected UMOMessage |
AbstractMessageReceiver.handleUnacceptedFilter(UMOMessage message)
|
protected UMOMessage |
AbstractMessageReceiver.applyResponseTransformer(UMOMessage returnMessage)
|
| Uses of UMOMessage in org.mule.providers.dq |
| Methods in org.mule.providers.dq that return UMOMessage | |
protected UMOMessage |
DQMessageDispatcher.doSend(UMOEvent event)
|
protected UMOMessage |
DQMessageDispatcher.doReceive(UMOImmutableEndpoint endpoint,
long timeout)
Make a specific request to the underlying transport |
| Uses of UMOMessage in org.mule.providers.email |
| Methods in org.mule.providers.email that return UMOMessage | |
protected UMOMessage |
SmtpMessageDispatcher.doReceive(UMOImmutableEndpoint endpoint,
long timeout)
Make a specific request to the underlying transport |
protected UMOMessage |
SmtpMessageDispatcher.doSend(UMOEvent event)
|
protected UMOMessage |
Pop3MessageReceiver.handleUnacceptedFilter(UMOMessage message)
|
protected UMOMessage |
Pop3MessageDispatcher.doSend(UMOEvent event)
|
protected UMOMessage |
Pop3MessageDispatcher.doReceive(UMOImmutableEndpoint endpoint,
long timeout)
Make a specific request to the underlying transport Endpoint can be in the form of pop3://username:password@pop3.lotsofmail.org |
| Methods in org.mule.providers.email with parameters of type UMOMessage | |
protected UMOMessage |
Pop3MessageReceiver.handleUnacceptedFilter(UMOMessage message)
|
| Uses of UMOMessage in org.mule.providers.email.filters |
| Methods in org.mule.providers.email.filters with parameters of type UMOMessage | |
boolean |
AbstractMailFilter.accept(UMOMessage message)
|
| Uses of UMOMessage in org.mule.providers.file |
| Methods in org.mule.providers.file that return UMOMessage | |
protected UMOMessage |
FileMessageDispatcher.doReceive(UMOImmutableEndpoint endpoint,
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 UMOMessage |
FileMessageDispatcher.doSend(UMOEvent event)
|
| Methods in org.mule.providers.file with parameters of type UMOMessage | |
OutputStream |
FileMessageDispatcher.getOutputStream(UMOImmutableEndpoint endpoint,
UMOMessage message)
Well get the output stream (if any) for this type of transport. |
| Uses of UMOMessage in org.mule.providers.file.filters |
| Methods in org.mule.providers.file.filters with parameters of type UMOMessage | |
boolean |
FilenameWildcardFilter.accept(UMOMessage message)
|
| Uses of UMOMessage in org.mule.providers.ftp |
| Methods in org.mule.providers.ftp that return UMOMessage | |
protected UMOMessage |
FtpMessageDispatcher.doSend(UMOEvent event)
|
protected UMOMessage |
FtpMessageDispatcher.doReceive(UMOImmutableEndpoint endpoint,
long timeout)
Make a specific request to the underlying transport |
| Methods in org.mule.providers.ftp with parameters of type UMOMessage | |
OutputStream |
FtpMessageDispatcher.getOutputStream(UMOImmutableEndpoint endpoint,
UMOMessage message)
Well get the output stream (if any) for this type of transport. |
| Uses of UMOMessage in org.mule.providers.gs |
| Methods in org.mule.providers.gs with parameters of type UMOMessage | |
Entry |
GigaSpacesEntryConverter.toEntry(Object pojo,
UMOMessage msg)
|
| Uses of UMOMessage in org.mule.providers.gs.filters |
| Methods in org.mule.providers.gs.filters with parameters of type UMOMessage | |
boolean |
JavaSpaceTemplateFilter.accept(UMOMessage message)
Check a given message against this filter. |
boolean |
PojoTypeTemplateFilter.accept(UMOMessage message)
Check a given message against this filter. |
| Uses of UMOMessage in org.mule.providers.http |
| Methods in org.mule.providers.http that return UMOMessage | |
protected UMOMessage |
HttpClientMessageDispatcher.doReceive(UMOImmutableEndpoint endpoint,
long timeout)
Make a specific request to the underlying transport |
protected UMOMessage |
HttpClientMessageDispatcher.doSend(UMOEvent event)
|
| Methods in org.mule.providers.http with parameters of type UMOMessage | |
protected String |
HttpMessageReceiver.getRequestPath(UMOMessage message)
|
protected AbstractMessageReceiver |
HttpMessageReceiver.getTargetReceiver(UMOMessage message,
UMOEndpoint endpoint)
|
void |
HttpSessionHandler.retrieveSessionInfoFromMessage(UMOMessage message,
UMOSession session)
|
void |
HttpSessionHandler.storeSessionInfoToMessage(UMOSession session,
UMOMessage message)
|
| Uses of UMOMessage in org.mule.providers.http.servlet |
| Methods in org.mule.providers.http.servlet with parameters of type UMOMessage | |
protected void |
AbstractReceiverServlet.writeResponse(HttpServletResponse servletResponse,
UMOMessage message)
|
| Uses of UMOMessage in org.mule.providers.jbi |
| Methods in org.mule.providers.jbi that return UMOMessage | |
static UMOMessage |
JbiUtils.createMessage(NormalizedMessage message)
|
protected UMOMessage |
JbiMessageDispatcher.doSend(UMOEvent event)
|
protected UMOMessage |
JbiMessageDispatcher.doReceive(UMOImmutableEndpoint endpoint,
long timeout)
Make a specific request to the underlying transport |
| Methods in org.mule.providers.jbi with parameters of type UMOMessage | |
static void |
JbiUtils.populateNormalizedMessage(UMOMessage muleMessage,
NormalizedMessage message)
|
| Uses of UMOMessage in org.mule.providers.jbi.components |
| Methods in org.mule.providers.jbi.components that return UMOMessage | |
UMOMessage |
MuleReceiver.onMessage(UMOMessage message,
UMOTransaction trans,
boolean synchronous,
OutputStream outputStream)
|
| Methods in org.mule.providers.jbi.components with parameters of type UMOMessage | |
UMOMessage |
MuleReceiver.onMessage(UMOMessage message,
UMOTransaction trans,
boolean synchronous,
OutputStream outputStream)
|
| Uses of UMOMessage in org.mule.providers.jdbc |
| Methods in org.mule.providers.jdbc that return UMOMessage | |
protected UMOMessage |
JdbcMessageDispatcher.doSend(UMOEvent event)
|
protected UMOMessage |
JdbcMessageDispatcher.doReceive(UMOImmutableEndpoint endpoint,
long timeout)
Make a specific request to the underlying transport |
| Uses of UMOMessage in org.mule.providers.jms |
| Methods in org.mule.providers.jms that return UMOMessage | |
protected UMOMessage |
JmsMessageDispatcher.doSend(UMOEvent event)
|
protected UMOMessage |
JmsMessageDispatcher.doReceive(UMOImmutableEndpoint endpoint,
long timeout)
Make a specific request to the underlying transport |
| Methods in org.mule.providers.jms with parameters of type UMOMessage | |
void |
JmsReplyToHandler.processReplyTo(UMOEvent event,
UMOMessage returnMessage,
Object replyTo)
|
| Uses of UMOMessage in org.mule.providers.jms.filters |
| Methods in org.mule.providers.jms.filters with parameters of type UMOMessage | |
boolean |
JmsSelectorFilter.accept(UMOMessage message)
|
boolean |
JmsPropertyFilter.accept(UMOMessage message)
|
| Uses of UMOMessage in org.mule.providers.jms.transformers |
| Methods in org.mule.providers.jms.transformers with parameters of type UMOMessage | |
protected void |
AbstractJmsTransformer.setJmsProperties(UMOMessage umoMessage,
Message msg)
|
| Uses of UMOMessage in org.mule.providers.oracle.jms |
| Methods in org.mule.providers.oracle.jms that return UMOMessage | |
protected UMOMessage |
OracleJmsMessageDispatcher.doReceive(UMOImmutableEndpoint endpoint,
long timeout)
Make a specific request to the underlying transport Save a copy of the endpoint's properties within the OracleJmsSupport object. |
| Uses of UMOMessage in org.mule.providers.quartz |
| Methods in org.mule.providers.quartz that return UMOMessage | |
protected UMOMessage |
QuartzMessageDispatcher.doSend(UMOEvent event)
|
protected UMOMessage |
QuartzMessageDispatcher.doReceive(UMOImmutableEndpoint endpoint,
long timeout)
Make a specific request to the underlying transport |
| Uses of UMOMessage in org.mule.providers.rmi |
| Methods in org.mule.providers.rmi that return UMOMessage | |
UMOMessage |
RmiMessageDispatcher.doSend(UMOEvent event)
|
protected UMOMessage |
RmiMessageDispatcher.doReceive(UMOImmutableEndpoint endpoint,
long timeout)
Make a specific request to the underlying transport |
| Uses of UMOMessage in org.mule.providers.soap.axis |
| Methods in org.mule.providers.soap.axis that return UMOMessage | |
protected UMOMessage |
AxisMessageDispatcher.doSend(UMOEvent event)
|
protected UMOMessage |
AxisMessageDispatcher.doReceive(UMOImmutableEndpoint endpoint,
long timeout)
Make a specific request to the underlying transport |
UMOMessage |
AxisMessageDispatcher.receive(String endpoint,
Object[] args)
|
protected UMOMessage |
AxisMessageDispatcher.createMessage(Object result,
Call call)
|
| Methods in org.mule.providers.soap.axis with parameters of type UMOMessage | |
protected void |
AxisMessageDispatcher.setMessageContextProperties(UMOMessage message,
MessageContext ctx)
|
protected void |
AxisMessageDispatcher.setMessageContextAttachments(UMOMessage message,
MessageContext ctx)
|
| Uses of UMOMessage in org.mule.providers.soap.glue |
| Methods in org.mule.providers.soap.glue that return UMOMessage | |
protected UMOMessage |
GlueMessageDispatcher.doSend(UMOEvent event)
|
protected UMOMessage |
GlueMessageDispatcher.doReceive(UMOImmutableEndpoint endpoint,
long timeout)
Make a specific request to the underlying transport |
| Uses of UMOMessage in org.mule.providers.soap.xfire |
| Methods in org.mule.providers.soap.xfire that return UMOMessage | |
protected UMOMessage |
XFireMessageDispatcher.doSend(UMOEvent event)
|
protected UMOMessage |
XFireMessageDispatcher.doReceive(UMOImmutableEndpoint endpoint,
long timeout)
Make a specific request to the underlying transport |
| Uses of UMOMessage in org.mule.providers.space |
| Methods in org.mule.providers.space that return UMOMessage | |
protected UMOMessage |
SpaceMessageDispatcher.doSend(UMOEvent event)
|
protected UMOMessage |
SpaceMessageDispatcher.doReceive(UMOImmutableEndpoint endpoint,
long timeout)
Make a specific request to the underlying transport |
| Uses of UMOMessage in org.mule.providers.stream |
| Methods in org.mule.providers.stream that return UMOMessage | |
protected UMOMessage |
StreamMessageDispatcher.doSend(UMOEvent event)
|
protected UMOMessage |
StreamMessageDispatcher.doReceive(UMOImmutableEndpoint endpoint,
long timeout)
Make a specific request to the underlying transport |
| Uses of UMOMessage in org.mule.providers.tcp |
| Methods in org.mule.providers.tcp that return UMOMessage | |
protected UMOMessage |
TcpMessageDispatcher.doSend(UMOEvent event)
|
protected UMOMessage |
TcpMessageDispatcher.doReceive(UMOImmutableEndpoint endpoint,
long timeout)
Make a specific request to the underlying transport |
| Methods in org.mule.providers.tcp with parameters of type UMOMessage | |
OutputStream |
TcpMessageDispatcher.getOutputStream(UMOImmutableEndpoint endpoint,
UMOMessage message)
Well get the output stream (if any) for this type of transport. |
| Uses of UMOMessage in org.mule.providers.udp |
| Methods in org.mule.providers.udp that return UMOMessage | |
protected UMOMessage |
UdpMessageDispatcher.doSend(UMOEvent event)
|
protected UMOMessage |
UdpMessageDispatcher.doReceive(UMOImmutableEndpoint endpoint,
long timeout)
Make a specific request to the underlying transport |
| Uses of UMOMessage in org.mule.providers.vm |
| Methods in org.mule.providers.vm that return UMOMessage | |
protected UMOMessage |
VMMessageDispatcher.doReceive(UMOImmutableEndpoint endpoint,
long timeout)
Make a specific request to the underlying transport |
protected UMOMessage |
VMMessageDispatcher.doSend(UMOEvent event)
|
| Constructors in org.mule.providers.vm with parameters of type UMOMessage | |
VMMessageAdapter(UMOMessage message)
|
|
| Uses of UMOMessage in org.mule.providers.xmpp |
| Methods in org.mule.providers.xmpp that return UMOMessage | |
protected UMOMessage |
XmppMessageDispatcher.doSend(UMOEvent event)
|
protected UMOMessage |
XmppMessageDispatcher.doReceive(UMOImmutableEndpoint endpoint,
long timeout)
Make a specific request to the underlying transport |
| Uses of UMOMessage in org.mule.ra |
| Methods in org.mule.ra that return UMOMessage | |
UMOMessage |
JcaComponent.sendEvent(UMOEvent event)
This is the synchronous call method and not supported by components managed in a JCA container |
UMOMessage |
MuleConnection.receive(String url,
long timeout)
|
UMOMessage |
MuleConnection.send(String url,
Object payload,
Map messageProperties)
|
UMOMessage |
DefaultMuleConnection.send(String url,
Object payload,
Map messageProperties)
Sends an object (payload) synchronous to the given url and returns a UMOMessage response back. |
UMOMessage |
DefaultMuleConnection.receive(String url,
long timeout)
Will receive an event from an endpointUri determined by the url |
| Methods in org.mule.ra with parameters of type UMOMessage | |
protected UMOEvent |
DefaultMuleConnection.getEvent(UMOMessage message,
UMOEndpointURI uri,
boolean synchronous)
Packages a mule event for the current request |
| Uses of UMOMessage in org.mule.routing |
| Methods in org.mule.routing that return UMOMessage | |
UMOMessage |
ComponentCatchAllStrategy.catchMessage(UMOMessage message,
UMOSession session,
boolean synchronous)
|
UMOMessage |
ForwardingCatchAllStrategy.catchMessage(UMOMessage message,
UMOSession session,
boolean synchronous)
|
UMOMessage |
LoggingCatchAllStrategy.catchMessage(UMOMessage message,
UMOSession session,
boolean synchronous)
|
| Methods in org.mule.routing with parameters of type UMOMessage | |
String |
CorrelationPropertiesExtractor.getMessageId(UMOMessage message)
|
String |
CorrelationPropertiesExtractor.getCorrelationId(UMOMessage message)
|
UMOMessage |
ComponentCatchAllStrategy.catchMessage(UMOMessage message,
UMOSession session,
boolean synchronous)
|
UMOMessage |
ForwardingCatchAllStrategy.catchMessage(UMOMessage message,
UMOSession session,
boolean synchronous)
|
UMOMessage |
LoggingCatchAllStrategy.catchMessage(UMOMessage message,
UMOSession session,
boolean synchronous)
|
| Uses of UMOMessage in org.mule.routing.filters |
| Methods in org.mule.routing.filters with parameters of type UMOMessage | |
boolean |
MessagePropertyFilter.accept(UMOMessage message)
|
boolean |
WildcardFilter.accept(UMOMessage message)
|
boolean |
EqualsFilter.accept(UMOMessage message)
|
boolean |
RegExFilter.accept(UMOMessage message)
|
boolean |
PayloadTypeFilter.accept(UMOMessage message)
|
boolean |
ExceptionTypeFilter.accept(UMOMessage message)
Check a given message against this filter. |
boolean |
OGNLFilter.accept(UMOMessage message)
|
| Uses of UMOMessage in org.mule.routing.filters.logic |
| Methods in org.mule.routing.filters.logic with parameters of type UMOMessage | |
boolean |
NotFilter.accept(UMOMessage message)
|
boolean |
OrFilter.accept(UMOMessage message)
|
boolean |
AndFilter.accept(UMOMessage message)
|
| Uses of UMOMessage in org.mule.routing.filters.xml |
| Methods in org.mule.routing.filters.xml with parameters of type UMOMessage | |
boolean |
JXPathFilter.accept(UMOMessage obj)
|
boolean |
IsXmlFilter.accept(UMOMessage obj)
|
| Uses of UMOMessage in org.mule.routing.inbound |
| Methods in org.mule.routing.inbound that return UMOMessage | |
UMOMessage |
InboundMessageRouter.route(UMOEvent event)
|
UMOMessage |
InboundMessageRouter.send(UMOEvent event)
|
protected abstract UMOMessage |
AbstractEventAggregator.aggregateEvents(EventGroup events)
This method is invoked if the shouldAggregate method is called and returns true. |
protected UMOMessage |
MessageChunkingAggregator.aggregateEvents(EventGroup events)
This method is invoked if the shouldAggregate method is called and returns true. |
| Uses of UMOMessage in org.mule.routing.outbound |
| Methods in org.mule.routing.outbound that return UMOMessage | |
UMOMessage |
OutboundPassThroughRouter.route(UMOMessage message,
UMOSession session,
boolean synchronous)
|
UMOMessage |
AbstractMessageSplitter.route(UMOMessage message,
UMOSession session,
boolean synchronous)
|
protected abstract UMOMessage |
AbstractMessageSplitter.getMessagePart(UMOMessage message,
UMOEndpoint endpoint)
Retrieves a specific message part for the given endpoint. |
UMOMessage |
ChainingRouter.route(UMOMessage message,
UMOSession session,
boolean synchronous)
|
UMOMessage |
EndpointSelector.route(UMOMessage message,
UMOSession session,
boolean synchronous)
|
UMOMessage |
AbstractRecipientList.route(UMOMessage message,
UMOSession session,
boolean synchronous)
|
UMOMessage |
AbstractOutboundRouter.send(UMOSession session,
UMOMessage message,
UMOEndpoint endpoint)
|
UMOMessage |
FilteringOutboundRouter.route(UMOMessage message,
UMOSession session,
boolean synchronous)
|
UMOMessage |
MulticastingRouter.route(UMOMessage message,
UMOSession session,
boolean synchronous)
|
UMOMessage |
OutboundMessageRouter.route(UMOMessage message,
UMOSession session,
boolean synchronous)
|
protected UMOMessage |
OutboundMessageRouter.catchAll(UMOMessage message,
UMOSession session,
boolean synchronous)
|
protected UMOMessage |
FilteringListMessageSplitter.getMessagePart(UMOMessage message,
UMOEndpoint endpoint)
|
UMOMessage |
MessageChunkingRouter.route(UMOMessage message,
UMOSession session,
boolean synchronous)
|
UMOMessage |
TemplateEndpointRouter.route(UMOMessage message,
UMOSession session,
boolean synchronous)
|
UMOMessage |
ExceptionBasedRouter.route(UMOMessage message,
UMOSession session,
boolean synchronous)
|
protected UMOMessage |
FilteringXmlMessageSplitter.getMessagePart(UMOMessage message,
UMOEndpoint endpoint)
Retrieves a specific message part for the given endpoint. |
UMOMessage |
RoundRobinXmlSplitter.route(UMOMessage message,
UMOSession session,
boolean synchronous)
|
| Methods in org.mule.routing.outbound with parameters of type UMOMessage | |
UMOMessage |
OutboundPassThroughRouter.route(UMOMessage message,
UMOSession session,
boolean synchronous)
|
UMOMessage |
AbstractMessageSplitter.route(UMOMessage message,
UMOSession session,
boolean synchronous)
|
protected void |
AbstractMessageSplitter.initialise(UMOMessage message)
Template method that can be used to split the message up before the getMessagePart method is called . |
protected abstract UMOMessage |
AbstractMessageSplitter.getMessagePart(UMOMessage message,
UMOEndpoint endpoint)
Retrieves a specific message part for the given endpoint. |
UMOMessage |
ChainingRouter.route(UMOMessage message,
UMOSession session,
boolean synchronous)
|
protected void |
ChainingRouter.processIntermediaryResult(UMOMessage localResult,
UMOMessage intermediaryResult)
Process intermediary result of invocation. |
UMOMessage |
EndpointSelector.route(UMOMessage message,
UMOSession session,
boolean synchronous)
|
UMOMessage |
AbstractRecipientList.route(UMOMessage message,
UMOSession session,
boolean synchronous)
|
protected UMOEndpoint |
AbstractRecipientList.getRecipientEndpoint(UMOMessage message,
String recipient)
|
protected abstract List |
AbstractRecipientList.getRecipients(UMOMessage message)
|
void |
AbstractOutboundRouter.dispatch(UMOSession session,
UMOMessage message,
UMOEndpoint endpoint)
|
UMOMessage |
AbstractOutboundRouter.send(UMOSession session,
UMOMessage message,
UMOEndpoint endpoint)
|
protected void |
AbstractOutboundRouter.setMessageProperties(UMOSession session,
UMOMessage message,
UMOEndpoint endpoint)
|
UMOMessage |
FilteringOutboundRouter.route(UMOMessage message,
UMOSession session,
boolean synchronous)
|
boolean |
FilteringOutboundRouter.isMatch(UMOMessage message)
|
UMOEndpoint |
FilteringOutboundRouter.getEndpoint(int index,
UMOMessage message)
Will Return the endpont at the given index and will resolve any template tags on the Endpoint URI if necessary |
UMOMessage |
MulticastingRouter.route(UMOMessage message,
UMOSession session,
boolean synchronous)
|
UMOMessage |
OutboundMessageRouter.route(UMOMessage message,
UMOSession session,
boolean synchronous)
|
UMOEndpoint[] |
OutboundMessageRouter.getEndpointsForMessage(UMOMessage message)
A helper method for finding out which endpoints a message would be routed to without actually routing the the message |
protected UMOMessage |
OutboundMessageRouter.catchAll(UMOMessage message,
UMOSession session,
boolean synchronous)
|
protected List |
StaticRecipientList.getRecipients(UMOMessage message)
|
protected void |
FilteringListMessageSplitter.initialise(UMOMessage message)
Template method can be used to split the message up before the getMessagePart method is called . |
protected UMOMessage |
FilteringListMessageSplitter.getMessagePart(UMOMessage message,
UMOEndpoint endpoint)
|
UMOMessage |
MessageChunkingRouter.route(UMOMessage message,
UMOSession session,
boolean synchronous)
|
UMOMessage |
TemplateEndpointRouter.route(UMOMessage message,
UMOSession session,
boolean synchronous)
|
UMOMessage |
ExceptionBasedRouter.route(UMOMessage message,
UMOSession session,
boolean synchronous)
|
protected boolean |
ExceptionBasedRouter.exceptionPayloadAvailable(UMOMessage message)
|
protected void |
FilteringXmlMessageSplitter.initialise(UMOMessage message)
Template method can be used to split the message up before the getMessagePart method is called . |
protected UMOMessage |
FilteringXmlMessageSplitter.getMessagePart(UMOMessage message,
UMOEndpoint endpoint)
Retrieves a specific message part for the given endpoint. |
UMOMessage |
RoundRobinXmlSplitter.route(UMOMessage message,
UMOSession session,
boolean synchronous)
|
protected UMOEndpoint |
RoundRobinXmlSplitter.getEndpointForMessage(UMOMessage message)
Retrieves a specific message part for the given endpoint. |
| Uses of UMOMessage in org.mule.routing.response |
| Methods in org.mule.routing.response that return UMOMessage | |
UMOMessage |
AbstractResponseAggregator.getResponse(UMOMessage message)
This method is called by the responding callee thread and should return the aggregated response message |
protected abstract UMOMessage |
AbstractResponseAggregator.aggregateEvents(EventGroup events)
This method is invoked if the shouldAggregate method is called and returns true. |
protected UMOMessage |
SingleResponseRouter.aggregateEvents(EventGroup events)
This method is invoked if the shouldAggregate method is called and returns true. |
UMOMessage |
ResponseMessageRouter.getResponse(UMOMessage message)
|
| Methods in org.mule.routing.response with parameters of type UMOMessage | |
UMOMessage |
AbstractResponseAggregator.getResponse(UMOMessage message)
This method is called by the responding callee thread and should return the aggregated response message |
protected Object |
AbstractResponseRouter.getReplyAggregateIdentifier(UMOMessage message)
Extracts a 'Correlation Id' from a reply message. |
protected Object |
AbstractResponseRouter.getCallResponseAggregateIdentifier(UMOMessage message)
Extracts a Group identifier from the current event. |
UMOMessage |
ResponseMessageRouter.getResponse(UMOMessage message)
|
| Uses of UMOMessage in org.mule.samples.loanbroker |
| Methods in org.mule.samples.loanbroker that return UMOMessage | |
UMOMessage |
SyncLoanBroker.getLoanQuote(LoanRequest request)
|
| Uses of UMOMessage in org.mule.samples.loanbroker.esb |
| Methods in org.mule.samples.loanbroker.esb that return UMOMessage | |
UMOMessage |
Main.request(CustomerQuoteRequest request)
|
| Uses of UMOMessage in org.mule.samples.loanbroker.esb.routers |
| Methods in org.mule.samples.loanbroker.esb.routers that return UMOMessage | |
protected UMOMessage |
BankQuotesResponseAggregator.aggregateEvents(EventGroup events)
This method is invoked if the shouldAggregate method is called and returns true. |
| Uses of UMOMessage in org.mule.samples.loanbroker.routers |
| Methods in org.mule.samples.loanbroker.routers that return UMOMessage | |
protected UMOMessage |
BankQuotesAggregator.aggregateEvents(EventGroup events)
This method is invoked if the shouldAggregate method is called and returns true. |
protected UMOMessage |
BankQuotesResponseAggregator.aggregateEvents(EventGroup events)
This method is invoked if the shouldAggregate method is called and returns true. |
| Uses of UMOMessage in org.mule.samples.voipservice.routers |
| Methods in org.mule.samples.voipservice.routers that return UMOMessage | |
protected UMOMessage |
PaymentValidationResponseAggregator.aggregateEvents(EventGroup events)
|
| Uses of UMOMessage in org.mule.samples.voipservice.service |
| Methods in org.mule.samples.voipservice.service that return UMOMessage | |
UMOMessage |
SyncVoipBroker.validate(ServiceParamTO serviceParamTO)
|
| Uses of UMOMessage in org.mule.tck.testmodels.mule |
| Methods in org.mule.tck.testmodels.mule that return UMOMessage | |
protected UMOMessage |
TestResponseAggregator.aggregateEvents(EventGroup events)
This method is invoked if the shouldAggregate method is called and returns true. |
protected UMOMessage |
TestMessageDispatcher.doSend(UMOEvent event)
|
UMOMessage |
TestMessageDispatcher.doReceive(UMOImmutableEndpoint endpoint,
long timeout)
|
UMOMessage |
TestCatchAllStrategy.catchMessage(UMOMessage message,
UMOSession session,
boolean synchronous)
|
| Methods in org.mule.tck.testmodels.mule with parameters of type UMOMessage | |
UMOMessage |
TestCatchAllStrategy.catchMessage(UMOMessage message,
UMOSession session,
boolean synchronous)
|
| Uses of UMOMessage in org.mule.test.usecases.service |
| Methods in org.mule.test.usecases.service that return UMOMessage | |
protected UMOMessage |
DummyResponseAggregator.aggregateEvents(EventGroup events)
|
| Uses of UMOMessage in org.mule.umo |
| Fields in org.mule.umo declared as UMOMessage | |
protected UMOMessage |
MessagingException.umoMessage
The UMOMessage being processed when the error occurred |
| Methods in org.mule.umo that return UMOMessage | |
UMOMessage |
UMOEvent.getMessage()
Returns the message payload for this event |
UMOMessage |
UMOSession.sendEvent(UMOMessage message)
This will send an event via the configured outbound endpoint on the component for this session |
UMOMessage |
UMOSession.sendEvent(UMOEvent event)
Depending on the session state this methods either Passes an event synchronously to the next available Mule UMO in the pool or via the endpoint configured for the event |
UMOMessage |
UMOSession.sendEvent(UMOMessage message,
UMOImmutableEndpoint endpoint)
Depending on the session state this methods either Passes an event synchronously to the next available Mule UMO in the pool or via the endpoint configured for the event |
UMOMessage |
UMOSession.sendEvent(UMOMessage message,
String endpointName)
Depending on the session state this methods either Passes an event synchronously to the next available Mule UMO in the pool or via the endpoint configured for the event |
UMOMessage |
UMOSession.receiveEvent(UMOImmutableEndpoint endpoint,
long timeout)
Requests a synchronous receive of an event on the component |
UMOMessage |
UMOSession.receiveEvent(String endpointName,
long timeout)
Requests a synchronous receive of an event on the component |
UMOMessage |
UMOEventContext.getMessage()
Returns the message payload for this event |
UMOMessage |
UMOEventContext.sendEvent(Object message)
This will send an event via the configured outbound router on the component |
UMOMessage |
UMOEventContext.sendEvent(UMOMessage message)
Depending on the session state this methods either Passes an event synchronously to the next available Mule UMO in the pool or via the endpoint configured for the event |
UMOMessage |
UMOEventContext.sendEvent(UMOMessage message,
UMOEndpointURI endpoint)
Depending on the session state this methods either Passes an event synchronously to the next available Mule UMO in the pool or via the endpoint configured for the event |
UMOMessage |
UMOEventContext.sendEvent(UMOMessage message,
String endpointName)
Depending on the session state this methods either Passes an event synchronously to the next available Mule UMO in the pool or via the endpoint configured for the event |
UMOMessage |
UMOEventContext.sendEvent(UMOMessage message,
UMOEndpoint endpoint)
Depending on the session state this methods either Passes an event synchronously to the next available Mule UMO in the pool or via the endpoint configured for the event |
UMOMessage |
UMOEventContext.receiveEvent(UMOEndpoint endpoint,
long timeout)
Requests a synchronous receive of an event on the component |
UMOMessage |
UMOEventContext.receiveEvent(String endpointName,
long timeout)
Requests a synchronous receive of an event on the component |
UMOMessage |
UMOEventContext.receiveEvent(UMOEndpointURI endpoint,
long timeout)
Requests a synchronous receive of an event on the component |
UMOMessage |
Invocation.execute()
Excutes this invocation |
UMOMessage |
Invocation.getMessage()
Returns the current message |
UMOMessage |
FutureMessageResult.getMessage()
|
UMOMessage |
FutureMessageResult.getMessage(long timeout)
|
UMOMessage |
UMOInterceptor.intercept(Invocation invocation)
Invoked by the previous interceptor in the chain |
UMOMessage |
UMOComponent.sendEvent(UMOEvent event)
Makes a synhronous event call to the component. |
UMOMessage |
MessagingException.getUmoMessage()
|
| Methods in org.mule.umo with parameters of type UMOMessage | |
UMOMessage |
UMOSession.sendEvent(UMOMessage message)
This will send an event via the configured outbound endpoint on the component for this session |
UMOMessage |
UMOSession.sendEvent(UMOMessage message,
UMOImmutableEndpoint endpoint)
Depending on the session state this methods either Passes an event synchronously to the next available Mule UMO in the pool or via the endpoint configured for the event |
UMOMessage |
UMOSession.sendEvent(UMOMessage message,
String endpointName)
Depending on the session state this methods either Passes an event synchronously to the next available Mule UMO in the pool or via the endpoint configured for the event |
void |
UMOSession.dispatchEvent(UMOMessage message)
This will dispatch an event asynchronously via the configured outbound endpoint on the component for this session |
void |
UMOSession.dispatchEvent(UMOMessage message,
UMOImmutableEndpoint endpoint)
Depending on the session state this methods either Passes an event asynchronously to the next available Mule UMO in the pool or via the endpoint configured for the event |
void |
UMOSession.dispatchEvent(UMOMessage message,
String endpointName)
Depending on the session state this methods either Passes an event asynchronously to the next available Mule UMO in the pool or via the endpoint configured for the event |
UMOEvent |
UMOSession.createOutboundEvent(UMOMessage message,
UMOImmutableEndpoint endpoint,
UMOEvent previousEvent)
Creates an outbound event for this session |
boolean |
UMOFilter.accept(UMOMessage message)
Check a given message against this filter. |
UMOMessage |
UMOEventContext.sendEvent(UMOMessage message)
Depending on the session state this methods either Passes an event synchronously to the next available Mule UMO in the pool or via the endpoint configured for the event |
UMOMessage |
UMOEventContext.sendEvent(UMOMessage message,
UMOEndpointURI endpoint)
Depending on the session state this methods either Passes an event synchronously to the next available Mule UMO in the pool or via the endpoint configured for the event |
UMOMessage |
UMOEventContext.sendEvent(UMOMessage message,
String endpointName)
Depending on the session state this methods either Passes an event synchronously to the next available Mule UMO in the pool or via the endpoint configured for the event |
UMOMessage |
UMOEventContext.sendEvent(UMOMessage message,
UMOEndpoint endpoint)
Depending on the session state this methods either Passes an event synchronously to the next available Mule UMO in the pool or via the endpoint configured for the event |
FutureMessageResult |
UMOEventContext.sendEventAsync(UMOMessage message,
int timeout)
sends an event request via the configured outbound router for this component. |
FutureMessageResult |
UMOEventContext.sendEventAsync(UMOMessage message,
UMOEndpointURI endpoint,
int timeout)
sends an event request via the configured outbound router for this component. |
FutureMessageResult |
UMOEventContext.sendEventAsync(UMOMessage message,
String endpointName,
int timeout)
sends an event request via the configured outbound router for this component. |
void |
UMOEventContext.dispatchEvent(UMOMessage message)
This will dispatch an event asynchronously via the configured outbound endpoint on the component for this session |
void |
UMOEventContext.dispatchEvent(UMOMessage message,
UMOEndpointURI endpoint)
Depending on the session state this methods either Passes an event asynchronously to the next available Mule UMO in the pool or via the endpoint configured for the event |
void |
UMOEventContext.dispatchEvent(UMOMessage message,
String endpointName)
Depending on the session state this methods either Passes an event asynchronously to the next available Mule UMO in the pool or via the endpoint configured for the event |
void |
UMOEventContext.dispatchEvent(UMOMessage message,
UMOEndpoint endpoint)
Depending on the session state this methods either Passes an event asynchronously to the next available Mule UMO in the pool or via the endpoint configured for the event |
void |
Invocation.setMessage(UMOMessage message)
|
| Constructors in org.mule.umo with parameters of type UMOMessage | |
Invocation(UMOImmutableDescriptor descriptor,
UMOMessage message,
Invocation invocation)
Constructs an initialised invocation |
|
ComponentException(Message message,
UMOMessage umoMessage,
UMOComponent component)
|
|
ComponentException(Message message,
UMOMessage umoMessage,
UMOComponent component,
Throwable cause)
|
|
ComponentException(UMOMessage umoMessage,
UMOComponent component,
Throwable cause)
|
|
MessagingException(Message message,
UMOMessage umoMessage)
|
|
MessagingException(Message message,
UMOMessage umoMessage,
Throwable cause)
|
|
| Uses of UMOMessage in org.mule.umo.provider |
| Methods in org.mule.umo.provider that return UMOMessage | |
UMOMessage |
UMOMessageDispatcher.send(UMOEvent event)
Sends an event from the endpoint to the external system |
UMOMessage |
UMOMessageDispatcher.receive(UMOEndpointURI endpointUri,
long timeout)
Deprecated. Use receive(UMOImmutableEndpoint endpoint, long timeout) |
UMOMessage |
UMOMessageDispatcher.receive(UMOImmutableEndpoint endpoint,
long timeout)
Make a specific request to the underlying transport |
| Methods in org.mule.umo.provider with parameters of type UMOMessage | |
OutputStream |
UMOMessageDispatcher.getOutputStream(UMOImmutableEndpoint endpoint,
UMOMessage message)
Well get the output stream (if any) for this type of transport. |
void |
UMOSessionHandler.storeSessionInfoToMessage(UMOSession session,
UMOMessage message)
|
void |
UMOSessionHandler.retrieveSessionInfoFromMessage(UMOMessage message,
UMOSession session)
|
| Constructors in org.mule.umo.provider with parameters of type UMOMessage | |
DispatchException(UMOMessage message,
UMOImmutableEndpoint endpoint)
|
|
DispatchException(UMOMessage umoMessage,
UMOImmutableEndpoint endpoint,
Throwable cause)
|
|
DispatchException(Message message,
UMOMessage umoMessage,
UMOImmutableEndpoint endpoint)
|
|
DispatchException(Message message,
UMOMessage umoMessage,
UMOImmutableEndpoint endpoint,
Throwable cause)
|
|
| Uses of UMOMessage in org.mule.umo.routing |
| Methods in org.mule.umo.routing that return UMOMessage | |
UMOMessage |
UMORouterCatchAllStrategy.catchMessage(UMOMessage message,
UMOSession session,
boolean synchronous)
|
UMOMessage |
UMOResponseRouter.getResponse(UMOMessage message)
Called by the Mule framework once the outbound router has been processed on a component the Message passed in is the response message from the component (or outbount router if a response was returned). |
UMOMessage |
UMOOutboundRouter.route(UMOMessage message,
UMOSession session,
boolean synchronous)
This method is responsible for routing the Message via the Session. |
UMOMessage |
UMOResponseMessageRouter.getResponse(UMOMessage message)
|
UMOMessage |
UMOInboundMessageRouter.route(UMOEvent event)
|
UMOMessage |
UMOOutboundMessageRouter.route(UMOMessage message,
UMOSession session,
boolean synchronous)
Prepares one or more events to be dispached by a Message Dispatcher |
| Methods in org.mule.umo.routing with parameters of type UMOMessage | |
UMOMessage |
UMORouterCatchAllStrategy.catchMessage(UMOMessage message,
UMOSession session,
boolean synchronous)
|
UMOMessage |
UMOResponseRouter.getResponse(UMOMessage message)
Called by the Mule framework once the outbound router has been processed on a component the Message passed in is the response message from the component (or outbount router if a response was returned). |
UMOMessage |
UMOOutboundRouter.route(UMOMessage message,
UMOSession session,
boolean synchronous)
This method is responsible for routing the Message via the Session. |
boolean |
UMOOutboundRouter.isMatch(UMOMessage message)
Determines if the event should be processed by this router. |
UMOMessage |
UMOResponseMessageRouter.getResponse(UMOMessage message)
|
UMOMessage |
UMOOutboundMessageRouter.route(UMOMessage message,
UMOSession session,
boolean synchronous)
Prepares one or more events to be dispached by a Message Dispatcher |
UMOEndpoint[] |
UMOOutboundMessageRouter.getEndpointsForMessage(UMOMessage message)
A helper method for finding out which endpoints a message would be routed to without actually routing the the message |
| Uses of UMOMessage in org.mule.umo.security |
|
|||||||||||
| PREV NEXT | FRAMES NO FRAMES | ||||||||||