Package | Description |
---|---|
org.mule |
The Mule implementation of the Universal Message Objects(tm) API specification.
|
org.mule.agent |
Admin components and Agents used to control and Monitor Mule
|
org.mule.api |
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.api.component | |
org.mule.api.config | |
org.mule.api.context |
Manager APIs, including the UMOManager, agent and server event interfaces
|
org.mule.api.endpoint |
Endpoint interfaces.
|
org.mule.api.interceptor | |
org.mule.api.lifecycle |
Lifecycle interfaces for all UMOcomponents.
|
org.mule.api.model |
Contains the interfaces for the Model and supporting objects such as the CompoenntResolver, EntryPointResolver, etc.
|
org.mule.api.registry | |
org.mule.api.routing |
Interfaces that define inbound and outbound routing API.
|
org.mule.api.security |
Security API for authentication and authorisation.
|
org.mule.api.service | |
org.mule.api.transaction | |
org.mule.api.transformer |
Contains the interfaces for transformers and exceptions for the UMO Transformer API.
|
org.mule.api.transformer.wire | |
org.mule.api.transport |
Contains the interfaces that comprise a provider implementation.
|
org.mule.component | |
org.mule.component.builder | |
org.mule.config |
Providers Mule Xml configuration support and general configuration classes.
|
org.mule.config.bootstrap | |
org.mule.config.spring |
Support claases for Load Mule from Spring.
|
org.mule.context.notification |
Internal server notification types fired via the MuleManager.
|
org.mule.endpoint |
Implemtation of Mule endpoint uris.
|
org.mule.interceptor | |
org.mule.lifecycle | |
org.mule.lifecycle.phases | |
org.mule.model | |
org.mule.model.direct | |
org.mule.model.pipeline | |
org.mule.model.resolvers | |
org.mule.model.seda | |
org.mule.module.client |
Simple interface for Mule clients to send and receive events from local or remote Mule Servers.
|
org.mule.module.client.remoting | |
org.mule.module.management |
Mule system management extensions such as Jmx support.
|
org.mule.module.management.agent |
Management agents including agents for Jdmk, MX4J, and Log4J
|
org.mule.module.management.mbean |
Jmx Management beans for mule components, the model and the Mule server.
|
org.mule.registry | |
org.mule.routing |
Defines the core routing patterns supported by mule.
|
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.service | |
org.mule.transaction |
Contains the core transaction support classes and exception types.
|
org.mule.transformer.wire | |
org.mule.transport |
Contains Abstract classes providing common functionality for all Mule providers.
|
org.mule.transport.bpm | |
org.mule.transport.ejb | |
org.mule.transport.http |
Provides http transport including proxy support.
|
org.mule.transport.http.components | |
org.mule.transport.jms |
Provides Jms transport connectivity with support for all Jms features.
|
org.mule.transport.quartz | |
org.mule.transport.rmi | |
org.mule.transport.service |
Provides SPI support for building mule connectors and providers using service descriptors.
|
org.mule.transport.servlet | |
org.mule.transport.stdio | |
org.mule.transport.tcp |
Provides tcp connectivity for Mule.
|
org.mule.transport.udp |
Provides Udp connectivity for Mule.
|
org.mule.transport.vm |
A connector implementation allowing events to be passed between Mule sessions via in-memory queues.
|
org.mule.util.pool | |
org.mule.util.xa |
An abstract resource manager that supports local and xa transactions.
|
org.mule.work |
A javax.resource.spi.WorkManager implementation.
|
Modifier and Type | Class and Description |
---|---|
class |
FailedToQueueEventException
FailedToQueueEventException is thrown when an event cannot be put
on an internal service queue. |
Modifier and Type | Method and Description |
---|---|
void |
DefaultMuleContext.applyLifecycle(Object object)
Apply current phase of the LifecycleManager.
|
MuleEvent |
DefaultMuleSession.createOutboundEvent(MuleMessage message,
OutboundEndpoint endpoint,
MuleEvent previousEvent) |
void |
DefaultMuleSession.dispatchEvent(MuleEvent event) |
void |
DefaultMuleEventContext.dispatchEvent(MuleMessage message)
This will dispatch an event asynchronously via the configured outbound
endpoint on the service for this session
|
void |
DefaultMuleSession.dispatchEvent(MuleMessage message) |
void |
DefaultMuleEventContext.dispatchEvent(MuleMessage message,
EndpointURI 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 |
DefaultMuleEventContext.dispatchEvent(MuleMessage message,
OutboundEndpoint 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 |
DefaultMuleSession.dispatchEvent(MuleMessage message,
OutboundEndpoint endpoint) |
void |
DefaultMuleEventContext.dispatchEvent(MuleMessage 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 |
DefaultMuleSession.dispatchEvent(MuleMessage message,
String endpointName) |
void |
DefaultMuleEventContext.dispatchEvent(Object message)
This will dispatch an event asynchronously via the configured outbound
endpoint on the service for this session
|
byte[] |
DefaultMuleEventContext.getMessageAsBytes()
Reterns the conents of the message as a byte array.
|
String |
DefaultMuleEventContext.getMessageAsString()
Returns the message contents as a string This method will use the default
encoding on the event
|
String |
DefaultMuleEvent.getMessageAsString() |
String |
DefaultMuleEventContext.getMessageAsString(String encoding)
Returns the message contents as a string
|
String |
DefaultMuleEvent.getMessageAsString(String encoding)
Returns the message contents as a string
|
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 |
DefaultMuleSession.requestEvent(InboundEndpoint endpoint,
long timeout) |
MuleMessage |
DefaultMuleEventContext.requestEvent(String endpointName,
long timeout)
Requests a synchronous receive of an event on the service
|
MuleMessage |
DefaultMuleSession.requestEvent(String endpointName,
long timeout) |
void |
MuleSessionHandler.retrieveSessionInfoFromMessage(MuleMessage message,
MuleSession session) |
void |
NullSessionHandler.retrieveSessionInfoFromMessage(MuleMessage message,
MuleSession session) |
MuleMessage |
DefaultMuleSession.sendEvent(MuleEvent event) |
MuleMessage |
DefaultMuleEventContext.sendEvent(MuleMessage 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
|
MuleMessage |
DefaultMuleSession.sendEvent(MuleMessage message) |
MuleMessage |
DefaultMuleEventContext.sendEvent(MuleMessage message,
EndpointURI 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
|
MuleMessage |
DefaultMuleEventContext.sendEvent(MuleMessage message,
OutboundEndpoint 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
|
MuleMessage |
DefaultMuleSession.sendEvent(MuleMessage message,
OutboundEndpoint endpoint) |
MuleMessage |
DefaultMuleEventContext.sendEvent(MuleMessage 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
|
MuleMessage |
DefaultMuleSession.sendEvent(MuleMessage message,
String endpointName) |
MuleMessage |
DefaultMuleEventContext.sendEvent(Object message)
This will send an event via the configured outbound router on the service
|
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.
|
FutureMessageResult |
DefaultMuleEventContext.sendEventAsync(Object message,
int timeout)
sends an event request via the configured outbound router for this service.
|
void |
DefaultMuleContext.start() |
void |
DefaultMuleContext.stop()
Stops the
MuleManager which stops all sessions and
connectors |
void |
MuleSessionHandler.storeSessionInfoToMessage(MuleSession session,
MuleMessage message) |
void |
NullSessionHandler.storeSessionInfoToMessage(MuleSession session,
MuleMessage message) |
Constructor and Description |
---|
DefaultMuleSession(MuleMessage message,
SessionHandler requestSessionHandler,
MuleContext muleContext) |
DefaultMuleSession(MuleMessage message,
SessionHandler requestSessionHandler,
Service service,
MuleContext muleContext) |
Modifier and Type | Method and Description |
---|---|
void |
AbstractNotificationLoggerAgent.start() |
void |
ConfigScannerAgent.start() |
void |
AbstractNotificationLoggerAgent.stop() |
void |
ConfigScannerAgent.stop() |
Modifier and Type | Class and Description |
---|---|
class |
DefaultMuleException
MuleException Is the base exception type for the Mule application
any other exceptions thrown by Mule code will be based on this exception. |
class |
MessagingException
MessagingException is a general message exception thrown when
errors specific to Message processing occur.. |
Modifier and Type | Method and Description |
---|---|
void |
MuleContext.applyLifecycle(Object object) |
MuleEvent |
MuleSession.createOutboundEvent(MuleMessage message,
OutboundEndpoint endpoint,
MuleEvent previousEvent)
Creates an outbound event for this session
|
void |
MuleSession.dispatchEvent(MuleEvent event)
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(MuleMessage message)
This will dispatch an event asynchronously via the configured outbound
endpoint on the service for this session
|
void |
MuleSession.dispatchEvent(MuleMessage message)
This will dispatch an event asynchronously via the configured outbound
endpoint on the service for this session
|
void |
MuleEventContext.dispatchEvent(MuleMessage message,
EndpointURI 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 |
MuleEventContext.dispatchEvent(MuleMessage message,
OutboundEndpoint 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 |
MuleSession.dispatchEvent(MuleMessage message,
OutboundEndpoint 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 |
MuleEventContext.dispatchEvent(MuleMessage 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 |
MuleSession.dispatchEvent(MuleMessage 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(Object payload)
This will dispatch an event asynchronously via the configured outbound
endpoint on the service for this session
|
byte[] |
MuleEventContext.getMessageAsBytes()
Returns the contents of the message as a byte array.
|
byte[] |
MuleEvent.getMessageAsBytes()
Reterns the conents of the message as a byte array.
|
String |
MuleEventContext.getMessageAsString()
Returns the message contents as a string This method will use the encoding set
on the event
|
String |
MuleEvent.getMessageAsString()
Returns the message contents as a string If necessary this will use the
encoding set on the event
|
String |
MuleEventContext.getMessageAsString(String encoding)
Returns the message contents as a string
|
String |
MuleEvent.getMessageAsString(String encoding)
Returns the message contents as a string
|
MuleMessage |
MuleEventContext.requestEvent(EndpointURI endpoint,
long timeout)
Requests a synchronous receive of an event on the service.
|
MuleMessage |
MuleEventContext.requestEvent(InboundEndpoint endpoint,
long timeout)
Requests a synchronous receive of an event on the service.
|
MuleMessage |
MuleSession.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 |
MuleSession.requestEvent(String endpointName,
long timeout)
Requests a synchronous receive of an event on the service
|
MuleMessage |
MuleSession.sendEvent(MuleEvent 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
|
MuleMessage |
MuleEventContext.sendEvent(MuleMessage 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
|
MuleMessage |
MuleSession.sendEvent(MuleMessage message)
This will send an event via the configured outbound endpoint on the service
for this session
|
MuleMessage |
MuleEventContext.sendEvent(MuleMessage message,
EndpointURI 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
|
MuleMessage |
MuleEventContext.sendEvent(MuleMessage message,
OutboundEndpoint 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
|
MuleMessage |
MuleSession.sendEvent(MuleMessage message,
OutboundEndpoint 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
|
MuleMessage |
MuleEventContext.sendEvent(MuleMessage 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
|
MuleMessage |
MuleSession.sendEvent(MuleMessage 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
|
MuleMessage |
MuleEventContext.sendEvent(Object message)
This will send an event via the configured outbound router on the service
|
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)
sends an event request via the configured outbound router for this service.
|
FutureMessageResult |
MuleEventContext.sendEventAsync(MuleMessage message,
String endpointName,
int timeout)
sends an event request via the configured outbound router for this service.
|
FutureMessageResult |
MuleEventContext.sendEventAsync(Object message,
int timeout)
sends an event request via the configured outbound router for this service.
|
Modifier and Type | Method and Description |
---|---|
LifecycleAdapter |
LifecycleAdapterFactory.create(Object pojoService,
JavaComponent component,
EntryPointResolverSet resolver) |
MuleMessage |
Component.onCall(MuleEvent event)
Invokes the component
|
Modifier and Type | Class and Description |
---|---|
class |
ConfigurationException |
Modifier and Type | Class and Description |
---|---|
class |
MuleContextException
MuleContextException is thrown when an exception occurs with Manager
objects |
Modifier and Type | Class and Description |
---|---|
class |
EndpointException
EndpointException is an abstract exception extended by endpoint
specific exceptions. |
class |
EndpointNotFoundException
EndpointNotFoundException is thrown when an endpoint name or
protocol is specified but a matching endpoint is not registered with the Mule
server |
class |
MalformedEndpointException
MalformedEndpointException is thrown by the MuleEndpointURI class
if it fails to parse a Url |
Modifier and Type | Method and Description |
---|---|
EndpointBuilder |
EndpointFactory.getEndpointBuilder(String uri)
Used to retrieve the an EndpointBuilder equal to the one would be used to create an endpoint.
This is useful if you need to customize a builder before creation of an endpoint as you can use this method to obtain the endpoint builder, custommize it and then call the factory methods that take a EndpointBuilder rather than a String. |
InboundEndpoint |
EndpointFactory.getInboundEndpoint(EndpointBuilder builder)
Creates an endpoint with the "INBOUND" role using the builder provided.
|
InboundEndpoint |
EndpointFactory.getInboundEndpoint(EndpointURI endpointUri)
Deprecated.
|
InboundEndpoint |
EndpointFactory.getInboundEndpoint(String uri)
Creates an endpoint with the "INBOUND" role.
|
OutboundEndpoint |
EndpointFactory.getOutboundEndpoint(EndpointBuilder builder)
Creates an endpoint with the "OUTBOUND" role using the builder provided.
|
OutboundEndpoint |
EndpointFactory.getOutboundEndpoint(EndpointURI endpointUri)
Deprecated.
|
OutboundEndpoint |
EndpointFactory.getOutboundEndpoint(String uri)
Creates an endpoint with the "OUTBOUND" role.
|
Modifier and Type | Method and Description |
---|---|
Object |
Invocation.execute()
Deprecated.
Calls the component
|
MuleMessage |
Interceptor.intercept(Invocation invocation)
Deprecated.
Invoked when the component should be called.
|
Modifier and Type | Class and Description |
---|---|
class |
CreateException
InitialisationException is thrown by the initialise method defined
in the org.mule.api.lifecycle.Initialisable interface. |
class |
DisposeException
DisposeException TODO (document class) |
class |
FatalException
FatalException can be thrown during initialisation or during
execution to indicate that something fatal has occurred and the MuleManager must
shutdown. |
class |
InitialisationException
InitialisationException is thrown by the initialise method defined
in the org.mule.api.lifecycle.Initialisable interface. |
class |
LifecycleException
LifecycleException TODO |
class |
RecoverableException
RecoverableException can be thrown during initialisation to
indicate that the error occurred is not fatal and a reactive action can be
performed to try and remedy the error. |
class |
StartException
DisposeException TODO (document class) |
class |
StopException
DisposeException TODO (document class) |
Modifier and Type | Method and Description |
---|---|
void |
LifecycleManager.applyLifecycle(MuleContext muleContext,
Object object) |
void |
LifecyclePhase.fireLifecycle(MuleContext muleContext,
String currentPhase) |
void |
LifecycleManager.firePhase(MuleContext muleContext,
String phase) |
void |
Startable.start() |
void |
Stoppable.stop() |
Modifier and Type | Class and Description |
---|---|
class |
ModelException |
class |
SessionException
SessionException is thrown when errors occur in the DefaultMuleSession or
Seession Manager |
Modifier and Type | Class and Description |
---|---|
class |
RegistrationException |
class |
ServiceException
Any service-related exception: service not found, service lookup error, etc.
|
Modifier and Type | Method and Description |
---|---|
void |
Registry.registerAgent(Agent agent) |
void |
Registry.registerConnector(Connector connector) |
void |
Registry.registerEndpoint(ImmutableEndpoint endpoint) |
void |
Registry.registerEndpointBuilder(String name,
EndpointBuilder builder) |
void |
Registry.registerModel(Model model) |
void |
Registry.registerService(Service service) |
void |
Registry.registerTransformer(Transformer transformer) |
void |
Registry.unregisterAgent(String agentName) |
void |
Registry.unregisterConnector(String connectorName) |
void |
Registry.unregisterEndpoint(String endpointName) |
void |
Registry.unregisterModel(String modelName) |
void |
Registry.unregisterObject(String key) |
void |
Registry.unregisterService(String serviceName) |
void |
Registry.unregisterTransformer(String transformerName) |
Modifier and Type | Class and Description |
---|---|
class |
CouldNotRouteInboundEventException
CouldNotRouteInboundEventException thrown if the current service
cannot accept the inbound event. |
class |
CouldNotRouteOutboundMessageException
CouldNotRouteOutboundMessageException thrown if Mule fails to route
the current outbound event. |
class |
ResponseTimeoutException
ResponseTimeoutException is thrown when a response is not received
in a given timeout in the Response Router. |
class |
RoutePathNotFoundException
RoutePathNotFoundException is thrown if a routing path for an event
cannot be found. |
class |
RoutingException
RoutingException is a base class for all routing exceptions. |
class |
ServiceRoutingException
ServiceRoutingException is thrown due to a routing exception
between the endpoint the event was received on and the service receiving the
event. |
Modifier and Type | Method and Description |
---|---|
MuleMessage |
ResponseRouterCollection.getResponse(MuleMessage message) |
Modifier and Type | Class and Description |
---|---|
class |
CredentialsNotSetException
CredentialsNotSetException is thrown when user credentials cannot
be obtained from the current message |
class |
CryptoFailureException
CryptoFailureException is a generic exception thrown by an
CryptoStrategy if encryption or decryption fails. |
class |
EncryptionNotSupportedException
EncryptionNotSupportedException is thrown if an algorithm is set in
the MULE_USER header but it doesn't match the algorithm set on the security filter |
class |
EncryptionStrategyNotFoundException
EncryptionStrategyNotFoundException is thrown by the
SecurityManager when an encryption scheme is set in a property or header that
has not been registered witrh the manager |
class |
SecurityException
SecurityException is a generic security exception |
class |
SecurityProviderNotFoundException
SecurityProviderNotFoundException is thrown by the
SecurityManager when an authentication request is made but no suitable security
provider can be found to process the authentication |
class |
UnauthorisedException
UnauthorisedException is thrown if authentication fails |
class |
UnknownAuthenticationTypeException
UnknownAuthenticationTypeException is thrown if a security context
request is make with an unrecognised Authentication type. |
class |
UnsupportedAuthenticationSchemeException
UnsupportedAuthenticationSchemeException is thrown when a
authentication scheme is being used on the message that the Security filter does
not understand |
Modifier and Type | Method and Description |
---|---|
void |
Service.dispatchEvent(MuleEvent event)
Makes an asynchronous event call to the service.
|
void |
Service.pause()
Pauses event processing for a single Mule Service.
|
void |
Service.resume()
Resumes a single Mule Service that has been paused.
|
MuleMessage |
Service.sendEvent(MuleEvent event)
Makes a synchronous event call to the service.
|
Modifier and Type | Class and Description |
---|---|
class |
TransactionException
TransactionException is thrown when an exception occurs while
trying to create, start commit or rollback an exception |
Modifier and Type | Class and Description |
---|---|
class |
TransformerException
TransformerException is a simple exception that is thrown by
transformers. |
Modifier and Type | Method and Description |
---|---|
Object |
WireFormat.read(InputStream is) |
void |
WireFormat.write(OutputStream out,
Object o,
String encoding) |
Modifier and Type | Class and Description |
---|---|
class |
ConnectorException
ConnectorException Is thrown in the context of a Connector,
usually some sort of transport level error where the connection has failed. |
class |
DispatchException
DispatchException is thrown when an endpoint dispatcher fails to
send, dispatch or receive a message. |
class |
MessageTypeNotSupportedException
MessageTypeNotSupportedException is thrown when a message payload
is set on a Message implementation of MessageAdapter which is not of supported
type for that message or adapter. |
class |
NoReceiverForEndpointException
NoReceiverForEndpointException is thrown when an enpoint is
specified for a receiver but no such receiver exists. |
class |
ReceiveException
ReceiveException is specifically thrown by the Provider receive
method if something fails in the underlying transport |
Modifier and Type | Method and Description |
---|---|
void |
MessageRequesterFactory.activate(InboundEndpoint endpoint,
MessageRequester requester)
Invoked before the given requester is handed out to a
client, but not after
MessageRequesterFactory.create(org.mule.api.endpoint.InboundEndpoint) . |
void |
MessageDispatcherFactory.activate(OutboundEndpoint endpoint,
MessageDispatcher dispatcher)
Invoked before the given dispatcher is handed out to a
client, but not after
MessageDispatcherFactory.create(OutboundEndpoint) . |
MessageRequester |
MessageRequesterFactory.create(InboundEndpoint endpoint)
Creates a new message requester instance, initialised with the passed
endpoint.
|
MessageDispatcher |
MessageDispatcherFactory.create(OutboundEndpoint endpoint)
Creates a new message dispatcher instance, initialised with the passed
endpoint.
|
OutputStream |
Connector.getOutputStream(OutboundEndpoint endpoint,
MuleMessage message)
Will get the output stream for this type of transport.
|
MuleMessage |
InternalMessageListener.onMessage(MuleMessage message,
Transaction trans,
boolean synchronous,
OutputStream outputStream) |
void |
ReplyToHandler.processReplyTo(MuleEvent event,
MuleMessage returnMessage,
Object replyTo) |
void |
SessionHandler.retrieveSessionInfoFromMessage(MuleMessage message,
MuleSession session) |
MuleMessage |
MessageReceiver.routeMessage(MuleMessage message) |
MuleMessage |
MessageReceiver.routeMessage(MuleMessage message,
boolean synchronous) |
MuleMessage |
MessageReceiver.routeMessage(MuleMessage message,
boolean synchronous,
OutputStream outputStream) |
MuleMessage |
MessageReceiver.routeMessage(MuleMessage message,
OutputStream outputStream) |
MuleMessage |
MessageReceiver.routeMessage(MuleMessage message,
Transaction trans,
boolean synchronous) |
MuleMessage |
MessageReceiver.routeMessage(MuleMessage message,
Transaction trans,
boolean synchronous,
OutputStream outputStream) |
void |
SessionHandler.storeSessionInfoToMessage(MuleSession session,
MuleMessage message) |
Modifier and Type | Method and Description |
---|---|
protected void |
DefaultLifecycleAdapter.configureNestedRouter() |
LifecycleAdapter |
DefaultLifecycleAdapterFactory.create(Object pojoService,
JavaComponent component,
EntryPointResolverSet resolver) |
protected LifecycleAdapter |
AbstractJavaComponent.createLifeCycleAdaptor()
Creates and initialises a new LifecycleAdaptor instance wrapped the component
object instance obtained from the configured object factory.
|
protected void |
AbstractComponent.doStart() |
protected void |
SimpleCallableJavaComponent.doStart() |
protected void |
AbstractJavaComponent.doStart() |
protected void |
DefaultJavaComponent.doStart() |
protected void |
PooledJavaComponent.doStart() |
protected void |
AbstractComponent.doStop() |
protected void |
SimpleCallableJavaComponent.doStop() |
protected void |
DefaultJavaComponent.doStop() |
protected void |
PooledJavaComponent.doStop() |
MuleMessage |
DefaultLifecycleAdapter.intercept(Invocation invocation) |
MuleMessage |
AbstractComponent.onCall(MuleEvent event) |
void |
DefaultLifecycleAdapter.start()
Propagates start() life-cycle to component object implementations if they
implement the mule
Startable interface. |
void |
AbstractComponent.start() |
void |
DefaultLifecycleAdapter.stop()
Propagates stop() life-cycle to component object implementations if they
implement the mule
Stoppable interface. |
void |
AbstractComponent.stop() |
Constructor and Description |
---|
DefaultLifecycleAdapter(Object componentObject,
JavaComponent component) |
DefaultLifecycleAdapter(Object componentObject,
JavaComponent component,
EntryPointResolverSet entryPointResolver) |
Modifier and Type | Class and Description |
---|---|
class |
MessageBuilderException
Thrown by a MessageBuilder implementation if it cannot build the current
message or some other error occurs.
|
Modifier and Type | Method and Description |
---|---|
static MuleException |
ExceptionHelper.getRootMuleException(Throwable t) |
Modifier and Type | Method and Description |
---|---|
protected void |
SimpleRegistryBootstrap.process(Properties props) |
Modifier and Type | Method and Description |
---|---|
protected void |
SpringRegistry.doRegisterTransformer(Transformer transformer) |
void |
SpringRegistry.registerAgent(Agent agent) |
void |
SpringRegistry.registerConnector(Connector connector) |
void |
SpringRegistry.registerEndpoint(ImmutableEndpoint endpoint) |
void |
SpringRegistry.registerEndpointBuilder(String name,
EndpointBuilder builder) |
void |
SpringRegistry.registerModel(Model model) |
void |
SpringRegistry.registerService(Service service) |
void |
SpringRegistry.unregisterAgent(String agentName) |
void |
SpringRegistry.unregisterConnector(String connectorName) |
Modifier and Type | Class and Description |
---|---|
class |
NotificationException
Thrown by the ServerNotification Manager if unrecognised listeners or events are
passed to the manager
|
Modifier and Type | Method and Description |
---|---|
protected ImmutableEndpoint |
DefaultEndpointFactory.getEndpoint(EndpointURI uri,
org.mule.endpoint.DefaultEndpointFactory.EndpointSource source) |
EndpointBuilder |
DefaultEndpointFactory.getEndpointBuilder(String uri) |
InboundEndpoint |
DefaultEndpointFactory.getInboundEndpoint(EndpointBuilder builder) |
InboundEndpoint |
DefaultEndpointFactory.getInboundEndpoint(EndpointURI uri) |
InboundEndpoint |
DefaultEndpointFactory.getInboundEndpoint(String uri) |
OutboundEndpoint |
DefaultEndpointFactory.getOutboundEndpoint(EndpointBuilder builder) |
OutboundEndpoint |
DefaultEndpointFactory.getOutboundEndpoint(EndpointURI uri) |
OutboundEndpoint |
DefaultEndpointFactory.getOutboundEndpoint(String uri) |
Modifier and Type | Class and Description |
---|---|
class |
InterceptorException |
Modifier and Type | Class and Description |
---|---|
class |
AlreadyInitialisedException
AlreadyInitialisedException is thrown when a service or connector
has already been initialised. |
Modifier and Type | Method and Description |
---|---|
void |
GenericLifecycleManager.applyLifecycle(MuleContext muleContext,
Object object) |
void |
ContainerManagedLifecyclePhase.fireLifecycle(MuleContext muleContext,
String currentPhase) |
void |
DefaultLifecyclePhase.fireLifecycle(MuleContext muleContext,
String currentPhase) |
void |
GenericLifecycleManager.firePhase(MuleContext muleContext,
String phase) |
Modifier and Type | Method and Description |
---|---|
void |
MuleContextDisposePhase.fireLifecycle(MuleContext muleContext,
String currentPhase) |
Modifier and Type | Class and Description |
---|---|
class |
ModelServiceNotFoundException
Is thrown when a model service name is specified and cannot be found or loaded
|
Modifier and Type | Method and Description |
---|---|
void |
AbstractModel.start()
Starts all registered components
|
void |
AbstractModel.stop()
Stops any registered components
|
Modifier and Type | Method and Description |
---|---|
protected void |
DirectService.doDispatch(MuleEvent event) |
protected MuleMessage |
DirectService.doSend(MuleEvent event) |
Modifier and Type | Method and Description |
---|---|
protected void |
PipelineService.doDispatch(MuleEvent event) |
protected MuleMessage |
PipelineService.doSend(MuleEvent event) |
Modifier and Type | Class and Description |
---|---|
class |
EntryPointNotFoundException
Tis exception gets thrown by the
DefaultEntryPointResolverSet if after trying
all entrypointResolvers it cannot fin the entrypoint on the service service |
class |
NoSatisfiableMethodsException
NoSatisfiableMethodsException is thrown by EntryPointResolvers when
the service passed has no methods that meet the criteria of the configured
EntryPointResolver. |
class |
TooManySatisfiableMethodsException
TooManySatisfiableMethodsException is thrown by EntryPointResolvers
when the service passed has more than one method that meets the criteria of the
configured EntryPointResolver. |
Modifier and Type | Method and Description |
---|---|
protected void |
SedaService.doDispatch(MuleEvent event) |
protected void |
SedaService.doForceStop() |
protected MuleMessage |
SedaService.doSend(MuleEvent event) |
protected void |
SedaService.doStart() |
protected void |
SedaService.doStop() |
Object |
SedaService.getInstance() |
Modifier and Type | Method and Description |
---|---|
FutureMessageResult |
RemoteDispatcher.asyncReceiveRemote(String endpoint,
int timeout) |
void |
MuleClient.dispatch(String url,
MuleMessage message)
Dispatches an event asynchronously to a endpointUri via a Mule server.
|
void |
MuleClient.dispatch(String url,
Object payload,
Map messageProperties)
Dispatches an event asynchronously to a endpointUri via a Mule server.
|
protected MuleMessage |
RemoteDispatcher.dispatchAction(RemoteDispatcherNotification action,
boolean synchronous,
int timeout) |
void |
MuleClient.dispatchDirect(String componentName,
MuleMessage message)
Dispatches an event asynchronously to a component
|
void |
MuleClient.dispatchDirect(String component,
Object payload,
Map messageProperties)
Dispatches an event asynchronously to a component
|
void |
RemoteDispatcher.dispatchRemote(String endpoint,
Object payload,
Map messageProperties) |
void |
RemoteDispatcher.dispatchToRemoteComponent(String component,
Object payload,
Map messageProperties)
Dispatcher an event asynchronously to a components on a remote Mule instance.
|
protected MuleMessage |
RemoteDispatcher.doToRemote(String endpoint,
Object payload,
Map messageProperties,
boolean synchronous,
int timeout) |
protected MuleMessage |
RemoteDispatcher.doToRemoteComponent(String component,
Object payload,
Map messageProperties,
boolean synchronous) |
protected ImmutableEndpoint |
MuleClient.getDefaultClientEndpoint(Service service,
Object payload) |
protected MuleEvent |
MuleClient.getEvent(MuleMessage message,
String uri,
boolean synchronous)
Packages a mule event for the current request
|
protected InboundEndpoint |
MuleClient.getInboundEndpoint(String uri) |
protected OutboundEndpoint |
MuleClient.getOutboundEndpoint(String uri) |
RemoteDispatcher |
MuleClient.getRemoteDispatcher(String serverEndpoint) |
RemoteDispatcher |
MuleClient.getRemoteDispatcher(String serverEndpoint,
String user,
String password) |
MuleMessage |
RemoteDispatcher.receiveRemote(String endpoint,
int timeout) |
void |
MuleClient.registerComponent(Object component,
String name,
EndpointURI listenerEndpoint)
Deprecated.
Use the RegistryContext to get the registry and register the
service there
|
void |
MuleClient.registerComponent(Object component,
String name,
MuleEndpointURI listenerEndpoint,
MuleEndpointURI sendEndpoint)
Deprecated.
Use the RegistryContext to get the registry and register the
service there
|
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
|
protected WireFormat |
RemoteDispatcher.requestWireFormat() |
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 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 messageProperties,
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.
|
FutureMessageResult |
MuleClient.sendAsync(String url,
Object payload,
Map messageProperties)
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,
Object payload,
Map messageProperties,
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 |
RemoteDispatcher.sendAsyncRemote(String endpoint,
Object payload,
Map messageProperties) |
FutureMessageResult |
RemoteDispatcher.sendAsyncToRemoteComponent(String component,
String transformers,
Object payload,
Map messageProperties)
sends an event to a components on a remote Mule instance, while 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)
Sends an event synchronously to a component
|
MuleMessage |
MuleClient.sendDirect(String component,
String transformers,
Object payload,
Map messageProperties)
Sends an event synchronously to a component
|
FutureMessageResult |
MuleClient.sendDirectAsync(String component,
String transformers,
MuleMessage message)
Snds an event to a component 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.
|
FutureMessageResult |
MuleClient.sendDirectAsync(String component,
String transformers,
Object payload,
Map messageProperties)
Sends an event to a component 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.
|
void |
MuleClient.sendNoReceive(String url,
Object payload,
Map messageProperties)
Sends an event synchronously to a endpointUri via a Mule server without
waiting for the result.
|
MuleMessage |
RemoteDispatcher.sendRemote(String endpoint,
Object payload,
Map messageProperties) |
MuleMessage |
RemoteDispatcher.sendRemote(String endpoint,
Object payload,
Map messageProperties,
int timeout) |
MuleMessage |
RemoteDispatcher.sendToRemoteComponent(String component,
Object payload,
Map messageProperties)
sends an event synchronously to a components on a remote Mule instance.
|
void |
MuleClient.unregisterComponent(String name)
Deprecated.
Use the RegistryContext to get the registry and unregister the
service there
|
protected void |
RemoteDispatcher.updateContext(MuleMessage message,
ImmutableEndpoint endpoint,
boolean synchronous) |
Constructor and Description |
---|
MuleClient()
Creates a Mule client that will use the default serverEndpoint when connecting to a remote
server instance.
|
MuleClient(boolean startContext) |
MuleClient(MuleContext context) |
MuleClient(String configResources)
Configures a Mule client instance using the the default
SpringXmlConfigurationBuilder to parse configResources . |
MuleClient(String user,
String password)
Configures a new Mule client and either uses an existing Manager running in
this JVM or creates a new empty
MuleContext |
MuleProxyListener(Class listenerClass,
AbstractEventTransformer eventTransformer,
String componentName) |
MuleProxyListener(Class listenerClass,
String componentName) |
RemoteDispatcher(String endpoint) |
RemoteDispatcher(String endpoint,
Credentials credentials) |
Modifier and Type | Class and Description |
---|---|
class |
RemoteDispatcherException
Exceptions thrown by the Client RemteDispatcher.
|
class |
UnsupportedWireFormatException
Exception is thrown when the server is using a wire format that the client does not support
|
Modifier and Type | Method and Description |
---|---|
static Service |
RemoteDispatcherComponent.getSerivce(InboundEndpoint endpoint,
WireFormat wireFormat,
String encoding,
int eventTimeout,
MuleContext managementContext) |
protected Object |
RemoteDispatcherComponent.invokeAction(RemoteDispatcherNotification action,
MuleEventContext context) |
protected Object |
RemoteDispatcherComponent.receiveAction(RemoteDispatcherNotification action,
MuleEventContext context) |
protected Object |
RemoteDispatcherComponent.sendAction(RemoteDispatcherNotification action,
MuleEventContext context) |
void |
RemoteDispatcherAgent.start() |
void |
RemoteDispatcherAgent.stop() |
Modifier and Type | Class and Description |
---|---|
class |
ManagementException
ManagementException is a general exception thrown by management
extensions. |
Modifier and Type | Class and Description |
---|---|
class |
JmxManagementException
JmxManagementException is thrown by the Jmx agents if an error
occurs while executing an operation. |
Modifier and Type | Method and Description |
---|---|
protected void |
JmxAgent.registerWrapperService()
Register a Java Service Wrapper agent.
|
void |
Log4jAgent.start() |
void |
JmxAgent.start()
(non-Javadoc)
|
void |
WrapperManagerAgent.start() |
void |
RmiRegistryAgent.start() |
void |
JdmkAgent.start() |
void |
DefaultJmxSupportAgent.start() |
void |
Mx4jAgent.start() |
void |
Log4jAgent.stop() |
void |
JmxAgent.stop() |
void |
WrapperManagerAgent.stop() |
void |
RmiRegistryAgent.stop() |
void |
JdmkAgent.stop() |
void |
DefaultJmxSupportAgent.stop() |
void |
Mx4jAgent.stop() |
Modifier and Type | Method and Description |
---|---|
void |
MuleServiceMBean.dispose() |
void |
ServiceServiceMBean.dispose() |
void |
MuleService.dispose() |
void |
ServiceService.dispose() |
void |
ServiceServiceMBean.forceStop()
Causes the service to stop without processing its event queue first
|
void |
ServiceService.forceStop() |
void |
ServiceServiceMBean.pause()
Pauses event processing for theComponent.
|
void |
ServiceService.pause()
Pauses event processing for theComponent.
|
void |
ServiceServiceMBean.resume()
Resumes the Service that has been paused.
|
void |
ServiceService.resume()
Resumes the Service that has been paused.
|
void |
MuleServiceMBean.start() |
void |
RegistryServiceMBean.start() |
void |
ModelServiceMBean.start() |
void |
RegistryService.start() |
void |
MuleService.start() |
void |
ServiceService.start() |
void |
ModelService.start() |
void |
ConnectorServiceMBean.startConnector() |
void |
ConnectorService.startConnector() |
void |
MuleServiceMBean.stop() |
void |
RegistryServiceMBean.stop() |
void |
ModelServiceMBean.stop() |
void |
RegistryService.stop() |
void |
MuleService.stop() |
void |
ServiceService.stop() |
void |
ModelService.stop() |
void |
ConnectorServiceMBean.stopConnector() |
void |
ConnectorService.stopConnector() |
Modifier and Type | Method and Description |
---|---|
protected void |
TransientRegistry.doRegisterTransformer(Transformer transformer) |
protected abstract void |
AbstractRegistry.doRegisterTransformer(Transformer transformer) |
void |
TransientRegistry.registerAgent(Agent agent) |
void |
TransientRegistry.registerConnector(Connector connector) |
void |
TransientRegistry.registerEndpoint(ImmutableEndpoint endpoint) |
void |
TransientRegistry.registerEndpointBuilder(String name,
EndpointBuilder builder) |
void |
TransientRegistry.registerModel(Model model) |
void |
TransientRegistry.registerService(Service service) |
void |
AbstractRegistry.registerTransformer(Transformer transformer) |
void |
TransientRegistry.unregisterAgent(String agentName) |
void |
TransientRegistry.unregisterConnector(String connectorName) |
void |
TransientRegistry.unregisterEndpoint(String endpointName) |
void |
TransientRegistry.unregisterModel(String modelName) |
void |
TransientRegistry.unregisterObject(String key) |
protected void |
TransientRegistry.unregisterObject(String key,
Object metadata) |
void |
TransientRegistry.unregisterService(String serviceName) |
void |
TransientRegistry.unregisterTransformer(String transformerName) |
Modifier and Type | Class and Description |
---|---|
class |
AggregationException
TODO document
|
class |
CorrelationTimeoutException
TODO
|
Modifier and Type | Method and Description |
---|---|
void |
DefaultInboundRouterCollection.dispatch(MuleEvent event) |
MuleMessage |
DefaultInboundRouterCollection.send(MuleEvent event) |
void |
WireTap.setEndpoint(OutboundEndpoint endpoint) |
Modifier and Type | Method and Description |
---|---|
void |
AbstractOutboundRouter.dispatch(MuleSession session,
MuleMessage message,
OutboundEndpoint endpoint) |
protected OutboundEndpoint |
AbstractRecipientList.getRecipientEndpointFromString(MuleMessage message,
String recipient) |
protected OutboundEndpoint |
AbstractRecipientList.getRecipientEndpointFromUri(EndpointURI uri) |
protected OutboundEndpoint |
EndpointSelector.lookupEndpoint(String endpointName) |
MuleMessage |
AbstractOutboundRouter.send(MuleSession session,
MuleMessage message,
OutboundEndpoint endpoint) |
Modifier and Type | Method and Description |
---|---|
protected void |
AbstractService.connectListeners() |
protected void |
AbstractService.disconnectListeners() |
void |
AbstractService.dispatchEvent(MuleEvent event) |
protected abstract void |
AbstractService.doDispatch(MuleEvent event) |
protected void |
AbstractService.doForceStop() |
protected void |
AbstractService.doPause()
Custom components can execute code necessary to put the service in a paused
state here.
|
protected void |
AbstractService.doResume()
Custom components can execute code necessary to resume a service once it has
been paused If a developer overloads this method the doPause() method MUST
also be overloaded to avoid inconsistent state in the service
|
protected abstract MuleMessage |
AbstractService.doSend(MuleEvent event) |
protected void |
AbstractService.doStart() |
protected void |
AbstractService.doStop() |
void |
AbstractService.forceStop() |
void |
AbstractService.pause()
Pauses event processing for a single Mule Service.
|
protected MuleMessage |
AbstractService.processAsyncReplyRouter(MuleMessage result) |
protected void |
AbstractService.processReplyTo(MuleEvent event,
MuleMessage result,
ReplyToHandler replyToHandler,
Object replyTo) |
protected void |
AbstractService.registerListeners() |
void |
AbstractService.resume()
Resumes a single Mule Service that has been paused.
|
MuleMessage |
AbstractService.sendEvent(MuleEvent event) |
void |
AbstractService.start() |
protected void |
AbstractService.start(boolean startPaused)
Starts a Mule Service.
|
protected void |
AbstractService.startListeners() |
void |
AbstractService.stop() |
protected void |
AbstractService.stopListeners() |
protected void |
AbstractService.unregisterListeners() |
Modifier and Type | Class and Description |
---|---|
class |
IllegalTransactionStateException
IllegalTransactionStateException TODO (document class) |
class |
TransactionInProgressException
TransactionInProgressException is thrown if a new transaction is
started when there is one already in progress. |
class |
TransactionNotInProgressException
TransactionNotInProgressException TODO (document class) |
class |
TransactionRollbackException |
class |
TransactionStatusException |
Modifier and Type | Method and Description |
---|---|
Object |
TransformerPairWireFormat.read(InputStream in) |
void |
TransformerPairWireFormat.write(OutputStream out,
Object o,
String encoding) |
Modifier and Type | Class and Description |
---|---|
class |
ConnectException
TODO document
|
class |
FatalConnectException
TODO document
|
Modifier and Type | Method and Description |
---|---|
void |
AbstractMessageRequesterFactory.activate(InboundEndpoint endpoint,
MessageRequester requester) |
void |
KeyedPoolMessageRequesterFactoryAdapter.activate(InboundEndpoint endpoint,
MessageRequester requester) |
void |
AbstractMessageDispatcherFactory.activate(OutboundEndpoint endpoint,
MessageDispatcher dispatcher) |
void |
KeyedPoolMessageDispatcherFactoryAdapter.activate(OutboundEndpoint endpoint,
MessageDispatcher dispatcher) |
abstract MessageRequester |
AbstractMessageRequesterFactory.create(InboundEndpoint endpoint) |
MessageRequester |
KeyedPoolMessageRequesterFactoryAdapter.create(InboundEndpoint endpoint) |
MessageRequester |
UnsupportedMessageRequesterFactory.create(InboundEndpoint endpoint) |
MessageDispatcher |
UnsupportedMessageDispatcherFactory.create(OutboundEndpoint endpoint) |
abstract MessageDispatcher |
AbstractMessageDispatcherFactory.create(OutboundEndpoint endpoint) |
MessageDispatcher |
KeyedPoolMessageDispatcherFactoryAdapter.create(OutboundEndpoint endpoint) |
void |
TransactedPollingMessageReceiver.doStart() |
protected abstract void |
AbstractMessageReceiver.doStart() |
protected void |
AbstractPollingMessageReceiver.doStart() |
protected abstract void |
AbstractConnector.doStart()
Template method to perform any work when starting the connectoe
|
protected abstract void |
AbstractMessageReceiver.doStop() |
protected void |
AbstractPollingMessageReceiver.doStop() |
protected abstract void |
AbstractConnector.doStop()
Template method to perform any work when stopping the connectoe
|
protected WorkManager |
AbstractConnector.getDispatcherWorkManager()
Returns a work manager for message dispatchers.
|
protected OutboundEndpoint |
DefaultReplyToHandler.getEndpoint(MuleEvent event,
String endpointUri) |
OutputStream |
AbstractConnector.getOutputStream(OutboundEndpoint endpoint,
MuleMessage message)
Will get the output stream for this type of transport.
|
protected WorkManager |
AbstractConnector.getReceiverWorkManager(String receiverName)
Returns a work manager for message receivers.
|
protected WorkManager |
AbstractConnector.getRequesterWorkManager()
Returns a work manager for message requesters.
|
protected void |
AbstractConnector.initWorkManagers() |
void |
DefaultReplyToHandler.processReplyTo(MuleEvent event,
MuleMessage returnMessage,
Object replyTo) |
MuleMessage |
AbstractMessageReceiver.routeMessage(MuleMessage message) |
MuleMessage |
AbstractMessageReceiver.routeMessage(MuleMessage message,
boolean synchronous) |
MuleMessage |
AbstractMessageReceiver.routeMessage(MuleMessage message,
boolean synchronous,
OutputStream outputStream) |
MuleMessage |
AbstractMessageReceiver.routeMessage(MuleMessage message,
OutputStream outputStream) |
MuleMessage |
AbstractMessageReceiver.routeMessage(MuleMessage message,
Transaction trans,
boolean synchronous) |
MuleMessage |
AbstractMessageReceiver.routeMessage(MuleMessage message,
Transaction trans,
boolean synchronous,
OutputStream outputStream) |
void |
AbstractMessageReceiver.start() |
void |
AbstractConnector.start() |
void |
AbstractConnector.stop() |
Modifier and Type | Method and Description |
---|---|
MessageDispatcher |
ProcessMessageDispatcherFactory.create(OutboundEndpoint endpoint) |
protected void |
ProcessMessageReceiver.doStart() |
protected void |
ProcessConnector.doStart() |
protected void |
ProcessMessageReceiver.doStop() |
protected void |
ProcessConnector.doStop() |
void |
ProcessMessageReceiver.generateAsynchronousEvent(String endpoint,
Object payload,
Map messageProperties) |
protected MuleMessage |
ProcessMessageReceiver.generateEvent(String endpoint,
Object payload,
Map messageProperties,
boolean synchronous) |
MuleMessage |
ProcessMessageReceiver.generateSynchronousEvent(String endpoint,
Object payload,
Map messageProperties) |
Modifier and Type | Method and Description |
---|---|
MessageDispatcher |
EjbMessageDispatcherFactory.create(OutboundEndpoint endpoint) |
Modifier and Type | Method and Description |
---|---|
MessageRequester |
HttpClientMessageRequesterFactory.create(InboundEndpoint endpoint)
Creates a new message requester instance, initialised with the passed
endpoint.
|
MessageDispatcher |
HttpClientMessageDispatcherFactory.create(OutboundEndpoint endpoint)
Creates a new message dispatcher instance, initialised with the passed
endpoint.
|
protected HttpResponse |
HttpMessageReceiver.HttpWorker.doBad(RequestLine requestLine) |
protected HttpResponse |
HttpMessageReceiver.HttpWorker.doHead(RequestLine requestLine) |
protected HttpResponse |
HttpMessageReceiver.HttpWorker.doOtherValid(RequestLine requestLine,
String method) |
protected HttpResponse |
HttpMessageReceiver.HttpWorker.doRequest(HttpRequest request,
RequestLine requestLine) |
protected HttpResponse |
HttpMessageReceiver.HttpWorker.processRequest(HttpRequest request) |
void |
HttpSessionHandler.retrieveSessionInfoFromMessage(MuleMessage message,
MuleSession session) |
void |
HttpSessionHandler.storeSessionInfoToMessage(MuleSession session,
MuleMessage message) |
Modifier and Type | Class and Description |
---|---|
class |
RestServiceException |
Modifier and Type | Method and Description |
---|---|
protected void |
RestServiceWrapper.doStart() |
protected void |
RestServiceWrapper.doStop() |
Modifier and Type | Class and Description |
---|---|
class |
MessageRedeliveredException |
Modifier and Type | Method and Description |
---|---|
MessageRequester |
JmsMessageRequesterFactory.create(InboundEndpoint endpoint) |
MessageDispatcher |
JmsMessageDispatcherFactory.create(OutboundEndpoint endpoint) |
protected void |
TransactedSingleResourceJmsMessageReceiver.doStart() |
protected void |
JmsConnector.doStart() |
protected void |
MultiConsumerJmsMessageReceiver.doStart() |
protected void |
JmsMessageReceiver.doStart() |
protected void |
TransactedSingleResourceJmsMessageReceiver.doStop() |
protected void |
JmsConnector.doStop() |
protected void |
MultiConsumerJmsMessageReceiver.doStop() |
protected void |
JmsMessageReceiver.doStop() |
void |
JmsReplyToHandler.processReplyTo(MuleEvent event,
MuleMessage returnMessage,
Object replyTo) |
Modifier and Type | Method and Description |
---|---|
MessageDispatcher |
QuartzMessageDispatcherFactory.create(OutboundEndpoint endpoint) |
protected void |
QuartzMessageReceiver.doStart() |
protected void |
QuartzConnector.doStart() |
protected void |
QuartzMessageReceiver.doStop() |
protected void |
QuartzConnector.doStop() |
Modifier and Type | Method and Description |
---|---|
MessageDispatcher |
RmiMessageDispatcherFactory.create(OutboundEndpoint endpoint) |
protected void |
RmiCallbackMessageReceiver.doStart() |
protected void |
RmiConnector.doStart() |
protected void |
RmiCallbackMessageReceiver.doStop() |
protected void |
RmiConnector.doStop() |
Method |
RmiConnector.getMethodObject(Remote remoteObject,
MuleEvent event)
Helper method for Dispatchers and Receives to extract the correct method from
a Remote object
|
Object |
RmiCallbackMessageReceiver.routeMessage(Object message)
Routes message forward
|
Modifier and Type | Class and Description |
---|---|
class |
TransportFactoryException
TransportFactoryException is thrown by the endpoint factory if the
endpoint service cannot be found in the META-INF/services directory or if any part
of the endpoint cannot be instanciated. |
class |
TransportServiceException
TransportServiceException is thrown if a ProviderServicedescriptor
has a service error set. |
class |
TransportServiceNotFoundException
TransportServiceNotFoundException is thorown if no matching service
endpoint descriptor is found for the connector protocol. |
Modifier and Type | Method and Description |
---|---|
MessageReceiver |
DefaultTransportServiceDescriptor.createMessageReceiver(Connector connector,
Service service,
InboundEndpoint endpoint) |
MessageReceiver |
TransportServiceDescriptor.createMessageReceiver(Connector connector,
Service service,
InboundEndpoint endpoint) |
MessageReceiver |
DefaultTransportServiceDescriptor.createMessageReceiver(Connector connector,
Service service,
InboundEndpoint endpoint,
Object[] args) |
MessageReceiver |
TransportServiceDescriptor.createMessageReceiver(Connector connector,
Service service,
InboundEndpoint endpoint,
Object[] args) |
Modifier and Type | Method and Description |
---|---|
protected MuleMessage |
MuleReceiverServlet.doMethod(javax.servlet.http.HttpServletRequest request,
String method) |
protected void |
ServletMessageReceiver.doStart() |
protected void |
ServletConnector.doStart() |
protected void |
ServletMessageReceiver.doStop() |
protected void |
ServletConnector.doStop() |
protected InboundEndpoint |
MuleRESTReceiverServlet.getEndpointForURI(javax.servlet.http.HttpServletRequest httpServletRequest) |
protected MuleMessage |
MuleReceiverServlet.routeMessage(MessageReceiver receiver,
MuleMessage requestMessage,
javax.servlet.http.HttpServletRequest request) |
Modifier and Type | Method and Description |
---|---|
MessageDispatcher |
StdioMessageDispatcherFactory.create(OutboundEndpoint endpoint) |
OutputStream |
PromptStdioConnector.getOutputStream(ImmutableEndpoint endpoint,
MuleMessage message) |
Modifier and Type | Method and Description |
---|---|
MessageRequester |
TcpMessageRequesterFactory.create(InboundEndpoint endpoint) |
MessageDispatcher |
TcpMessageDispatcherFactory.create(OutboundEndpoint endpoint) |
protected void |
TcpConnector.doStart() |
protected void |
TcpMessageReceiver.doStart() |
protected void |
TcpConnector.doStop() |
protected void |
TcpMessageReceiver.doStop() |
OutputStream |
TcpConnector.getOutputStream(ImmutableEndpoint endpoint,
MuleMessage message) |
Modifier and Type | Method and Description |
---|---|
MessageRequester |
UdpMessageRequesterFactory.create(InboundEndpoint endpoint) |
MessageDispatcher |
UdpMessageDispatcherFactory.create(OutboundEndpoint endpoint) |
protected void |
UdpConnector.doStart() |
protected void |
UdpMessageReceiver.doStart() |
protected void |
UdpConnector.doStop() |
protected void |
UdpMessageReceiver.doStop() |
Modifier and Type | Method and Description |
---|---|
MessageRequester |
VMMessageRequesterFactory.create(InboundEndpoint endpoint) |
MessageDispatcher |
VMMessageDispatcherFactory.create(OutboundEndpoint endpoint) |
protected void |
VMConnector.doStart() |
protected void |
VMConnector.doStop() |
Object |
VMMessageReceiver.onCall(MuleMessage message,
boolean synchronous) |
void |
VMMessageReceiver.onMessage(MuleMessage message) |
Modifier and Type | Method and Description |
---|---|
void |
DefaultLifecycleEnabledObjectPool.start() |
void |
DefaultLifecycleEnabledObjectPool.stop() |
Modifier and Type | Class and Description |
---|---|
class |
ResourceManagerException |
class |
ResourceManagerSystemException |
Modifier and Type | Method and Description |
---|---|
void |
MuleWorkManager.start() |
Copyright © 2003–2013 MuleSource, Inc.. All rights reserved.