Modifier and Type | Method and Description |
---|---|
protected void |
DefaultMuleMessage.applyAllTransformers(MuleEvent event,
List<? extends Transformer> transformers) |
void |
DefaultMuleMessage.applyTransformers(MuleEvent event,
List<? extends Transformer> transformers)
Will apply a list of transformers to the payload of the message.
|
void |
DefaultMuleMessage.applyTransformers(MuleEvent event,
List<? extends Transformer> transformers,
Class<?> outputType) |
void |
DefaultMuleMessage.applyTransformers(MuleEvent event,
Transformer... transformers)
Will apply a list of transformers to the payload of the message.
|
void |
DefaultMuleEventContext.dispatchEvent(MuleMessage message)
This will dispatch an event asynchronously via the configured outbound
endpoint on the service for this session
|
void |
DefaultMuleEventContext.dispatchEvent(MuleMessage message,
EndpointURI endpointUri)
Depending on the session state this methods either Passes an event
asynchronously to the next available Mule component in the pool or via the
endpointUri configured for the event
|
void |
DefaultMuleEventContext.dispatchEvent(MuleMessage message,
OutboundEndpoint endpoint)
Depending on the session state this methods either Passes an event
asynchronously to the next available Mule component in the pool or via the
endpoint configured for the event
|
void |
DefaultMuleEventContext.dispatchEvent(MuleMessage message,
String endpointName)
Depending on the session state this methods either Passes an event
asynchronously to the next available Mule component in the pool or via the
endpoint configured for the event
|
void |
DefaultMuleEventContext.dispatchEvent(Object message)
This will dispatch an event asynchronously via the configured outbound
endpoint on the service for this session
|
byte[] |
VoidMuleEvent.getMessageAsBytes() |
byte[] |
DefaultMuleEventContext.getMessageAsBytes()
Reterns the conents of the message as a byte array.
|
String |
VoidMuleEvent.getMessageAsString() |
String |
DefaultMuleEventContext.getMessageAsString()
Returns the message contents as a string This method will use the default
encoding on the event
|
String |
DefaultMuleEvent.getMessageAsString() |
String |
VoidMuleEvent.getMessageAsString(String encoding) |
String |
DefaultMuleEventContext.getMessageAsString(String encoding)
Returns the message contents as a string
|
String |
DefaultMuleEvent.getMessageAsString(String encoding)
Returns the message contents for logging
|
void |
DefaultMuleMessage.initAfterDeserialisation(MuleContext context)
Invoked after deserialization.
|
MuleMessage |
DefaultMuleEventContext.requestEvent(EndpointURI endpointUri,
long timeout)
Requests a synchronous receive of an event on the service
|
MuleMessage |
DefaultMuleEventContext.requestEvent(InboundEndpoint endpoint,
long timeout)
Requests a synchronous receive of an event on the service
|
MuleMessage |
DefaultMuleEventContext.requestEvent(String endpointName,
long timeout)
Requests a synchronous receive of an event on the service
|
MuleMessage |
DefaultMuleEventContext.sendEvent(MuleMessage message)
Depending on the session state this methods either Passes an event
synchronously to the next available Mule component in the pool or via the
endpoint configured for the event
|
MuleMessage |
DefaultMuleEventContext.sendEvent(MuleMessage message,
EndpointURI endpointUri)
Depending on the session state this methods either Passes an event
synchronously to the next available Mule component in the pool or via the
endpointUri configured for the event
|
MuleMessage |
DefaultMuleEventContext.sendEvent(MuleMessage message,
OutboundEndpoint endpoint)
Depending on the session state this methods either Passes an event
synchronously to the next available Mule component in the pool or via the
endpoint configured for the event
|
MuleMessage |
DefaultMuleEventContext.sendEvent(MuleMessage message,
String endpointName)
Depending on the session state this methods either Passes an event
synchronously to the next available Mule component in the pool or via the
endpoint configured for the event
|
MuleMessage |
DefaultMuleEventContext.sendEvent(Object message)
This will send an event via the configured outbound router on the service
|
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
MuleContext which stops all sessions and
connectors |
Modifier and Type | Method and Description |
---|---|
void |
AbstractNotificationLoggerAgent.start() |
void |
AbstractNotificationLoggerAgent.stop() |
Modifier and Type | Class and Description |
---|---|
class |
AnnotationException
Root exception for errors related to annotation parsing
|
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 |
MuleMessage.applyTransformers(MuleEvent event,
List<? extends Transformer> transformers)
Will apply a list of transformers to the payload of the message.
|
void |
MuleMessage.applyTransformers(MuleEvent event,
List<? extends Transformer> transformers,
Class<?> outputType)
Will apply a list of transformers to the payload of the message.
|
void |
MuleMessage.applyTransformers(MuleEvent event,
Transformer... transformers)
Will apply a list of transformers to the payload of the message.
|
void |
Closeable.close()
Closes the resource.
|
void |
MuleEventContext.dispatchEvent(MuleMessage message)
Deprecated.
|
void |
MuleEventContext.dispatchEvent(MuleMessage message,
EndpointURI endpoint)
Deprecated.
|
void |
MuleEventContext.dispatchEvent(MuleMessage message,
OutboundEndpoint endpoint)
Depending on the session state this methods either Passes an event
asynchronously to the next available Mule component in the pool or via the endpoint
configured for the event
|
void |
MuleEventContext.dispatchEvent(MuleMessage message,
String endpointName)
Depending on the session state this methods either Passes an event
asynchronously to the next available Mule component in the pool or via the endpoint
configured for the event.
|
void |
MuleEventContext.dispatchEvent(Object payload)
Deprecated.
|
MuleMessage |
FutureMessageResult.getMessage() |
MuleMessage |
FutureMessageResult.getMessage(long timeout) |
byte[] |
MuleEventContext.getMessageAsBytes()
Returns the contents of the message as a byte array.
|
byte[] |
MuleEvent.getMessageAsBytes()
Returns the contents 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
|
InboundEndpoint |
EndpointAnnotationParser.parseInboundEndpoint(Annotation annotation,
Map metaInfo)
Creates an inbound endpoint from the annotation.
|
MessageProcessor |
MessageProcessorAnnotationParser.parseMessageProcessor(Annotation annotation)
Will create a Mule Router according to the annotation.
|
OutboundEndpoint |
EndpointAnnotationParser.parseOutboundEndpoint(Annotation annotation,
Map metaInfo)
Creates an outbound endpoint from the annotation.
|
MuleMessage |
MuleEventContext.requestEvent(EndpointURI endpoint,
long timeout)
Deprecated.
|
MuleMessage |
MuleEventContext.requestEvent(InboundEndpoint endpoint,
long timeout)
Requests a synchronous receive of an event on the service.
|
MuleMessage |
MuleEventContext.requestEvent(String endpointName,
long timeout)
Requests a synchronous receive of an event on the service.
|
MuleMessage |
MuleEventContext.sendEvent(MuleMessage message)
Deprecated.
|
MuleMessage |
MuleEventContext.sendEvent(MuleMessage message,
EndpointURI endpoint)
Deprecated.
|
MuleMessage |
MuleEventContext.sendEvent(MuleMessage message,
OutboundEndpoint endpoint)
Depending on the session state this methods either Passes an event
synchronously to the next available Mule component in the pool or via the endpoint
configured for the event
|
MuleMessage |
MuleEventContext.sendEvent(MuleMessage message,
String endpointName)
Depending on the session state this methods either Passes an event
synchronously to the next available Mule component in the pool or via the endpoint
configured for the event
|
MuleMessage |
MuleEventContext.sendEvent(Object message)
Deprecated.
|
FutureMessageResult |
MuleEventContext.sendEventAsync(MuleMessage message,
EndpointURI endpoint,
int timeout)
sends an event request via the configured outbound router for this service.
|
FutureMessageResult |
MuleEventContext.sendEventAsync(MuleMessage message,
int timeout)
Deprecated.
|
FutureMessageResult |
MuleEventContext.sendEventAsync(MuleMessage message,
String endpointName,
int timeout)
sends an event request via the configured outbound router for this service.
|
FutureMessageResult |
MuleEventContext.sendEventAsync(Object message,
int timeout)
Deprecated.
|
Modifier and Type | Method and Description |
---|---|
MuleEvent |
CachingStrategy.process(MuleEvent request,
MessageProcessor messageProcessor)
Processes a
MuleEvent using a caching schema. |
Modifier and Type | Method and Description |
---|---|
HttpCallback |
HttpCallbackFactory.createCallback(HttpCallbackAdapter adapter,
String authCodeRegex,
FetchAccessTokenMessageProcessor fetchAccessTokenMessageProcessor,
MessageProcessor listener,
MuleContext muleContext,
FlowConstruct flowConstruct)
returns a new callback that has not been started
|
MuleEvent |
SourceCallback.processEvent(MuleEvent event)
Dispatch the current event to the flow
|
Modifier and Type | Method and Description |
---|---|
void |
MuleClient.dispatch(String url,
MuleMessage message)
Dispatches an event asynchronously to a endpointUri via a Mule server.
|
void |
MuleClient.dispatch(String url,
MuleMessage message,
OperationOptions operationOptions)
Dispatches an event asynchronously to a endpointUri via a Mule server.
|
void |
MuleClient.dispatch(String url,
Object payload,
Map<String,Object> messageProperties)
Deprecated.
use
MuleClient.dispatch(String, org.mule.api.MuleMessage) instead
Dispatches an event asynchronously to a endpointUri via a Mule server. The URL
determines where to dispatch the event to. |
MuleMessage |
LocalMuleClient.process(OutboundEndpoint endpoint,
MuleMessage message)
Sends an event synchronously to a endpointUri via a Mule server and a
resulting message is returned.
|
MuleMessage |
LocalMuleClient.process(OutboundEndpoint endpoint,
Object payload,
Map<String,Object> messageProperties)
Sends an event synchronously to a endpointUri via a Mule server and a
resulting message is returned.
|
MuleMessage |
MuleClient.process(String uri,
MessageExchangePattern mep,
MuleMessage message)
Processes a messsage with an outbound endpoint using the specified
MessageExchangePattern |
MuleMessage |
MuleClient.process(String uri,
MessageExchangePattern mep,
Object payload,
Map<String,Object> messageProperties)
Processes a message with an outbound endpoint using the specified
MessageExchangePattern |
MuleMessage |
LocalMuleClient.request(InboundEndpoint endpoint,
long timeout)
Will receive an event from an endpointUri determined by the URL.
|
MuleMessage |
MuleClient.request(String url,
long timeout)
Will receive an event from an endpointUri determined by the URL.
|
MuleMessage |
MuleClient.send(String url,
MuleMessage message)
Sends an event synchronously to a endpointUri via a Mule server and a
resulting message is returned.
|
MuleMessage |
MuleClient.send(String url,
MuleMessage message,
long timeout)
Deprecated.
use
MuleClient.send(String, org.mule.api.MuleMessage, OperationOptions) instead
Sends an event synchronously to a endpointUri via a mule server and a
resulting message is returned. |
MuleMessage |
MuleClient.send(String url,
MuleMessage message,
OperationOptions operationOptions)
Sends an event synchronously to a endpointUri via a Mule server and a
resulting message is returned.
|
MuleMessage |
MuleClient.send(String url,
Object payload,
Map<String,Object> messageProperties)
Deprecated.
use
MuleClient.send(String, org.mule.api.MuleMessage) instead
Sends an event synchronously to a endpointUri via a Mule server and a
resulting message is returned. |
MuleMessage |
MuleClient.send(String url,
Object payload,
Map<String,Object> messageProperties,
long timeout)
Deprecated.
use
MuleClient.send(String, org.mule.api.MuleMessage, OperationOptions)
Sends an event synchronously to a endpointUri via a mule server and a
resulting message is returned. |
Modifier and Type | Method and Description |
---|---|
LifecycleAdapter |
LifecycleAdapterFactory.create(Object pojoService,
JavaComponent component,
FlowConstruct flowConstruct,
EntryPointResolverSet resolver,
MuleContext muleContext) |
Object |
LifecycleAdapter.invoke(MuleEvent message) |
MuleEvent |
InterfaceBinding.process(MuleEvent event)
This method is responsible for routing the Message via the MuleSession.
|
void |
InterfaceBinding.setEndpoint(ImmutableEndpoint endpoint) |
Modifier and Type | Class and Description |
---|---|
class |
ConfigurationException |
Modifier and Type | Method and Description |
---|---|
MessageProcessor |
ConnectorOperationProvider.getMessageProcessor(String url,
OperationOptions operationOptions,
MessageExchangePattern exchangePattern)
A
MessageProcessor that contains the behaviour for the URL |
MessageProcessor |
ConnectorOperationLocator.locateConnectorOperation(String url,
OperationOptions operationOptions,
MessageExchangePattern exchangePattern)
Lookup for an operation from a connector
|
Modifier and Type | Class and Description |
---|---|
class |
FlowConstructInvalidException |
Modifier and Type | Class and Description |
---|---|
class |
MuleContextException
MuleContextException is thrown when an exception occurs with Mule Context
objects |
Modifier and Type | Method and Description |
---|---|
WorkManager |
WorkManagerSource.getWorkManager() |
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 |
---|---|
MessageProcessor |
EndpointMessageProcessorChainFactory.createInboundMessageProcessorChain(InboundEndpoint endpoint,
FlowConstruct flowConstruct,
MessageProcessor target) |
MessageProcessor |
EndpointMessageProcessorChainFactory.createOutboundMessageProcessorChain(OutboundEndpoint endpoint,
MessageProcessor target) |
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.
|
InboundEndpoint |
EndpointCache.getInboundEndpoint(String uri,
MessageExchangePattern mep) |
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.
|
OutboundEndpoint |
EndpointCache.getOutboundEndpoint(String uri,
MessageExchangePattern mep,
Long responseTimeout) |
Modifier and Type | Class and Description |
---|---|
class |
MessageRedeliveredException |
Modifier and Type | Method and Description |
---|---|
MuleEvent |
Interceptor.process(MuleEvent event)
Invoked when the component should be called.
|
Modifier and Type | Class and Description |
---|---|
class |
CreateException
CreateException is thrown when creating an object inside Mule wasn't possible due
to inconsistent internal state or wrong input. |
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 |
LifecycleCallback.onTransition(String phaseName,
O object) |
void |
Startable.start() |
void |
Stoppable.stop() |
Modifier and Type | Class and Description |
---|---|
class |
SessionException
SessionException is thrown when errors occur in the DefaultMuleSession or
Seession Manager |
Modifier and Type | Class and Description |
---|---|
class |
DynamicPipelineException |
Modifier and Type | Method and Description |
---|---|
void |
MessageRouter.addRoute(MessageProcessor processor)
Adds a new message processor to the list of routes
|
MessageProcessor |
MessageProcessorBuilder.build() |
MuleEvent |
MessageProcessor.process(MuleEvent event)
Invokes the MessageProcessor.
|
MuleEvent |
LoggerMessageProcessor.process(MuleEvent event) |
void |
MessageRouter.removeRoute(MessageProcessor processor)
Removes a message processor from the list of routes
|
String |
DynamicPipelineBuilder.reset()
Removes and disposes all injected message processors.
|
String |
DynamicPipelineBuilder.resetAndUpdate()
Injects the message processors added with
DynamicPipelineBuilder.injectBefore(org.mule.api.processor.MessageProcessor...)
and DynamicPipelineBuilder.injectAfter(org.mule.api.processor.MessageProcessor...)
If none were added the effect is the same as calling DynamicPipelineBuilder.reset() |
Modifier and Type | Class and Description |
---|---|
class |
RegistrationException |
class |
ResolverException
An exception that is thrown by resolver classes responsible for finding objects in the registry based on particular
criteria
|
class |
ServiceException
Any service-related exception: service not found, service lookup error, etc.
|
Modifier and Type | Method and Description |
---|---|
Object |
MuleRegistry.applyLifecycle(Object object)
Will execute any lifecycle phases on an object without actually registering the object in the registry.
|
Object |
MuleRegistry.applyLifecycle(Object object,
String phase) |
Object |
MuleRegistry.applyProcessors(Object object)
Will execute any processors on an object without actually registering the object in the registry.
|
Object |
MuleRegistry.applyProcessors(Object object,
int flags)
Will execute any processors on an object without actually registering the object in the registry.
|
Object |
MuleRegistry.applyProcessorsAndLifecycle(Object object)
Will execute any processors on an object and fire any lifecycle methods according to the current lifecycle without actually
registering the object in the registry.
|
void |
MuleRegistry.registerAgent(Agent agent) |
void |
MuleRegistry.registerConnector(Connector connector) |
void |
MuleRegistry.registerEndpoint(ImmutableEndpoint endpoint) |
void |
MuleRegistry.registerEndpointBuilder(String name,
EndpointBuilder builder) |
void |
MuleRegistry.registerFlowConstruct(FlowConstruct flowConstruct) |
void |
MuleRegistry.registerModel(Model model)
Deprecated.
|
void |
MuleRegistry.registerScheduler(Scheduler scheduler) |
void |
MuleRegistry.registerService(Service service)
Deprecated.
|
void |
MuleRegistry.registerTransformer(Transformer transformer) |
void |
MuleRegistry.unregisterAgent(String agentName) |
void |
MuleRegistry.unregisterConnector(String connectorName) |
void |
MuleRegistry.unregisterEndpoint(String endpointName) |
void |
MuleRegistry.unregisterFlowConstruct(String flowConstructName) |
void |
MuleRegistry.unregisterModel(String modelName)
Deprecated.
|
void |
MuleRegistry.unregisterScheduler(Scheduler scheduler) |
void |
MuleRegistry.unregisterService(String serviceName)
Deprecated.
|
void |
MuleRegistry.unregisterTransformer(String transformerName) |
Modifier and Type | Class and Description |
---|---|
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. |
Modifier and Type | Method and Description |
---|---|
boolean |
Matchable.isMatch(MuleMessage message)
Determines if the event should be processed
|
Modifier and Type | Class and Description |
---|---|
class |
FilterUnacceptedException |
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 |
NotPermittedException
NotPermittedException is thrown if the user isn't authorized
to perform an action. |
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 | 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 |
Service.dispatchEvent(MuleEvent event)
Deprecated.
|
void |
Service.pause()
Deprecated.
Pauses event processing for a single Mule Service.
|
void |
Service.resume()
Deprecated.
Resumes a single Mule Service that has been paused.
|
MuleEvent |
Service.sendEvent(MuleEvent event)
Deprecated.
|
Modifier and Type | Method and Description |
---|---|
void |
CompositeMessageSource.addSource(MessageSource messageSource) |
void |
CompositeMessageSource.removeSource(MessageSource messageSource) |
Modifier and Type | Class and Description |
---|---|
class |
ObjectAlreadyExistsException |
class |
ObjectDoesNotExistException |
class |
ObjectStoreException
This exception class is thrown in cases when an exception occurs while operating on an
ObjectStore . |
class |
ObjectStoreNotAvaliableException
This exception is thrown when the underlying to an
ObjectStore 's system fails. |
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. |
class |
TransformerMessagingException
An exception that occurred while transforming a message.
|
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 MuleMessage instance is
to be created with an payload type that is not of supported type by that
MuleMessageFactory . |
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.
|
MuleMessage |
MessageRequester.createMuleMessage(Object transportMessage) |
MuleMessage |
MessageReceiver.createMuleMessage(Object transportMessage) |
MuleMessage |
MessageDispatcher.createMuleMessage(Object transportMessage) |
MuleMessage |
MessageRequester.createMuleMessage(Object transportMessage,
String encoding) |
MuleMessage |
MessageReceiver.createMuleMessage(Object transportMessage,
String encoding) |
MuleMessage |
MessageDispatcher.createMuleMessage(Object transportMessage,
String encoding) |
OutputStream |
Connector.getOutputStream(OutboundEndpoint endpoint,
MuleEvent event)
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) |
MuleSession |
SessionHandler.retrieveSessionInfoFromMessage(MuleMessage message) |
void |
SessionHandler.retrieveSessionInfoFromMessage(MuleMessage message,
MuleSession session)
Deprecated.
Use retrieveSessionInfoFromMessage(MuleMessage message) instead
|
MuleEvent |
MessageReceiver.routeMessage(MuleMessage message) |
MuleEvent |
MessageReceiver.routeMessage(MuleMessage message,
Transaction trans) |
MuleEvent |
MessageReceiver.routeMessage(MuleMessage message,
Transaction trans,
OutputStream outputStream) |
void |
SessionHandler.storeSessionInfoToMessage(MuleSession session,
MuleMessage message) |
Modifier and Type | Method and Description |
---|---|
void |
DefaultLocalMuleClient.dispatch(String url,
MuleMessage message) |
void |
DefaultLocalMuleClient.dispatch(String url,
MuleMessage message,
OperationOptions operationOptions) |
void |
DefaultLocalMuleClient.dispatch(String url,
Object payload,
Map<String,Object> messageProperties) |
MuleMessage |
DefaultLocalMuleClient.process(OutboundEndpoint endpoint,
MuleMessage message) |
MuleMessage |
DefaultLocalMuleClient.process(OutboundEndpoint endpoint,
Object payload,
Map<String,Object> messageProperties) |
MuleMessage |
DefaultLocalMuleClient.process(String uri,
MessageExchangePattern mep,
MuleMessage message) |
MuleMessage |
DefaultLocalMuleClient.process(String uri,
MessageExchangePattern mep,
Object payload,
Map<String,Object> messageProperties) |
MuleMessage |
DefaultLocalMuleClient.request(InboundEndpoint endpoint,
long timeout) |
MuleMessage |
DefaultLocalMuleClient.request(String url,
long timeout) |
MuleMessage |
DefaultLocalMuleClient.send(String url,
MuleMessage message) |
MuleMessage |
DefaultLocalMuleClient.send(String url,
MuleMessage message,
long timeout) |
MuleMessage |
DefaultLocalMuleClient.send(String url,
MuleMessage message,
OperationOptions operationOptions) |
MuleMessage |
DefaultLocalMuleClient.send(String url,
Object payload,
Map<String,Object> messageProperties) |
MuleMessage |
DefaultLocalMuleClient.send(String url,
Object payload,
Map<String,Object> messageProperties,
long timeout) |
Modifier and Type | Class and Description |
---|---|
class |
ComponentException
ComponentException should be thrown when some action on a component
fails, such as starting or stopping |
Modifier and Type | Method and Description |
---|---|
static void |
BindingUtils.configureBinding(JavaComponent component,
Object componentObject) |
LifecycleAdapter |
DefaultComponentLifecycleAdapterFactory.create(Object pojoService,
JavaComponent component,
FlowConstruct flowConstruct,
EntryPointResolverSet resolver,
MuleContext muleContext) |
protected MuleEvent |
AbstractComponent.createResultEvent(MuleEvent event,
Object result) |
protected void |
SimpleCallableJavaComponent.doStart() |
protected void |
PooledJavaComponent.doStart() |
protected void |
DefaultJavaComponent.doStart() |
protected void |
AbstractJavaComponent.doStart() |
protected void |
AbstractComponent.doStart() |
protected void |
SimpleCallableJavaComponent.doStop() |
protected void |
PooledJavaComponent.doStop() |
protected void |
DefaultJavaComponent.doStop() |
protected void |
AbstractComponent.doStop() |
void |
ComponentLifecycleManager.fireStartPhase(LifecycleCallback<Component> callback) |
void |
ComponentLifecycleManager.fireStopPhase(LifecycleCallback<Component> callback) |
Object |
DefaultComponentLifecycleAdapter.invoke(MuleEvent event) |
MuleEvent |
DefaultInterfaceBinding.process(MuleEvent event) |
MuleEvent |
AbstractComponent.process(MuleEvent event) |
void |
DefaultInterfaceBinding.setEndpoint(ImmutableEndpoint e) |
void |
NullLifecycleAdapter.start() |
void |
DefaultComponentLifecycleAdapter.start()
Propagates start() life-cycle to component object implementations if they
implement the mule
Startable interface. |
void |
AbstractComponent.start() |
void |
NullLifecycleAdapter.stop() |
void |
DefaultComponentLifecycleAdapter.stop()
Propagates stop() life-cycle to component object implementations if they
implement the mule
Stoppable interface. |
void |
AbstractComponent.stop() |
Constructor and Description |
---|
DefaultComponentLifecycleAdapter(Object componentObject,
JavaComponent component,
FlowConstruct flowConstruct,
EntryPointResolverSet entryPointResolver,
MuleContext muleContext) |
DefaultComponentLifecycleAdapter(Object componentObject,
JavaComponent component,
FlowConstruct flowConstruct,
MuleContext muleContext) |
NullLifecycleAdapter(Object componentObject,
JavaComponent component,
FlowConstruct flowConstruct,
EntryPointResolverSet entryPointResolver,
MuleContext muleContext) |
Modifier and Type | Method and Description |
---|---|
static MuleException |
ExceptionHelper.getRootMuleException(Throwable t) |
Modifier and Type | Class and Description |
---|---|
class |
BootstrapException
Represents exceptions during the bootstrap configuration process
|
Modifier and Type | Method and Description |
---|---|
protected void |
DefaultsConfigurationBuilder.configureSystemModel(MuleRegistry registry)
Deprecated.
|
Modifier and Type | Method and Description |
---|---|
boolean |
ContentBasedRouter.isMatch(MuleMessage message)
Deprecated.
|
Modifier and Type | Method and Description |
---|---|
protected abstract AnnotatedEndpointData |
AbstractEndpointAnnotationParser.createEndpointData(Annotation annotation) |
protected EndpointBuilder |
AnnotatedEndpointHelper.getEndpointBuilder(AnnotatedEndpointData epData) |
protected AnnotatedEndpointHelper |
AbstractEndpointAnnotationParser.getEndpointHelper() |
protected Properties |
ConfigurableTransportFactory.loadOverrides() |
InboundEndpoint |
AbstractEndpointAnnotationParser.parseInboundEndpoint(Annotation annotation,
Map metaInfo) |
OutboundEndpoint |
AbstractEndpointAnnotationParser.parseOutboundEndpoint(Annotation annotation,
Map metaInfo) |
ImmutableEndpoint |
AnnotatedEndpointHelper.processEndpoint(AnnotatedEndpointData epData) |
Constructor and Description |
---|
AnnotatedEndpointHelper(MuleContext muleContext) |
ConfigurableTransportFactory(MuleContext muleContext) |
Modifier and Type | Method and Description |
---|---|
protected void |
DecoratingAnnotatedServiceProcessor.processInbound(Class componentFactoryClass,
Service service) |
protected void |
DecoratingAnnotatedServiceProcessor.processInboundRouters(Class componentFactoryClass,
Service service) |
protected void |
DecoratingAnnotatedServiceProcessor.processOutbound(Class componentFactoryClass,
Service service) |
protected OutboundRouter |
DecoratingAnnotatedServiceProcessor.processOutboundRouter(Class componentFactoryClass) |
protected void |
DecoratingAnnotatedServiceProcessor.processReply(Class componentFactoryClass,
Service service) |
protected void |
DecoratingAnnotatedServiceProcessor.processReplyRouters(Class componentFactoryClass,
Service service) |
protected InboundEndpoint |
DecoratingAnnotatedServiceProcessor.tryInboundEndpointAnnotation(AnnotationMetaData metaData,
ChannelType channelType) |
protected OutboundEndpoint |
DecoratingAnnotatedServiceProcessor.tryOutboundEndpointAnnotation(AnnotationMetaData metaData,
ChannelType channelType) |
Modifier and Type | Method and Description |
---|---|
MuleEvent |
AggregationStrategyDefinitionParser.AggregationStrategyDelegate.aggregate(AggregationContext context) |
protected MessageProcessor |
FlowRefFactoryBean.createDynamicReferenceMessageProcessor(String name) |
protected AbstractFlowConstruct |
AbstractFlowConstructFactoryBean.createFlowConstruct() |
protected MessageProcessor |
FlowRefFactoryBean.getReferencedFlow(String name,
FlowConstruct flowConstruct) |
Modifier and Type | Method and Description |
---|---|
MessageProcessor |
MuleConnectorOperationLocator.locateConnectorOperation(String url,
OperationOptions operationOptions,
MessageExchangePattern exchangePattern) |
Modifier and Type | Method and Description |
---|---|
protected void |
Flow.configureMessageProcessors(MessageProcessorChainBuilder builder) |
protected void |
AbstractPipeline.configureMessageProcessors(MessageProcessorChainBuilder builder) |
protected void |
AbstractConfigurationPattern.configureMessageProcessors(MessageProcessorChainBuilder builder) |
protected abstract void |
AbstractConfigurationPattern.configureMessageProcessorsAfterTransformation(MessageProcessorChainBuilder builder) |
protected abstract void |
AbstractConfigurationPattern.configureMessageProcessorsBeforeTransformation(MessageProcessorChainBuilder builder) |
protected void |
Flow.configurePostProcessors(MessageProcessorChainBuilder builder) |
protected void |
AbstractPipeline.configurePostProcessors(MessageProcessorChainBuilder builder) |
protected void |
Flow.configurePreProcessors(MessageProcessorChainBuilder builder) |
protected void |
AbstractPipeline.configurePreProcessors(MessageProcessorChainBuilder builder) |
protected void |
AbstractConfigurationPattern.configurePreProcessors(MessageProcessorChainBuilder builder) |
protected MessageProcessor |
AbstractPipeline.createPipeline()
Creates a
MessageProcessor that will process messages from the configured MessageSource
. |
protected void |
Validator.doInitialise() |
protected void |
AbstractPipeline.doInitialise() |
protected void |
AbstractFlowConstruct.doInitialise() |
protected void |
AbstractPipeline.doStart() |
protected void |
AbstractFlowConstruct.doStart() |
protected void |
AbstractPipeline.doStop() |
protected void |
AbstractFlowConstruct.doStop() |
void |
FlowConstructLifecycleManager.fireDisposePhase(LifecycleCallback<FlowConstruct> callback) |
void |
FlowConstructLifecycleManager.fireInitialisePhase(LifecycleCallback<FlowConstruct> callback) |
void |
FlowConstructLifecycleManager.firePausePhase(LifecycleCallback<FlowConstruct> callback) |
void |
FlowConstructLifecycleManager.fireResumePhase(LifecycleCallback<FlowConstruct> callback) |
void |
FlowConstructLifecycleManager.fireStartPhase(LifecycleCallback<FlowConstruct> callback) |
void |
FlowConstructLifecycleManager.fireStopPhase(LifecycleCallback<FlowConstruct> callback) |
MuleEvent |
Flow.process(MuleEvent event) |
MuleEvent |
DynamicPipelineMessageProcessor.process(MuleEvent event) |
void |
AbstractFlowConstruct.start() |
protected void |
AbstractFlowConstruct.startIfStartable(Object candidate) |
void |
AbstractFlowConstruct.stop() |
protected void |
AbstractFlowConstruct.stopIfStoppable(Object candidate) |
Constructor and Description |
---|
SimpleService(String name,
MuleContext muleContext,
MessageSource messageSource,
List<MessageProcessor> transformers,
List<MessageProcessor> responseTransformers,
Component component,
SimpleService.Type type) |
Modifier and Type | Method and Description |
---|---|
F |
AbstractFlowConstructBuilder.build(MuleContext muleContext) |
F |
AbstractFlowConstructBuilder.buildAndRegister(MuleContext muleContext) |
protected Validator |
ValidatorBuilder.buildFlowConstruct(MuleContext muleContext) |
protected SimpleService |
SimpleServiceBuilder.buildFlowConstruct(MuleContext muleContext) |
protected Bridge |
BridgeBuilder.buildFlowConstruct(MuleContext muleContext) |
protected abstract F |
AbstractFlowConstructBuilder.buildFlowConstruct(MuleContext muleContext) |
protected InboundEndpoint |
AbstractFlowConstructWithSingleInboundEndpointBuilder.getOrBuildInboundEndpoint(MuleContext muleContext) |
protected OutboundEndpoint |
AbstractFlowConstructWithSingleInboundAndOutboundEndpointBuilder.getOrBuildOutboundEndpoint(MuleContext muleContext) |
Modifier and Type | Method and Description |
---|---|
MuleEvent |
FlowConstructStatisticsMessageProcessor.process(MuleEvent event) |
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 |
---|---|
MuleEvent |
DevkitBasedMessageProcessor.process(MuleEvent event)
This final process implementation shields actual processing into abstract
method
DevkitBasedMessageProcessor.doProcess(org.mule.api.MuleEvent) . |
void |
DevkitBasedMessageProcessor.start() |
void |
DevkitBasedMessageProcessor.stop() |
Modifier and Type | Method and Description |
---|---|
MuleEvent |
ExpressionLanguageComponent.process(MuleEvent event) |
Modifier and Type | Method and Description |
---|---|
MessageProcessor |
DefaultEndpointMessageProcessorChainFactory.createInboundMessageProcessorChain(InboundEndpoint endpoint,
FlowConstruct flowConstruct,
MessageProcessor target) |
protected MessageProcessor |
DefaultOutboundEndpoint.createMessageProcessorChain(FlowConstruct flowContruct) |
MessageProcessor |
DefaultInboundEndpoint.createMessageProcessorChain(FlowConstruct flowContruct) |
protected abstract MessageProcessor |
AbstractEndpoint.createMessageProcessorChain(FlowConstruct flowContruct) |
MessageProcessor |
DefaultEndpointMessageProcessorChainFactory.createOutboundMessageProcessorChain(OutboundEndpoint endpoint,
MessageProcessor target) |
protected List<MessageProcessor> |
DefaultEndpointMessageProcessorChainFactory.createOutboundMessageProcessors(OutboundEndpoint endpoint)
Override this method to change the default MessageProcessors.
|
protected List<MessageProcessor> |
DefaultEndpointMessageProcessorChainFactory.createOutboundResponseMessageProcessors(OutboundEndpoint endpoint)
Override this method to change the default MessageProcessors.
|
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) |
InboundEndpoint |
SimpleEndpointCache.getInboundEndpoint(String uri,
MessageExchangePattern mep) |
MessageProcessor |
AbstractEndpoint.getMessageProcessorChain(FlowConstruct flowContruct) |
OutboundEndpoint |
DefaultEndpointFactory.getOutboundEndpoint(EndpointBuilder builder) |
OutboundEndpoint |
DefaultEndpointFactory.getOutboundEndpoint(EndpointURI uri) |
OutboundEndpoint |
DefaultEndpointFactory.getOutboundEndpoint(String uri) |
OutboundEndpoint |
SimpleEndpointCache.getOutboundEndpoint(String uri,
MessageExchangePattern mep,
Long responseTimeout) |
OutboundEndpoint |
DynamicOutboundEndpoint.getStaticEndpoint(MuleEvent event) |
protected MessageProcessor |
EndpointMessageProcessorChainBuilder.initializeMessageProcessor(Object processor) |
MuleEvent |
DynamicURIOutboundEndpoint.process(MuleEvent event) |
MuleEvent |
DynamicOutboundEndpoint.process(MuleEvent event) |
MuleEvent |
DefaultOutboundEndpoint.process(MuleEvent event) |
void |
DynamicURIInboundEndpoint.start() |
void |
DefaultInboundEndpoint.start() |
void |
DynamicURIInboundEndpoint.stop() |
void |
DefaultInboundEndpoint.stop() |
Modifier and Type | Method and Description |
---|---|
protected void |
NullConnector.doStart() |
protected void |
NullConnector.doStop() |
Constructor and Description |
---|
NullConnector(MuleContext context) |
Modifier and Type | Method and Description |
---|---|
MuleEvent |
InboundNotificationMessageProcessor.process(MuleEvent event) |
MuleEvent |
InboundLoggingMessageProcessor.process(MuleEvent event) |
MuleEvent |
InboundExceptionDetailsMessageProcessor.process(MuleEvent event) |
MuleEvent |
InboundEndpointPropertyMessageProcessor.process(MuleEvent event) |
Modifier and Type | Method and Description |
---|---|
MuleEvent |
OutboundTxRollbackMessageProcessor.process(MuleEvent event) |
MuleEvent |
OutboundSessionHandlerMessageProcessor.process(MuleEvent event) |
MuleEvent |
OutboundRootMessageIdPropertyMessageProcessor.process(MuleEvent event) |
MuleEvent |
OutboundResponsePropertiesMessageProcessor.process(MuleEvent event) |
MuleEvent |
OutboundNotificationMessageProcessor.process(MuleEvent event) |
MuleEvent |
OutboundLoggingMessageProcessor.process(MuleEvent event) |
MuleEvent |
OutboundEventTimeoutMessageProcessor.process(MuleEvent event) |
MuleEvent |
OutboundEndpointPropertyMessageProcessor.process(MuleEvent event) |
Modifier and Type | Method and Description |
---|---|
MuleEvent |
MessageEnricher.process(MuleEvent event) |
Modifier and Type | Method and Description |
---|---|
MuleEvent |
RedeliveryExceeded.process(MuleEvent event) |
Modifier and Type | Class and Description |
---|---|
class |
ResponseDispatchException
Exception thrown when there's a failure writing the response using the transport infrastructure.
|
Modifier and Type | Method and Description |
---|---|
void |
FlowProcessingPhaseTemplate.afterFailureProcessingFlow(MuleException exception)
Call when the processing of the message through the flow fails in an exception strategy
|
Modifier and Type | Method and Description |
---|---|
void |
FlowProcessingPhaseTemplate.afterFailureProcessingFlow(MessagingException messagingException)
Call when the processing of the message through the flow fails.
|
void |
FlowProcessingPhaseTemplate.afterFailureProcessingFlow(MuleException exception)
Call when the processing of the message through the flow fails in an exception strategy
|
MuleEvent |
FlowProcessingPhaseTemplate.afterRouteEvent(MuleEvent muleEvent)
Post processing of the routed
MuleEvent |
void |
FlowProcessingPhaseTemplate.afterSuccessfulProcessingFlow(MuleEvent muleEvent)
Call after successfully processing the message through the flow
This method will always be called when the flow execution was successful.
|
MuleEvent |
FlowProcessingPhaseTemplate.beforeRouteEvent(MuleEvent muleEvent)
Pre processing of the
MuleEvent to route |
void |
ValidationPhaseTemplate.discardInvalidMessage()
Discards the message because the validation failed
|
void |
ThrottlingPhaseTemplate.discardMessageOnThrottlingExceeded()
Discards the message due to ThrottlingPolicy configured for the
MessageSource is exceeded |
MuleEvent |
ThrottlingPhaseTemplate.getMuleEvent() |
MuleEvent |
FlowProcessingPhaseTemplate.getMuleEvent() |
MuleEvent |
AsyncResponseFlowProcessingPhaseTemplate.getMuleEvent() |
Object |
FlowProcessingPhaseTemplate.getOriginalMessage() |
MuleEvent |
FlowProcessingPhaseTemplate.routeEvent(MuleEvent muleEvent)
Routes the
MuleEvent through the processors chain |
MuleEvent |
AsyncResponseFlowProcessingPhaseTemplate.routeEvent(MuleEvent muleEvent)
Routes the
MuleEvent through the processors chain |
void |
RequestResponseFlowProcessingPhaseTemplate.sendFailureResponseToClient(MessagingException messagingException) |
void |
AsyncResponseFlowProcessingPhaseTemplate.sendFailureResponseToClient(MessagingException messagingException,
ResponseCompletionCallback responseCompletionCallback) |
void |
RequestResponseFlowProcessingPhaseTemplate.sendResponseToClient(MuleEvent muleEvent)
Template method to send a response after processing the message.
|
void |
AsyncResponseFlowProcessingPhaseTemplate.sendResponseToClient(MuleEvent muleEvent,
ResponseCompletionCallback responseCompletionCallback)
Template method to send a response after processing the message.
|
Modifier and Type | Method and Description |
---|---|
MuleEvent |
ProcessingTimeInterceptor.after(MuleEvent event) |
abstract MuleEvent |
AbstractEnvelopeInterceptor.after(MuleEvent event)
This method is invoked after the event has been processed, unless an exception was thrown
|
MuleEvent |
ProcessingTimeInterceptor.before(MuleEvent event) |
abstract MuleEvent |
AbstractEnvelopeInterceptor.before(MuleEvent event)
This method is invoked before the event is processed
|
MuleEvent |
ProcessingTimeInterceptor.last(MuleEvent event,
ProcessingTime time,
long startTime,
boolean exceptionWasThrown) |
MuleEvent |
LoggingInterceptor.last(MuleEvent event,
ProcessingTime time,
long startTime,
boolean exceptionWasThrown) |
abstract MuleEvent |
AbstractEnvelopeInterceptor.last(MuleEvent event,
ProcessingTime time,
long startTime,
boolean exceptionWasThrown)
This method is always invoked after the event has been processed,
|
MuleEvent |
TimerInterceptor.process(MuleEvent event) |
MuleEvent |
InterceptorStack.process(MuleEvent event) |
MuleEvent |
AbstractEnvelopeInterceptor.process(MuleEvent event) |
Modifier and Type | Method and Description |
---|---|
abstract void |
SimpleLifecycleManager.fireDisposePhase(LifecycleCallback<O> callback) |
abstract void |
SimpleLifecycleManager.fireInitialisePhase(LifecycleCallback<O> callback) |
abstract void |
SimpleLifecycleManager.fireStartPhase(LifecycleCallback<O> callback) |
void |
DefaultLifecycleManager.fireStartPhase(LifecycleCallback<T> callback) |
abstract void |
SimpleLifecycleManager.fireStopPhase(LifecycleCallback<O> callback) |
void |
DefaultLifecycleManager.fireStopPhase(LifecycleCallback<T> callback) |
void |
EmptyLifecycleCallback.onTransition(String phaseName,
O object) |
Modifier and Type | Method and Description |
---|---|
MuleEvent |
ProcessIfStartedWaitIfSyncPausedMessageProcessor.process(MuleEvent event) |
MuleEvent |
ProcessIfStartedWaitIfPausedMessageProcessor.process(MuleEvent event) |
Modifier and Type | Method and Description |
---|---|
void |
DefaultProcessingTimeWatcher.start() |
void |
DefaultProcessingTimeWatcher.stop() |
Modifier and Type | Method and Description |
---|---|
void |
ModelLifecycleManager.fireDisposePhase(LifecycleCallback<AbstractModel> callback)
Deprecated.
|
void |
ModelLifecycleManager.fireInitialisePhase(LifecycleCallback<AbstractModel> callback)
Deprecated.
|
void |
ModelLifecycleManager.fireStartPhase(LifecycleCallback<AbstractModel> callback)
Deprecated.
|
void |
ModelLifecycleManager.fireStopPhase(LifecycleCallback<AbstractModel> callback)
Deprecated.
|
void |
AbstractModel.start()
Deprecated.
Starts all registered components
|
void |
AbstractModel.stop()
Deprecated.
Stops any registered components
|
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.doPause()
Deprecated.
|
protected void |
SedaService.doResume()
Deprecated.
|
Modifier and Type | Method and Description |
---|---|
Object |
AbderaServiceComponent.AbderaCallable.onCall(MuleEventContext event) |
Modifier and Type | Method and Description |
---|---|
protected List<MuleMessage> |
FeedSplitter.splitMessage(MuleEvent event) |
Modifier and Type | Method and Description |
---|---|
MuleMessage |
Rules.generateMessage(String endpoint,
Object payload,
Map messageProperties,
MessageExchangePattern exchangePattern) |
MuleMessage |
Process.generateMessage(String endpoint,
Object payload,
Map messageProperties,
MessageExchangePattern exchangePattern) |
Modifier and Type | Method and Description |
---|---|
FutureMessageResult |
RemoteDispatcher.asyncReceiveRemote(String endpoint,
int timeout)
Deprecated.
|
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<String,Object> messageProperties)
Dispatches an event asynchronously to a endpointUri via a Mule server.
|
protected MuleMessage |
RemoteDispatcher.dispatchAction(RemoteDispatcherNotification action,
boolean synchronous,
int timeout)
Deprecated.
|
void |
MuleClient.dispatchDirect(String componentName,
MuleMessage message)
Deprecated.
|
void |
MuleClient.dispatchDirect(String component,
Object payload,
Map<String,Object> messageProperties)
Deprecated.
|
void |
RemoteDispatcher.dispatchRemote(String endpoint,
Object payload,
Map messageProperties)
Deprecated.
|
void |
RemoteDispatcher.dispatchToRemoteComponent(String component,
Object payload,
Map messageProperties)
Deprecated.
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)
Deprecated.
|
protected MuleMessage |
RemoteDispatcher.doToRemoteComponent(String component,
Object payload,
Map messageProperties,
boolean synchronous)
Deprecated.
|
protected InboundEndpoint |
MuleClient.getDefaultClientEndpoint(Service service,
Object payload,
boolean sync) |
protected MuleEvent |
MuleClient.getEvent(MuleMessage message,
MessageExchangePattern exchangePattern) |
protected InboundEndpoint |
MuleClient.getInboundEndpoint(String uri) |
protected OutboundEndpoint |
MuleClient.getOutboundEndpoint(String uri,
MessageExchangePattern exchangePattern,
Integer responseTimeout) |
RemoteDispatcher |
MuleClient.getRemoteDispatcher(String serverEndpoint)
Deprecated.
|
RemoteDispatcher |
MuleClient.getRemoteDispatcher(String serverEndpoint,
String user,
String password)
Deprecated.
|
MuleMessage |
RemoteDispatcher.receiveRemote(String endpoint,
int timeout)
Deprecated.
|
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()
Deprecated.
|
MuleMessage |
MuleClient.send(String url,
MuleMessage message)
Sends an event synchronously to a endpointUri via a Mule server and a
resulting message is returned.
|
MuleMessage |
MuleClient.send(String url,
MuleMessage message,
int timeout)
Sends an event synchronously to a endpointUri via a mule server and a
resulting message is returned.
|
MuleMessage |
MuleClient.send(String url,
Object payload,
Map<String,Object> messageProperties)
Sends an event synchronously to a endpointUri via a Mule server and a
resulting message is returned.
|
MuleMessage |
MuleClient.send(String url,
Object payload,
Map<String,Object> messageProperties,
int timeout)
Sends an event synchronously to a endpointUri via a mule server and a
resulting message is returned.
|
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<String,Object> 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<String,Object> 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)
Deprecated.
|
FutureMessageResult |
RemoteDispatcher.sendAsyncToRemoteComponent(String component,
String transformers,
Object payload,
Map messageProperties)
Deprecated.
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)
Deprecated.
|
MuleMessage |
MuleClient.sendDirect(String component,
String transformers,
Object payload,
Map<String,Object> messageProperties)
Deprecated.
|
FutureMessageResult |
MuleClient.sendDirectAsync(String component,
String transformers,
MuleMessage message)
Deprecated.
|
FutureMessageResult |
MuleClient.sendDirectAsync(String component,
String transformers,
Object payload,
Map<String,Object> messageProperties)
Deprecated.
|
void |
MuleClient.sendNoReceive(String url,
Object payload,
Map<String,Object> 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)
Deprecated.
|
MuleMessage |
RemoteDispatcher.sendRemote(String endpoint,
Object payload,
Map messageProperties,
int timeout)
Deprecated.
|
MuleMessage |
RemoteDispatcher.sendToRemoteComponent(String component,
Object payload,
Map messageProperties)
Deprecated.
sends an event synchronously to a components on a remote Mule instance.
|
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)
Deprecated.
|
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 |
RemoteDispatcher(String endpoint,
Credentials credentials,
MuleContext muleContext)
Deprecated.
|
RemoteDispatcher(String endpoint,
MuleContext muleContext)
Deprecated.
|
Modifier and Type | Class and Description |
---|---|
class |
RemoteDispatcherException
Deprecated.
|
class |
UnsupportedWireFormatException
Deprecated.
|
Modifier and Type | Method and Description |
---|---|
static Service |
RemoteDispatcherComponent.getSerivce(InboundEndpoint endpoint,
WireFormat wireFormat,
String encoding,
int eventTimeout,
MuleContext muleContext)
Deprecated.
|
protected Object |
RemoteDispatcherComponent.invokeAction(RemoteDispatcherNotification action,
MuleEventContext context)
Deprecated.
|
protected Object |
RemoteDispatcherComponent.receiveAction(RemoteDispatcherNotification action,
MuleEventContext context)
Deprecated.
|
protected Object |
RemoteDispatcherComponent.sendAction(RemoteDispatcherNotification action,
MuleEventContext context)
Deprecated.
|
void |
RemoteDispatcherAgent.start()
Deprecated.
|
void |
RemoteDispatcherAgent.stop()
Deprecated.
|
Modifier and Type | Method and Description |
---|---|
static CxfConfiguration |
CxfConfiguration.getConfiguration(MuleContext muleContext) |
protected InputStream |
CxfInboundMessageProcessor.getMessageStream(MuleEvent context)
Gets the stream representation of the current message.
|
MuleEvent |
CxfOutboundMessageProcessor.process(MuleEvent event) |
MuleEvent |
CxfInboundMessageProcessor.process(MuleEvent event) |
MuleEvent |
CxfOutboundMessageProcessor.processNext(MuleEvent event)
This method is public so it can be invoked from the MuleUniversalConduit.
|
MuleEvent |
CxfInboundMessageProcessor.processNext(MuleEvent event) |
protected MuleEvent |
CxfInboundMessageProcessor.sendToDestination(MuleEvent event) |
void |
CxfInboundMessageProcessor.start() |
void |
CxfInboundMessageProcessor.stop() |
Modifier and Type | Method and Description |
---|---|
CxfOutboundMessageProcessor |
AbstractOutboundMessageProcessorBuilder.build() |
CxfInboundMessageProcessor |
AbstractInboundMessageProcessorBuilder.build() |
protected Class<?> |
WebServiceMessageProcessorBuilder.getTargetClass(Service service)
Try to determine the target class from the Service.
|
Modifier and Type | Method and Description |
---|---|
MuleEvent |
FlowConfiguringMessageProcessor.process(MuleEvent event) |
void |
FlowConfiguringMessageProcessor.start() |
void |
FlowConfiguringMessageProcessor.stop() |
Modifier and Type | Class and Description |
---|---|
class |
WebServiceSecurityException |
Modifier and Type | Method and Description |
---|---|
protected void |
MuleUniversalConduit.dispatchMuleMessage(org.apache.cxf.message.Message m,
MuleEvent reqEvent,
OutboundEndpoint endpoint) |
protected OutboundEndpoint |
MuleUniversalConduit.getEndpoint(MuleContext muleContext,
String uri) |
protected MuleEvent |
MuleUniversalConduit.processNext(MuleEvent event,
org.apache.cxf.message.Exchange exchange,
OutboundEndpoint endpoint) |
Modifier and Type | Method and Description |
---|---|
MuleEvent |
AbstractDbMessageProcessor.process(MuleEvent muleEvent) |
Modifier and Type | Method and Description |
---|---|
void |
ResultSetIterator.close() |
Modifier and Type | Method and Description |
---|---|
void |
CloseableMap.close() |
Modifier and Type | Method and Description |
---|---|
protected EndpointBuilder |
AbstractMuleGuiceModule.createEndpointBuilder(String uri)
Deprecated.
Creates an
EndpointBuilder instance for the endpoint uri. |
Modifier and Type | Method and Description |
---|---|
void |
HttpAuthentication.authenticate(MuleEvent muleEvent,
HttpRequestBuilder builder)
Adds authentication information to the request.
|
boolean |
HttpAuthentication.shouldRetry(MuleEvent firstAttemptResponseEvent)
Detects if there was an authentication failure in the response.
|
Modifier and Type | Method and Description |
---|---|
HttpListener |
HttpListenerBuilder.build() |
void |
HttpListenerConfig.start()
Starts the listening for incoming request.
|
void |
HttpListener.start()
Starts an stopped listener.
|
void |
HttpListenerConfig.stop()
Stops listening for incoming request.
|
void |
HttpListener.stop()
Stops this listener.
|
Modifier and Type | Method and Description |
---|---|
HttpListenerConfig |
HttpListenerConfigBuilder.build() |
void |
HttpMessageProcessorTemplate.discardMessageOnThrottlingExceeded() |
MuleEvent |
HttpMessageProcessorTemplate.getMuleEvent() |
MuleEvent |
HttpMessageProcessorTemplate.routeEvent(MuleEvent muleEvent) |
void |
HttpMessageProcessorTemplate.sendFailureResponseToClient(MessagingException messagingException,
ResponseCompletionCallback responseCompletationCallback) |
void |
HttpMessageProcessorTemplate.sendResponseToClient(MuleEvent muleEvent,
ResponseCompletionCallback responseCompletationCallback) |
void |
DefaultHttpListenerConfig.start() |
void |
DefaultHttpListener.start() |
void |
DefaultHttpListenerConfig.stop() |
void |
DefaultHttpListener.stop() |
Modifier and Type | Class and Description |
---|---|
class |
ResponseValidatorException |
Modifier and Type | Method and Description |
---|---|
MuleEvent |
DefaultHttpRequester.process(MuleEvent muleEvent) |
void |
DefaultHttpRequesterConfig.start() |
void |
DefaultHttpRequesterConfig.stop() |
Modifier and Type | Method and Description |
---|---|
DefaultHttpRequester |
HttpRequesterBuilder.build() |
MessageProcessor |
HttpConnectorMessageProcessorProvider.getMessageProcessor(String url,
OperationOptions operationOptions,
MessageExchangePattern exchangePattern) |
MuleEvent |
OneWayHttpRequesterAdapter.process(MuleEvent event) |
Modifier and Type | Class and Description |
---|---|
class |
JsonSchemaValidationException
Exception to signal that a given json did not
pass validation against a json schema
|
Modifier and Type | Method and Description |
---|---|
MuleEvent |
ValidateJsonSchemaMessageProcessor.process(MuleEvent event) |
void |
JsonSchemaValidator.validate(MuleEvent event)
Parses the
event 's payload as a Json by the rules of
DefaultJsonParser.asJsonNode(Object) . |
Modifier and Type | Method and Description |
---|---|
protected void |
MuleContainer.doShutdown() |
void |
MuleContainer.shutdown()
shutdown the server.
|
void |
MuleContainer.shutdown(Throwable e)
Will shut down the server displaying the cause and time of the shutdown
|
void |
MuleContainer.start(boolean registerShutdownHook) |
void |
MuleContainer.stop() |
Modifier and Type | Method and Description |
---|---|
void |
DefaultMuleCoreExtensionManager.start() |
void |
DefaultMuleCoreExtensionManager.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 |
JmxDomainAgent.registerServices() |
protected void |
JmxApplicationAgent.registerServices() |
protected abstract void |
AbstractJmxAgent.registerServices() |
protected void |
AbstractJmxAgent.registerWrapperService()
Register a Java Service Wrapper agent.
|
void |
YourKitProfilerAgent.start() |
void |
WrapperManagerAgent.start() |
void |
RmiRegistryAgent.start() |
void |
Mx4jAgent.start() |
void |
Log4jAgent.start()
Deprecated.
|
void |
JdmkAgent.start() |
void |
DefaultJmxSupportAgent.start() |
void |
AbstractJmxAgent.start() |
void |
YourKitProfilerAgent.stop() |
void |
WrapperManagerAgent.stop() |
void |
RmiRegistryAgent.stop() |
void |
Mx4jAgent.stop() |
void |
Log4jAgent.stop()
Deprecated.
|
void |
JdmkAgent.stop() |
void |
DefaultJmxSupportAgent.stop() |
void |
AbstractJmxAgent.stop() |
Modifier and Type | Method and Description |
---|---|
void |
ServiceServiceMBean.dispose()
Deprecated.
|
void |
ServiceService.dispose() |
void |
MuleServiceMBean.dispose() |
void |
MuleService.dispose() |
void |
ServiceServiceMBean.forceStop()
Deprecated.
Causes the service to stop without processing its event queue first
|
void |
ServiceService.forceStop() |
void |
ServiceServiceMBean.pause()
Deprecated.
Pauses event processing for theComponent.
|
void |
ServiceService.pause()
Pauses event processing for theComponent.
|
void |
ServiceServiceMBean.resume()
Deprecated.
Resumes the Service that has been paused.
|
void |
ServiceService.resume()
Resumes the Service that has been paused.
|
void |
ServiceService.start() |
void |
RegistryServiceMBean.start() |
void |
MuleServiceMBean.start() |
void |
MuleService.start() |
void |
ModelServiceMBean.start() |
void |
ModelService.start()
Deprecated.
|
void |
ConnectorServiceMBean.startConnector() |
void |
ConnectorService.startConnector() |
void |
ServiceService.stop() |
void |
RegistryServiceMBean.stop() |
void |
MuleServiceMBean.stop() |
void |
MuleService.stop() |
void |
ModelServiceMBean.stop() |
void |
ModelService.stop()
Deprecated.
|
void |
ConnectorServiceMBean.stopConnector() |
void |
ConnectorService.stopConnector() |
Modifier and Type | Class and Description |
---|---|
class |
RequestAuthenticationException
Exception throw when it's not possible to create the authentication request for a given request.
|
Modifier and Type | Method and Description |
---|---|
static Flow |
DynamicFlowFactory.createDynamicFlow(MuleContext muleContext,
String flowName,
List<MessageProcessor> messageProcessors)
Creates a programmatic flow
|
protected MuleEvent |
AbstractTokenRequestHandler.invokeTokenUrl(MuleEvent event) |
Modifier and Type | Method and Description |
---|---|
void |
DefaultAuthorizationCodeGrantType.authenticate(MuleEvent muleEvent,
HttpRequestBuilder builder) |
protected void |
AbstractAuthorizationCodeTokenRequestHandler.createListenerForRedirectUrl() |
protected abstract void |
AbstractAuthorizationCodeTokenRequestHandler.doRefreshToken(MuleEvent currentEvent,
ResourceOwnerOAuthContext resourceOwnerOAuthContext)
ThreadSafe refresh token operation to be implemented by subclasses
|
void |
AutoAuthorizationCodeTokenRequestHandler.init()
Starts the http listener for the redirect url callback.
|
void |
AuthorizationRequestHandler.init() |
void |
AbstractAuthorizationCodeTokenRequestHandler.init()
initialization method after configuration.
|
void |
DefaultAuthorizationCodeGrantType.refreshToken(MuleEvent currentFlowEvent,
String resourceOwnerId) |
void |
AuthorizationCodeGrantType.refreshToken(MuleEvent currentFlowEvent,
String resourceOwnerId)
Does a refresh token for a particular oauth context id.
|
void |
AbstractAuthorizationCodeTokenRequestHandler.refreshToken(MuleEvent currentEvent,
String resourceOwnerId)
Updates the access token by calling the token url with refresh token grant type
|
void |
DefaultAuthorizationCodeGrantType.start() |
Modifier and Type | Method and Description |
---|---|
void |
ClientCredentialsGrantType.authenticate(MuleEvent muleEvent,
HttpRequestBuilder builder) |
void |
ClientCredentialsTokenRequestHandler.refreshAccessToken() |
void |
ClientCredentialsGrantType.refreshAccessToken() |
void |
ClientCredentialsGrantType.start() |
Modifier and Type | Method and Description |
---|---|
MuleEvent |
InvalidateOauthContextMessageProcessor.process(MuleEvent event) |
Modifier and Type | Method and Description |
---|---|
protected List<MuleMessage> |
FeedSplitter.splitMessage(MuleEvent event) |
Constructor and Description |
---|
ScriptConfigurationBuilder(String configResource)
Deprecated.
|
ScriptConfigurationBuilder(String[] configResources)
Deprecated.
|
ScriptConfigurationBuilder(String scriptEngineName,
String configResource)
Deprecated.
|
ScriptConfigurationBuilder(String scriptEngineName,
String[] configResources)
Deprecated.
|
Modifier and Type | Method and Description |
---|---|
protected void |
ScriptComponent.configureComponentBindings() |
Modifier and Type | Method and Description |
---|---|
protected Service |
MuleEventMulticaster.getDefaultService()
Deprecated.
|
protected void |
MuleEventMulticaster.registerMulticasterComponent()
Deprecated.
|
protected void |
MuleEventMulticaster.setSubscriptionsOnService(Service service)
Deprecated.
|
Modifier and Type | Method and Description |
---|---|
boolean |
SxcFilteringOutboundRouter.isMatch(MuleMessage message) |
boolean |
SxcFilteringOutboundRouter.testMatch(MuleMessage message) |
Constructor and Description |
---|
WSProxy(String name,
MuleContext muleContext,
MessageSource messageSource,
OutboundEndpoint outboundEndpoint,
List<MessageProcessor> transformers,
List<MessageProcessor> responseTransformers) |
WSProxy(String name,
MuleContext muleContext,
MessageSource messageSource,
OutboundEndpoint outboundEndpoint,
List<MessageProcessor> transformers,
List<MessageProcessor> responseTransformers,
String wsdlContents) |
WSProxy(String name,
MuleContext muleContext,
MessageSource messageSource,
OutboundEndpoint outboundEndpoint,
List<MessageProcessor> transformers,
List<MessageProcessor> responseTransformers,
URI wsdlUri) |
Modifier and Type | Method and Description |
---|---|
protected WSProxy |
WSProxyBuilder.buildFlowConstruct(MuleContext muleContext) |
Modifier and Type | Class and Description |
---|---|
class |
SoapFaultException
Exception thrown by the Web Services Consumer when processing a SOAP fault.
|
Modifier and Type | Method and Description |
---|---|
MessageProcessor |
WSConsumerConfig.createOutboundMessageProcessor()
Creates an outbound endpoint for the service address.
|
MuleEvent |
WSConsumer.process(MuleEvent event) |
Modifier and Type | Method and Description |
---|---|
void |
CronScheduler.start() |
void |
CronScheduler.stop() |
Modifier and Type | Method and Description |
---|---|
protected MuleException |
AbstractFilteringMessageProcessor.filterUnacceptedException(MuleEvent event) |
Modifier and Type | Method and Description |
---|---|
protected MuleEvent |
InvokerMessageProcessor.createResultEvent(MuleEvent event,
Object result) |
void |
SedaStageLifecycleManager.firePausePhase(LifecycleCallback<SedaStageInterceptingMessageProcessor> callback) |
void |
SedaStageLifecycleManager.fireResumePhase(LifecycleCallback<SedaStageInterceptingMessageProcessor> callback) |
void |
SedaStageLifecycleManager.fireStartPhase(LifecycleCallback<SedaStageInterceptingMessageProcessor> callback) |
void |
SedaStageLifecycleManager.fireStopPhase(LifecycleCallback<SedaStageInterceptingMessageProcessor> callback) |
protected MuleEvent |
AbstractFilteringMessageProcessor.handleUnaccepted(MuleEvent event) |
void |
SedaStageInterceptingMessageProcessor.pause() |
MuleEvent |
TransactionalInterceptingMessageProcessor.process(MuleEvent event) |
MuleEvent |
StopFurtherMessageProcessingMessageProcessor.process(MuleEvent event) |
MuleEvent |
SecurityFilterMessageProcessor.process(MuleEvent event) |
MuleEvent |
NullMessageProcessor.process(MuleEvent event) |
MuleEvent |
InvokerMessageProcessor.process(MuleEvent event) |
MuleEvent |
IdempotentRedeliveryPolicy.process(MuleEvent event) |
MuleEvent |
ExceptionHandlingMessageProcessor.process(MuleEvent event) |
MuleEvent |
EndpointTransactionalInterceptingMessageProcessor.process(MuleEvent event) |
MuleEvent |
AsyncInterceptingMessageProcessor.process(MuleEvent event) |
MuleEvent |
AsyncDelegateMessageProcessor.process(MuleEvent event) |
MuleEvent |
AbstractResponseMessageProcessor.process(MuleEvent event) |
MuleEvent |
AbstractFilteringMessageProcessor.process(MuleEvent event) |
MuleEvent |
AbstractDynamicMessageProcessor.process(MuleEvent event) |
protected MuleEvent |
AbstractInterceptingMessageProcessorBase.processNext(MuleEvent event) |
protected void |
SedaStageInterceptingMessageProcessor.processNextAsync(MuleEvent event) |
protected void |
AsyncInterceptingMessageProcessor.processNextAsync(MuleEvent event) |
protected MuleEvent |
AsyncInterceptingMessageProcessor.processNextTimed(MuleEvent event) |
protected MuleEvent |
ResponseMessageProcessorAdapter.processResponse(MuleEvent event) |
protected abstract MuleEvent |
AbstractResponseMessageProcessor.processResponse(MuleEvent processNext) |
protected abstract MessageProcessor |
AbstractDynamicMessageProcessor.resolveMessageProcessor(MuleEvent event)
Determines which MessageProcessor should be used.
|
void |
SedaStageInterceptingMessageProcessor.resume() |
void |
TransactionalInterceptingMessageProcessor.start() |
void |
SedaStageInterceptingMessageProcessor.start() |
void |
ResponseMessageProcessorAdapter.start() |
void |
IdempotentRedeliveryPolicy.start() |
void |
AsyncInterceptingMessageProcessor.start() |
void |
AbstractRedeliveryPolicy.start() |
void |
AbstractMuleObjectOwner.start() |
void |
TransactionalInterceptingMessageProcessor.stop() |
void |
SedaStageInterceptingMessageProcessor.stop() |
void |
ResponseMessageProcessorAdapter.stop() |
void |
AsyncInterceptingMessageProcessor.stop() |
void |
AbstractRedeliveryPolicy.stop() |
void |
AbstractMuleObjectOwner.stop() |
Modifier and Type | Method and Description |
---|---|
MessageProcessorChain |
DefaultMessageProcessorChainBuilder.build()
This builder supports the chaining together of message processors that intercept and also those that
don't.
|
protected MuleEvent |
SimpleMessageProcessorChain.doProcess(MuleEvent event) |
protected MuleEvent |
InterceptingChainLifecycleWrapper.doProcess(MuleEvent event) |
protected MuleEvent |
DefaultMessageProcessorChain.doProcess(MuleEvent event) |
protected abstract MuleEvent |
AbstractMessageProcessorChain.doProcess(MuleEvent event) |
static MessageProcessorChain |
DefaultMessageProcessorChain.from(List<MessageProcessor> messageProcessors) |
static MessageProcessorChain |
DefaultMessageProcessorChain.from(MessageProcessor... messageProcessors) |
protected MessageProcessor |
AbstractMessageProcessorChainBuilder.initializeMessageProcessor(Object processor) |
MuleEvent |
InterceptingChainLifecycleWrapper.process(MuleEvent event) |
MuleEvent |
AbstractMessageProcessorChain.process(MuleEvent event) |
void |
AbstractMessageProcessorChain.start() |
void |
AbstractMessageProcessorChain.stop() |
Modifier and Type | Method and Description |
---|---|
Object |
MuleRegistryHelper.applyLifecycle(Object object)
Will execute any lifecycle phases on an object without actually registering the object in the registry.
|
Object |
MuleRegistryHelper.applyLifecycle(Object object,
String phase) |
Object |
MuleRegistryHelper.applyProcessors(Object object)
Will execute any processors on an object without actually registering the object in the registry.
|
Object |
MuleRegistryHelper.applyProcessors(Object object,
int flags)
Will execute any processors on an object without actually registering the object in the registry.
|
Object |
MuleRegistryHelper.applyProcessorsAndLifecycle(Object object)
Will execute any processors on an object and fire any lifecycle methods according to the current lifecycle without actually
registering the object in the registry.
|
void |
MuleRegistryHelper.registerAgent(Agent agent) |
void |
MuleRegistryHelper.registerConnector(Connector connector) |
void |
MuleRegistryHelper.registerEndpoint(ImmutableEndpoint endpoint) |
void |
MuleRegistryHelper.registerEndpointBuilder(String name,
EndpointBuilder builder) |
void |
MuleRegistryHelper.registerFlowConstruct(FlowConstruct flowConstruct) |
void |
MuleRegistryHelper.registerModel(Model model)
Deprecated.
|
void |
MuleRegistryHelper.registerScheduler(Scheduler scheduler) |
void |
MuleRegistryHelper.registerService(Service service) |
void |
MuleRegistryHelper.registerTransformer(Transformer transformer) |
void |
MuleRegistryHelper.unregisterAgent(String agentName) |
void |
MuleRegistryHelper.unregisterConnector(String connectorName) |
void |
MuleRegistryHelper.unregisterEndpoint(String endpointName) |
void |
MuleRegistryHelper.unregisterFlowConstruct(String flowConstructName) |
void |
MuleRegistryHelper.unregisterModel(String modelName)
Deprecated.
|
void |
MuleRegistryHelper.unregisterScheduler(Scheduler scheduler) |
void |
MuleRegistryHelper.unregisterService(String serviceName) |
void |
MuleRegistryHelper.unregisterTransformer(String transformerName) |
Modifier and Type | Class and Description |
---|---|
class |
RetryPolicyExhaustedException
This exception is thrown when a Retry policy has made all the retry attempts
it wants to make and is still failing.
|
Modifier and Type | Class and Description |
---|---|
class |
AggregationException
TODO document
|
class |
CompositeRoutingException
This is a
MessagingException used to aggregate exceptions thrown by
several routes in the context of a single MessageRouter Exceptions are
correlated to each route through a sequential id |
class |
RouteResolverException
Exception thrown when a route for an event can not be found
|
class |
RoutingFailedMessagingException
Exception through by routing strategies when routing fails
|
Modifier and Type | Method and Description |
---|---|
protected MuleException |
MessageFilter.filterUnacceptedException(MuleEvent event) |
Modifier and Type | Method and Description |
---|---|
void |
ScatterGatherRouter.addRoute(MessageProcessor processor)
Adds a new message processor to the list of routes
|
MuleEvent |
CollectAllAggregationStrategy.aggregate(AggregationContext context) |
MuleEvent |
AggregationStrategy.aggregate(AggregationContext context)
aggregates the events in the given context into a single one
|
protected MuleEvent |
CollectAllAggregationStrategy.aggregateWithFailedRoutes(AggregationContext context) |
protected MuleEvent |
CollectAllAggregationStrategy.aggregateWithoutFailedRoutes(AggregationContext context) |
void |
EventGroup.initAfterDeserialisation(MuleContext context) |
boolean |
UntilSuccessful.isMatch(MuleMessage message) |
boolean |
RoundRobin.isMatch(MuleMessage message) |
boolean |
FirstSuccessful.isMatch(MuleMessage message) |
MuleEvent |
WireTap.process(MuleEvent event) |
MuleEvent |
ScatterGatherRouter.process(MuleEvent event) |
MuleEvent |
Resequencer.process(MuleEvent event) |
MuleEvent |
Foreach.process(MuleEvent event) |
MuleEvent |
DynamicRoundRobin.process(MuleEvent event) |
MuleEvent |
DynamicFirstSuccessful.process(MuleEvent event) |
MuleEvent |
DynamicAll.process(MuleEvent event) |
MuleEvent |
AbstractSelectiveRouter.process(MuleEvent event) |
MuleEvent |
AbstractMatchingRouter.process(MuleEvent event) |
MuleEvent |
AbstractAggregator.process(MuleEvent event) |
protected MuleEvent |
AbstractMatchingRouter.processDefaultRoute(MuleEvent event) |
protected MuleEvent |
IdempotentMessageFilter.processNext(MuleEvent event) |
void |
ScatterGatherRouter.removeRoute(MessageProcessor processor)
Removes a message processor from the list of routes
|
protected MuleEvent |
AbstractRoutingStrategy.sendRequest(MuleEvent routedEvent,
MuleMessage message,
MessageProcessor route,
boolean awaitResponse)
Send message event to destination.
|
void |
Foreach.setMessageProcessors(List<MessageProcessor> messageProcessors) |
protected abstract List<MuleMessage> |
AbstractSplitter.splitMessage(MuleEvent event) |
protected MessageSequence<?> |
AbstractSplitter.splitMessageIntoSequence(MuleEvent event) |
void |
UntilSuccessful.start() |
void |
ScatterGatherRouter.start() |
void |
MessageProcessorFilterPair.start() |
void |
MessageFilter.start() |
void |
AbstractSelectiveRouter.start() |
void |
AbstractAggregator.start() |
void |
UntilSuccessful.stop() |
void |
MessageProcessorFilterPair.stop() |
void |
MessageFilter.stop() |
void |
AbstractSelectiveRouter.stop() |
void |
AbstractAggregator.stop() |
Modifier and Type | Class and Description |
---|---|
class |
CorrelationTimeoutException |
Modifier and Type | Method and Description |
---|---|
void |
EventCorrelator.start() |
void |
EventCorrelator.stop() |
Modifier and Type | Method and Description |
---|---|
void |
OutboundPassThroughRouter.addRoute(MessageProcessor target)
Deprecated.
|
void |
FilteringOutboundRouter.addRoute(MessageProcessor target) |
void |
AbstractOutboundRouter.addRoute(MessageProcessor route) |
protected OutboundEndpoint |
AbstractRecipientList.buildOutboundEndpoint(String recipient) |
protected boolean |
MulticastingRouter.continueRoutingMessageAfter(MuleEvent response)
Deprecated.
Indicates that this router always routes messages to all the configured
endpoints no matters what a given response is.
|
protected abstract boolean |
AbstractSequenceRouter.continueRoutingMessageAfter(MuleEvent response)
Lets subclasses decide if the routing of a given message should continue
or not after receiving a given response from a synchronous endpoint.
|
protected OutboundEndpoint |
AbstractRecipientList.getRecipientEndpoint(MuleMessage message,
Object recipient) |
protected OutboundEndpoint |
AbstractRecipientList.getRecipientEndpointFromString(MuleMessage message,
String recipient) |
protected OutboundEndpoint |
AbstractRecipientList.getRecipientEndpointFromUri(EndpointURI uri) |
boolean |
TransformerRouter.isMatch(MuleMessage message)
Deprecated.
|
boolean |
FilteringOutboundRouter.isMatch(MuleMessage message) |
protected MessageProcessor |
EndpointSelector.lookupEndpoint(String endpointName)
Deprecated.
|
MuleEvent |
AbstractOutboundRouter.process(MuleEvent event) |
MuleEvent |
AbstractMessageSequenceSplitter.process(MuleEvent event) |
protected List<MuleEvent> |
AbstractMessageSequenceSplitter.processParts(MessageSequence<?> seq,
MuleEvent originalEvent) |
void |
AbstractOutboundRouter.removeRoute(MessageProcessor route) |
protected MuleEvent |
AbstractOutboundRouter.sendRequest(MuleEvent routedEvent,
MuleMessage message,
MessageProcessor route,
boolean awaitResponse) |
protected MuleEvent |
AbstractOutboundRouter.sendRequestEvent(MuleEvent routedEvent,
MuleMessage message,
MessageProcessor route,
boolean awaitResponse)
Send message event to destination.
|
void |
AbstractOutboundRouter.setMessageProcessors(List<MessageProcessor> routes)
Deprecated.
|
void |
OutboundPassThroughRouter.setRoutes(List<MessageProcessor> endpoints)
Deprecated.
|
void |
AbstractOutboundRouter.setRoutes(List<MessageProcessor> routes) |
protected abstract MessageSequence<?> |
AbstractMessageSequenceSplitter.splitMessageIntoSequence(MuleEvent event)
Converts the event into a
MessageSequence that will retrieve each of
the event elements |
void |
AbstractOutboundRouter.start() |
void |
AbstractOutboundRouter.stop() |
Modifier and Type | Method and Description |
---|---|
MuleEvent |
SimpleRequestReplyReplier.process(MuleEvent event) |
MuleEvent |
AbstractReplyToPropertyRequestReplyReplier.process(MuleEvent event) |
MuleEvent |
AbstractAsyncRequestReplyRequester.process(MuleEvent event) |
protected void |
AbstractReplyToPropertyRequestReplyReplier.processReplyTo(MuleEvent event,
MuleEvent result,
ReplyToHandler replyToHandler,
Object replyTo) |
protected void |
SimpleAsyncRequestReplyRequester.sendAsyncRequest(MuleEvent event) |
protected void |
AbstractAsyncRequestReplyRequester.sendAsyncRequest(MuleEvent event) |
protected void |
SimpleAsyncRequestReplyRequester.setAsyncReplyProperties(MuleEvent event) |
void |
SimpleAsyncRequestReplyRequester.start() |
void |
AbstractAsyncRequestReplyRequester.start() |
void |
SimpleAsyncRequestReplyRequester.stop() |
void |
AbstractAsyncRequestReplyRequester.stop() |
Modifier and Type | Method and Description |
---|---|
protected void |
AbstractSecurityFilter.updatePayload(MuleMessage message,
Object payload,
MuleEvent event) |
Modifier and Type | Method and Description |
---|---|
MuleEvent |
DefaultHttpCallback.FlowRefMessageProcessor.process(MuleEvent event) |
void |
DefaultHttpCallback.start()
Starts a http inbound endpoint served by the underlying connector.
|
void |
BaseOAuth2Manager.start()
if
Startable , then
org.mule.security.oauth.BaseOAuth2Manager.defaultUnauthorizedConnector
is started |
void |
DefaultHttpCallback.stop()
Stops and disposes the processor chain and the inbound endpoint.
|
void |
BaseOAuth2Manager.stop()
if
Stoppable , then
org.mule.security.oauth.BaseOAuth2Manager.defaultUnauthorizedConnector
is stopped |
Constructor and Description |
---|
DefaultHttpCallback(List<MessageProcessor> callbackMessageProcessors,
MuleContext muleContext,
String callbackDomain,
Integer localPort,
Integer remotePort,
Boolean async) |
DefaultHttpCallback(List<MessageProcessor> callbackMessageProcessors,
MuleContext muleContext,
String callbackDomain,
Integer localPort,
Integer remotePort,
Boolean async,
Object connector) |
DefaultHttpCallback(List<MessageProcessor> callbackMessageProcessors,
MuleContext muleContext,
String callbackDomain,
Integer localPort,
Integer remotePort,
String callbackPath,
Boolean async) |
DefaultHttpCallback(List<MessageProcessor> callbackMessageProcessors,
MuleContext muleContext,
String callbackDomain,
Integer localPort,
Integer remotePort,
String callbackPath,
Boolean async,
MessagingExceptionHandler exceptionHandler) |
DefaultHttpCallback(List<MessageProcessor> callbackMessageProcessors,
MuleContext muleContext,
String callbackDomain,
Integer localPort,
Integer remotePort,
String callbackPath,
Boolean async,
MessagingExceptionHandler exceptionHandler,
Object connector) |
DefaultHttpCallback(List<MessageProcessor> callbackMessageProcessors,
MuleContext muleContext,
String callbackDomain,
Integer localPort,
Integer remotePort,
String callbackPath,
Boolean async,
Object connector) |
DefaultHttpCallback(MessageProcessor callbackMessageProcessor,
MuleContext muleContext,
String callbackDomain,
Integer localPort,
Integer remotePort,
String callbackPath,
Boolean async,
MessagingExceptionHandler exceptionHandler,
Object connector) |
Modifier and Type | Method and Description |
---|---|
HttpCallback |
DefaultHttpCallbackFactory.createCallback(HttpCallbackAdapter adapter,
String authCodeRegex,
FetchAccessTokenMessageProcessor fetchAccessTokenMessageProcessor,
MessageProcessor listener,
MuleContext muleContext,
FlowConstruct flowConstruct) |
MuleEvent |
CallbackContinuationMessageProcessor.process(MuleEvent event) |
Modifier and Type | Method and Description |
---|---|
MuleEvent |
ExtractAuthorizationCodeMessageProcessor.process(MuleEvent event) |
MuleEvent |
AbstractListeningMessageProcessor.processEvent(MuleEvent event)
|
void |
BaseOAuth2AuthorizeMessageProcessor.start() |
void |
BaseOAuth1AuthorizeMessageProcessor.start() |
void |
AbstractAuthorizeMessageProcessor.start() |
protected void |
BaseOAuth1AuthorizeMessageProcessor.startCallback(HttpCallbackAdapter adapter,
FetchAccessTokenMessageProcessor fetchAccessTokenMessageProcessor) |
protected void |
AbstractAuthorizeMessageProcessor.startCallback(HttpCallbackAdapter adapter,
FetchAccessTokenMessageProcessor fetchAccessTokenMessageProcessor) |
void |
AbstractAuthorizeMessageProcessor.stop() |
Modifier and Type | Method and Description |
---|---|
void |
ServiceCompositeMessageSource.addSource(MessageSource source)
Deprecated.
|
protected void |
AbstractService.buildServiceMessageProcessorChain()
Deprecated.
|
protected void |
ServiceCompositeMessageSource.createMessageProcessorChain()
Deprecated.
|
protected void |
ServiceAsyncReplyCompositeMessageSource.createMessageProcessorChain()
Deprecated.
|
void |
AbstractService.dispatchEvent(MuleEvent event)
Deprecated.
|
protected void |
AbstractService.doForceStop()
Deprecated.
|
protected void |
AbstractService.doPause()
Deprecated.
Custom components can execute code necessary to put the service in a paused state here.
|
protected void |
AbstractService.doResume()
Deprecated.
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 void |
AbstractService.doStart()
Deprecated.
|
protected void |
AbstractService.doStop()
Deprecated.
|
void |
ServiceLifecycleManager.fireDisposePhase(LifecycleCallback<FlowConstruct> callback)
Deprecated.
|
void |
ServiceLifecycleManager.fireInitialisePhase(LifecycleCallback<FlowConstruct> callback)
Deprecated.
|
void |
ServiceLifecycleManager.firePausePhase(LifecycleCallback<FlowConstruct> callback)
Deprecated.
|
void |
ServiceLifecycleManager.fireResumePhase(LifecycleCallback<FlowConstruct> callback)
Deprecated.
|
void |
ServiceLifecycleManager.fireStartPhase(LifecycleCallback<FlowConstruct> callback)
Deprecated.
|
void |
ServiceLifecycleManager.fireStopPhase(LifecycleCallback<FlowConstruct> callback)
Deprecated.
|
void |
AbstractService.forceStop()
Deprecated.
|
void |
Pausable.pause() |
void |
AbstractService.pause()
Deprecated.
Pauses event processing for a single Mule Service.
|
protected void |
AbstractService.pauseIfPausable(Object candidate)
Deprecated.
|
MuleEvent |
AbstractService.process(MuleEvent event)
Deprecated.
|
void |
ServiceCompositeMessageSource.removeSource(MessageSource source)
Deprecated.
|
void |
Resumable.resume() |
void |
AbstractService.resume()
Deprecated.
Resumes a single Mule Service that has been paused.
|
protected void |
AbstractService.resumeIfResumable(Object candidate)
Deprecated.
|
MuleEvent |
AbstractService.sendEvent(MuleEvent event)
Deprecated.
|
void |
ServiceCompositeMessageSource.setMessageSources(List<MessageSource> sources)
Deprecated.
|
void |
ServiceCompositeMessageSource.start()
Deprecated.
|
void |
AbstractService.start()
Deprecated.
|
protected void |
AbstractService.startIfStartable(Object candidate)
Deprecated.
|
void |
ServiceCompositeMessageSource.stop()
Deprecated.
|
void |
AbstractService.stop()
Deprecated.
|
protected void |
AbstractService.stopIfStoppable(Object candidate)
Deprecated.
|
Constructor and Description |
---|
ServiceLifecycleManager(FlowConstruct service,
MuleContext muleContext)
Deprecated.
|
Modifier and Type | Method and Description |
---|---|
MuleEvent |
ServiceStatisticsMessageProcessor.process(MuleEvent event)
Deprecated.
|
MuleEvent |
ServiceSetEventRequestContextMessageProcessor.process(MuleEvent event)
Deprecated.
|
MuleEvent |
ServiceOutboundStatisticsMessageProcessor.process(MuleEvent event)
Deprecated.
|
MuleEvent |
ServiceOutboundMessageProcessor.process(MuleEvent event)
Deprecated.
|
MuleEvent |
ServiceLoggingMessageProcessor.process(MuleEvent event)
Deprecated.
|
MuleEvent |
ServiceInternalMessageProcessor.process(MuleEvent event)
Deprecated.
We do all this together here rather than chaining them in order to conserve
2.x exception handling behaviour
|
protected void |
ServiceInternalMessageProcessor.processReplyTo(MuleEvent event,
MuleEvent result,
ReplyToHandler replyToHandler,
Object replyTo)
Deprecated.
|
Modifier and Type | Method and Description |
---|---|
MuleSession |
SimpleSessionHandler.retrieveSessionInfoFromMessage(MuleMessage message) |
MuleSession |
SerializeOnlySessionHandler.retrieveSessionInfoFromMessage(MuleMessage message) |
MuleSession |
SerializeAndEncodeSessionHandler.retrieveSessionInfoFromMessage(MuleMessage message) |
MuleSession |
NullSessionHandler.retrieveSessionInfoFromMessage(MuleMessage message) |
MuleSession |
LegacySessionHandler.retrieveSessionInfoFromMessage(MuleMessage message)
Deprecated.
|
void |
SimpleSessionHandler.retrieveSessionInfoFromMessage(MuleMessage message,
MuleSession session)
Deprecated.
Use retrieveSessionInfoFromMessage(MuleMessage message) instead
|
void |
SerializeOnlySessionHandler.retrieveSessionInfoFromMessage(MuleMessage message,
MuleSession session)
Deprecated.
Use retrieveSessionInfoFromMessage(MuleMessage message) instead
|
void |
NullSessionHandler.retrieveSessionInfoFromMessage(MuleMessage message,
MuleSession session)
Deprecated.
Use retrieveSessionInfoFromMessage(MuleMessage message) instead
|
void |
LegacySessionHandler.retrieveSessionInfoFromMessage(MuleMessage message,
MuleSession session)
Deprecated.
Use retrieveSessionInfoFromMessage(MuleMessage message) instead
|
void |
SimpleSessionHandler.storeSessionInfoToMessage(MuleSession session,
MuleMessage message) |
void |
SerializeOnlySessionHandler.storeSessionInfoToMessage(MuleSession session,
MuleMessage message) |
void |
SerializeAndEncodeSessionHandler.storeSessionInfoToMessage(MuleSession session,
MuleMessage message) |
void |
NullSessionHandler.storeSessionInfoToMessage(MuleSession session,
MuleMessage message) |
void |
LegacySessionHandler.storeSessionInfoToMessage(MuleSession session,
MuleMessage message)
Deprecated.
|
Modifier and Type | Method and Description |
---|---|
void |
StartableCompositeMessageSource.addSource(MessageSource source) |
void |
StartableCompositeMessageSource.removeSource(MessageSource source) |
void |
StartableCompositeMessageSource.setMessageSources(List<MessageSource> sources) |
void |
StartableCompositeMessageSource.start() |
void |
ClusterizableMessageSourceWrapper.start() |
void |
StartableCompositeMessageSource.stop() |
void |
ClusterizableMessageSourceWrapper.stop() |
Modifier and Type | Method and Description |
---|---|
void |
QueueProducer.close() |
void |
PagingDelegateWrapper.close()
Closes the resource.
|
void |
PagingDelegateProducer.close()
Closes the delegate
|
void |
ListConsumer.close()
Closes the resource.
|
void |
ListableObjectStoreProducer.close() |
void |
ConsumerIterator.close()
Closes the underlying consumer
|
void |
CompositeProducer.close()
Closes all the producers
|
void |
AbstractConsumer.close()
Closes the resource.
|
Modifier and Type | Method and Description |
---|---|
void |
ManagedPagingDelegateAdapter.close() |
Modifier and Type | Method and Description |
---|---|
void |
AbstractScriptConfigBuilderTestCase.testEndpointConfig() |
void |
AbstractConfigBuilderTestCase.testEndpointConfig() |
void |
AbstractScriptConfigBuilderTestCase.testGlobalEndpointConfig() |
void |
AbstractConfigBuilderTestCase.testGlobalEndpointConfig() |
Modifier and Type | Class and Description |
---|---|
class |
FunctionalTestException |
Modifier and Type | Method and Description |
---|---|
MuleEvent |
InvocationCountMessageProcessor.process(MuleEvent event) |
MuleEvent |
AssertionMessageProcessor.process(MuleEvent event) |
void |
FunctionalTestComponent.start() |
void |
FunctionalTestComponent.stop() |
Modifier and Type | Method and Description |
---|---|
protected void |
FunctionalTestCase.stopFlowSchedulers(String flowName) |
Modifier and Type | Method and Description |
---|---|
void |
InboundEndpointWrapper.start() |
void |
InboundEndpointWrapper.stop() |
Modifier and Type | Method and Description |
---|---|
void |
FakeMuleServer.start() |
void |
FakeMuleServer.stop() |
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 |
---|---|
MuleEvent |
CompositeConverter.process(MuleEvent event) |
MuleEvent |
AbstractTransformer.process(MuleEvent event) |
Modifier and Type | Method and Description |
---|---|
MuleEvent |
CombineCollectionsTransformer.process(MuleEvent event) |
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
When this exception is thrown it will trigger a retry (reconnection) policy to go into effect if one is configured.
|
Modifier and Type | Method and Description |
---|---|
void |
AbstractTransportMessageProcessTemplate.afterFailureProcessingFlow(MuleException exception) |
Modifier and Type | Method and Description |
---|---|
abstract Object |
AbstractTransportMessageProcessTemplate.acquireMessage()
This method will only be called once for the
MessageProcessContext |
void |
KeyedPoolMessageRequesterFactoryAdapter.activate(InboundEndpoint endpoint,
MessageRequester requester) |
void |
AbstractMessageRequesterFactory.activate(InboundEndpoint endpoint,
MessageRequester requester) |
void |
KeyedPoolMessageDispatcherFactoryAdapter.activate(OutboundEndpoint endpoint,
MessageDispatcher dispatcher) |
void |
AbstractMessageDispatcherFactory.activate(OutboundEndpoint endpoint,
MessageDispatcher dispatcher) |
void |
AbstractTransportMessageProcessTemplate.afterFailureProcessingFlow(MessagingException messagingException) |
void |
AbstractTransportMessageProcessTemplate.afterFailureProcessingFlow(MuleException exception) |
MuleEvent |
AbstractTransportMessageProcessTemplate.afterRouteEvent(MuleEvent muleEvent) |
void |
AbstractTransportMessageProcessTemplate.afterSuccessfulProcessingFlow(MuleEvent response) |
protected void |
AbstractMessageReceiver.applyInboundTransformers(MuleEvent event) |
protected void |
AbstractMessageRequester.applyInboundTransformers(MuleMessage message) |
static void |
MessageDispatcherUtils.applyLifecycle(MessageDispatcher dispatcher)
Applies lifecycle to a MessageDispatcher based on the lifecycle state of its connector.
|
protected void |
KeyedPoolMessageDispatcherFactoryAdapter.applyLifecycle(MessageDispatcher dispatcher) |
protected void |
KeyedPoolMessageRequesterFactoryAdapter.applyLifecycle(MessageRequester requester,
boolean created) |
protected void |
AbstractMessageDispatcher.applyOutboundTransformers(MuleEvent event) |
protected void |
AbstractMessageReceiver.applyResponseTransformers(MuleEvent event) |
protected void |
AbstractMessageDispatcher.applyResponseTransformers(MuleEvent event) |
MuleEvent |
AbstractTransportMessageProcessTemplate.beforeRouteEvent(MuleEvent muleEvent) |
protected MessageDispatcher |
AbstractConnector.borrowDispatcher(OutboundEndpoint endpoint) |
MessageRequester |
UnsupportedMessageRequesterFactory.create(InboundEndpoint endpoint) |
MessageRequester |
KeyedPoolMessageRequesterFactoryAdapter.create(InboundEndpoint endpoint) |
abstract MessageRequester |
AbstractMessageRequesterFactory.create(InboundEndpoint endpoint) |
MessageDispatcher |
UnsupportedMessageDispatcherFactory.create(OutboundEndpoint endpoint) |
MessageDispatcher |
KeyedPoolMessageDispatcherFactoryAdapter.create(OutboundEndpoint endpoint) |
abstract MessageDispatcher |
AbstractMessageDispatcherFactory.create(OutboundEndpoint endpoint) |
MessageProcessor |
AbstractConnector.createDispatcherMessageProcessor(OutboundEndpoint endpoint) |
protected MuleEvent |
AbstractTransportMessageProcessTemplate.createEventFromMuleMessage(MuleMessage muleMessage) |
protected MuleMessage |
AbstractTransportMessageProcessTemplate.createMessageFromSource(Object message) |
protected MuleEvent |
AbstractMessageReceiver.createMuleEvent(MuleMessage message,
OutputStream outputStream) |
MuleMessage |
AbstractTransportMessageHandler.createMuleMessage(Object transportMessage)
Uses this object's
MuleMessageFactory to create a new MuleMessage instance. |
MuleMessage |
AbstractTransportMessageHandler.createMuleMessage(Object transportMessage,
MuleMessage previousMessage,
String encoding)
Uses this object's
MuleMessageFactory to create a new MuleMessage instance. |
MuleMessage |
AbstractTransportMessageHandler.createMuleMessage(Object transportMessage,
String encoding)
Uses this object's
MuleMessageFactory to create a new MuleMessage instance. |
protected MuleMessage |
AbstractTransportMessageHandler.createNullMuleMessage()
Uses this object's
MuleMessageFactory to create a new MuleMessage instance. |
protected <T> T |
AbstractConnector.createOperationResource(ImmutableEndpoint endpoint) |
void |
AbstractTransportMessageProcessTemplate.discardInvalidMessage() |
void |
TransactedPollingMessageReceiver.doStart() |
protected void |
AbstractTransportMessageHandler.doStart() |
protected void |
AbstractPollingMessageReceiver.doStart() |
protected abstract void |
AbstractConnector.doStart()
Template method to perform any work when starting the connectoe
|
protected void |
AbstractTransportMessageHandler.doStartHandler() |
protected void |
AbstractMessageReceiver.doStartHandler() |
protected void |
AbstractTransportMessageHandler.doStop() |
protected void |
AbstractPollingMessageReceiver.doStop() |
protected void |
AbstractMessageReceiver.doStop() |
protected abstract void |
AbstractConnector.doStop()
Template method to perform any work when stopping the connectoe
|
void |
ConnectorLifecycleManager.fireDisposePhase(LifecycleCallback<Connector> callback) |
void |
ConnectableLifecycleManager.fireDisposePhase(LifecycleCallback<O> callback) |
void |
ConnectorLifecycleManager.fireInitialisePhase(LifecycleCallback<Connector> callback) |
void |
ConnectableLifecycleManager.fireInitialisePhase(LifecycleCallback<O> callback) |
void |
ConnectorLifecycleManager.fireStartPhase(LifecycleCallback<Connector> callback) |
void |
ConnectableLifecycleManager.fireStartPhase(LifecycleCallback<O> callback) |
void |
ConnectorLifecycleManager.fireStopPhase(LifecycleCallback<Connector> callback) |
void |
ConnectableLifecycleManager.fireStopPhase(LifecycleCallback<O> callback) |
protected WorkManager |
AbstractConnector.getDispatcherWorkManager()
Returns a work manager for message dispatchers.
|
protected OutboundEndpoint |
DefaultReplyToHandler.getEndpoint(MuleEvent event,
String endpointUri) |
MuleEvent |
AbstractTransportMessageProcessTemplate.getMuleEvent() |
Object |
AbstractTransportMessageProcessTemplate.getOriginalMessage() |
OutputStream |
AbstractConnector.getOutputStream(OutboundEndpoint endpoint,
MuleEvent event)
Will get the output stream for this type of transport.
|
protected WorkManager |
AbstractConnector.getReceiverWorkManager()
Returns a work manager for message receivers.
|
protected WorkManager |
AbstractConnector.getRequesterWorkManager()
Returns a work manager for message requesters.
|
<T> T |
AbstractConnector.getTransactionalResource(ImmutableEndpoint endpoint)
Returns transactional resource to use based on endpoint configuration
and transactional context.
|
WorkManager |
DispatcherWorkManagerSource.getWorkManager() |
protected abstract WorkManager |
AbstractTransportMessageHandler.getWorkManager() |
protected WorkManager |
AbstractMessageRequester.getWorkManager() |
void |
DefaultReplyToHandler.initAfterDeserialisation(MuleContext context) |
protected void |
AbstractConnector.initWorkManagers() |
MuleEvent |
AbstractMessageDispatcher.process(MuleEvent event) |
void |
DefaultReplyToHandler.processReplyTo(MuleEvent event,
MuleMessage returnMessage,
Object replyTo) |
MuleEvent |
AbstractTransportMessageProcessTemplate.routeEvent(MuleEvent muleEvent) |
MuleEvent |
AbstractMessageReceiver.routeEvent(MuleEvent muleEvent) |
MuleEvent |
AbstractMessageReceiver.routeMessage(MuleMessage message) |
MuleEvent |
AbstractMessageReceiver.routeMessage(MuleMessage message,
MuleSession session,
OutputStream outputStream) |
MuleEvent |
AbstractMessageReceiver.routeMessage(MuleMessage message,
MuleSession session,
Transaction trans,
OutputStream outputStream) |
MuleEvent |
AbstractMessageReceiver.routeMessage(MuleMessage message,
Transaction trans) |
MuleEvent |
AbstractMessageReceiver.routeMessage(MuleMessage message,
Transaction trans,
OutputStream outputStream) |
void |
TrackingWorkManager.start() |
void |
AbstractTransportMessageHandler.start()
This method will start the connectable, calling
AbstractTransportMessageHandler.connect() if it is
needed. |
void |
AbstractConnector.start() |
protected void |
AbstractConnector.startAfterConnect() |
void |
AbstractTransportMessageHandler.stop() |
void |
AbstractConnector.stop() |
Modifier and Type | Method and Description |
---|---|
MessageDispatcher |
AjaxMessageDispatcherFactory.create(OutboundEndpoint endpoint) |
protected void |
AjaxMessageReceiver.doStart() |
void |
AjaxReplyToHandler.processReplyTo(MuleEvent event,
MuleMessage returnMessage,
Object replyTo) |
void |
BayeuxAware.setBayeux(org.mortbay.cometd.AbstractBayeux bayeux) |
Modifier and Type | Method and Description |
---|---|
void |
AjaxServletConnector.setBayeux(org.mortbay.cometd.AbstractBayeux bayeux) |
Modifier and Type | Method and Description |
---|---|
protected void |
AjaxConnector.doStart() |
Modifier and Type | Method and Description |
---|---|
MessageDispatcher |
EjbMessageDispatcherFactory.create(OutboundEndpoint endpoint) |
Modifier and Type | Method and Description |
---|---|
MessageRequester |
RetrieveMessageRequesterFactory.create(InboundEndpoint endpoint) |
MessageDispatcher |
SmtpMessageDispatcherFactory.create(OutboundEndpoint endpoint)
Creates a new message dispatcher instance, initialised with the passed
endpoint.
|
protected void |
RetrieveMessageReceiver.doStart() |
protected void |
AbstractMailConnector.doStart() |
protected void |
RetrieveMessageReceiver.doStop() |
protected void |
AbstractMailConnector.doStop() |
Modifier and Type | Method and Description |
---|---|
protected boolean |
FileMessageReceiver.attemptFileLock(File sourceFile)
Try to acquire a lock on a file and release it immediately.
|
MessageRequester |
FileMessageRequesterFactory.create(InboundEndpoint endpoint) |
MessageDispatcher |
FileMessageDispatcherFactory.create(OutboundEndpoint endpoint) |
protected void |
FileConnector.doStart() |
protected void |
FileConnector.doStop() |
Object |
FileMessageRequester.getDelegateSession()
There is no associated session for a file connector
|
Object |
FileMessageDispatcher.getDelegateSession()
There is no associated session for a file connector
|
protected static File |
FileMessageDispatcher.getNextFile(String dir,
Object filter) |
OutputStream |
FileConnector.getOutputStream(OutboundEndpoint endpoint,
MuleEvent event)
Well get the output stream (if any) for this type of transport.
|
void |
FileMessageReceiver.processFile(File file) |
Constructor and Description |
---|
FileMessageRequester(InboundEndpoint endpoint) |
Modifier and Type | Method and Description |
---|---|
MessageRequester |
FtpMessageRequesterFactory.create(InboundEndpoint endpoint)
Creates a new message requester instance, initialised with the passed
endpoint.
|
MessageDispatcher |
FtpMessageDispatcherFactory.create(OutboundEndpoint endpoint)
Creates a new message dispatcher instance, initialised with the passed
endpoint.
|
protected void |
FtpConnector.doStart() |
protected void |
FtpConnector.doStop() |
OutputStream |
FtpConnector.getOutputStream(OutboundEndpoint endpoint,
MuleEvent event)
Well get the output stream (if any) for this type of transport.
|
Modifier and Type | Method and Description |
---|---|
void |
HttpMessageProcessTemplate.afterFailureProcessingFlow(MuleException exception) |
Modifier and Type | Method and Description |
---|---|
Object |
HttpMessageProcessTemplate.acquireMessage() |
void |
HttpMessageProcessTemplate.afterFailureProcessingFlow(MuleException exception) |
protected void |
HttpConnector.applyDispatcherLifecycle(MessageDispatcher dispatcher) |
MuleEvent |
HttpsMessageProcessTemplate.beforeRouteEvent(MuleEvent muleEvent) |
MuleEvent |
HttpMessageProcessTemplate.beforeRouteEvent(MuleEvent muleEvent) |
protected MessageDispatcher |
HttpConnector.borrowDispatcher(OutboundEndpoint endpoint) |
protected HttpResponse |
OldHttpMessageReceiver.HttpWorker.buildFailureResponse(HttpVersion version,
int statusCode,
String description) |
MessageRequester |
HttpClientMessageRequesterFactory.create(InboundEndpoint endpoint)
Creates a new message requester instance, initialised with the passed
endpoint.
|
MessageDispatcher |
HttpsClientMessageDispatcherFactory.create(OutboundEndpoint endpoint) |
MessageDispatcher |
HttpClientMessageDispatcherFactory.create(OutboundEndpoint endpoint)
Creates a new message dispatcher instance, initialised with the passed
endpoint.
|
MessageProcessor |
HttpConnector.createDispatcherMessageProcessor(OutboundEndpoint endpoint) |
protected MuleMessage |
HttpMessageProcessTemplate.createMessageFromSource(Object message) |
void |
HttpMessageProcessTemplate.discardInvalidMessage() |
void |
HttpMessageProcessTemplate.discardMessageOnThrottlingExceeded() |
protected HttpResponse |
OldHttpMessageReceiver.HttpWorker.doBad(RequestLine requestLine) |
protected HttpResponse |
HttpMessageProcessTemplate.doBad(RequestLine requestLine) |
protected HttpResponse |
OldHttpMessageReceiver.HttpWorker.doOtherValid(RequestLine requestLine,
String method) |
protected HttpResponse |
OldHttpMessageReceiver.HttpWorker.doRequest(HttpRequest request) |
protected void |
HttpConnector.doStart() |
protected void |
HttpConnector.doStop() |
protected MuleMessage |
HttpClientMessageDispatcher.getResponseFromMethod(HttpMethod httpMethod,
ExceptionPayload ep) |
protected MuleMessage |
HttpClientMessageDispatcher.handleRedirect(HttpMethod method,
MuleEvent event) |
protected HttpResponse |
OldHttpMessageReceiver.HttpWorker.processRequest(HttpRequest request) |
void |
HttpMessageProcessTemplate.sendFailureResponseToClient(MessagingException messagingException) |
void |
HttpMessageProcessTemplate.sendResponseToClient(MuleEvent responseMuleEvent) |
protected HttpResponse |
HttpMessageProcessTemplate.transformResponse(Object response) |
protected HttpResponse |
OldHttpMessageReceiver.transformResponse(Object response,
MuleEvent event) |
Modifier and Type | Class and Description |
---|---|
class |
ResourceNotFoundException
Thrown when a static file is requested but not found
|
class |
RestServiceException |
Modifier and Type | Method and Description |
---|---|
MuleEvent |
StaticResourceMessageProcessor.process(MuleEvent event) |
MuleEvent |
HttpResponseBuilder.process(MuleEvent event) |
protected void |
HttpResponseBuilder.setBody(HttpResponse response,
MuleMessage message,
MuleEvent event) |
protected void |
HttpResponseBuilder.setCookies(HttpResponse response,
MuleMessage message) |
Modifier and Type | Method and Description |
---|---|
protected void |
HttpProxy.configureMessageProcessorsAfterTransformation(MessageProcessorChainBuilder builder) |
Constructor and Description |
---|
HttpProxy(String name,
MuleContext muleContext,
MessageSource messageSource,
OutboundEndpoint outboundEndpoint,
List<MessageProcessor> transformers,
List<MessageProcessor> responseTransformers,
CachingStrategy cachingStrategy) |
Modifier and Type | Method and Description |
---|---|
protected HttpProxy |
HttpProxyBuilder.buildFlowConstruct(MuleContext muleContext) |
Modifier and Type | Method and Description |
---|---|
protected void |
JdbcConnector.applyDispatcherLifecycle(MessageDispatcher dispatcher) |
protected MessageDispatcher |
JdbcConnector.borrowDispatcher(OutboundEndpoint endpoint) |
MessageRequester |
JdbcMessageRequesterFactory.create(InboundEndpoint endpoint) |
MessageDispatcher |
JdbcMessageDispatcherFactory.create(OutboundEndpoint endpoint) |
MessageProcessor |
JdbcConnector.createDispatcherMessageProcessor(OutboundEndpoint endpoint) |
protected <T> T |
JdbcConnector.createOperationResource(ImmutableEndpoint endpoint) |
protected void |
JdbcConnector.doStart() |
protected void |
JdbcConnector.doStop() |
Modifier and Type | Method and Description |
---|---|
protected void |
JmsMessageDispatcher.applyOutboundTransformers(MuleEvent event) |
void |
CustomCachingConnectionFactory.close() |
MessageRequester |
JmsMessageRequesterFactory.create(InboundEndpoint endpoint) |
MessageDispatcher |
JmsMessageDispatcherFactory.create(OutboundEndpoint endpoint) |
protected Connection |
JmsConnector.createConnection() |
protected ConnectionFactory |
JmsConnector.createConnectionFactory() |
protected Session |
JmsConnector.createOperationResource(ImmutableEndpoint endpoint) |
protected void |
MultiConsumerJmsMessageReceiver.SubReceiver.doConnect() |
protected void |
MultiConsumerJmsMessageReceiver.SubReceiver.doDisconnect() |
protected void |
TransactedSingleResourceJmsMessageReceiver.doStart() |
protected void |
MultiConsumerJmsMessageReceiver.doStart() |
protected void |
MultiConsumerJmsMessageReceiver.SubReceiver.doStart() |
protected void |
JmsMessageReceiver.doStart()
Deprecated.
|
protected void |
JmsConnector.doStart() |
protected void |
TransactedSingleResourceJmsMessageReceiver.doStop() |
protected void |
MultiConsumerJmsMessageReceiver.doStop() |
protected void |
JmsMessageReceiver.doStop()
Deprecated.
|
protected void |
JmsConnector.doStop() |
protected void |
MultiConsumerJmsMessageReceiver.SubReceiver.doStop(boolean force)
Stop the subreceiver.
|
void |
JmsReplyToHandler.initAfterDeserialisation(MuleContext muleContext) |
void |
JmsReplyToHandler.processReplyTo(MuleEvent event,
MuleMessage returnMessage,
Object replyTo) |
protected void |
MultiConsumerJmsMessageReceiver.startSubReceivers() |
Modifier and Type | Method and Description |
---|---|
void |
AbstractJndiNameResolver.start() |
void |
CachedJndiNameResolver.stop()
Cleans up the cache.
|
void |
AbstractJndiNameResolver.stop() |
Modifier and Type | Method and Description |
---|---|
void |
ReconnectWorkManager.start() |
void |
ReconnectWorkManager.startIfNotStarted() |
Modifier and Type | Method and Description |
---|---|
void |
RedeliveryHandler.handleRedelivery(Message message,
InboundEndpoint endpoint,
FlowConstruct flow)
Process the redelivered message.
|
void |
JmsXRedeliveryHandler.handleRedelivery(Message message,
InboundEndpoint endpoint,
FlowConstruct flow)
process the redelivered message.
|
void |
CountingRedeliveryHandler.handleRedelivery(Message message,
InboundEndpoint endpoint,
FlowConstruct flow)
process the redelivered message.
|
abstract void |
AbstractRedeliveryHandler.handleRedelivery(Message message,
InboundEndpoint endpoint,
FlowConstruct flow) |
Modifier and Type | Method and Description |
---|---|
protected void |
MessageProcessorPollingMessageReceiver.doStart() |
protected void |
MessageProcessorPollingConnector.doStart() |
protected void |
MessageProcessorPollingMessageReceiver.doStop() |
protected void |
MessageProcessorPollingConnector.doStop() |
void |
MessageProcessorPollingInterceptor.postProcessRouting(MuleEvent event)
Post process the event after it was routed to the rest of the flow.
|
MuleEvent |
MessageProcessorPollingInterceptor.prepareRouting(MuleEvent sourceEvent,
MuleEvent event)
Called after the polling message processor processes the event, but before an event is routed to the rest of the flow.
|
MuleEvent |
MessageProcessorPollingInterceptor.prepareSourceEvent(MuleEvent event)
Called before sending the event to the message processor that will do poll for events.
|
Modifier and Type | Method and Description |
---|---|
void |
FixedFrequencyScheduler.schedule()
Executes the the
Scheduler task |
void |
FixedFrequencyScheduler.start()
Starts the Scheduling of a Task.
|
void |
FixedFrequencyScheduler.stop()
Stops the Scheduling of a Task.
|
Modifier and Type | Method and Description |
---|---|
MuleEvent |
WatermarkPollingInterceptor.prepareSourceEvent(MuleEvent event)
Watermark source preprocessing puts the watermark value into a flow variable
|
Modifier and Type | Method and Description |
---|---|
MessageDispatcher |
QuartzMessageDispatcherFactory.create(OutboundEndpoint endpoint) |
protected MuleEvent |
QuartzMessageReceiver.createMuleEvent(MuleMessage message,
OutputStream outputStream) |
protected void |
QuartzMessageReceiver.doStart() |
protected void |
QuartzConnector.doStart() |
protected void |
QuartzConnector.doStop() |
Modifier and Type | Method and Description |
---|---|
InboundEndpoint |
ScheduleConfigBuilder.buildScheduler() |
protected AnnotatedEndpointData |
ScheduleAnnotationParser.createEndpointData(Annotation annotation) |
protected QuartzConnector |
ScheduleAnnotationParser.getConnector() |
protected String[] |
ScheduleAnnotationParser.getProperties(Schedule schedule) |
InboundEndpoint |
ScheduleAnnotationParser.parseInboundEndpoint(Annotation annotation,
Map metaInfo) |
Constructor and Description |
---|
ScheduleConfigBuilder(String scheduleId,
MuleContext muleContext) |
Modifier and Type | Method and Description |
---|---|
protected void |
ScheduledDispatchJob.dispatch(String endpointRef,
Object payload,
org.quartz.JobDataMap jobDataMap) |
protected OutboundEndpoint |
ScheduledDispatchJob.getOutboundEndpoint(String uri) |
void |
PollEndpointJob.start() |
void |
PollEndpointJob.stop() |
Modifier and Type | Method and Description |
---|---|
MessageDispatcher |
RmiMessageDispatcherFactory.create(OutboundEndpoint endpoint) |
protected void |
RmiConnector.doStart() |
protected void |
RmiCallbackMessageReceiver.doStart() |
protected void |
RmiConnector.doStop() |
Method |
RmiConnector.getMethodObject(Remote remoteObject,
MuleEvent event,
OutboundEndpoint outboundEndpoint)
Helper method for Dispatchers and Receives to extract the correct method from
a Remote object
|
MuleEvent |
RmiCallbackMessageReceiver.routeMessage(Object payload) |
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 |
TransportServiceDescriptor.createMessageReceiver(Connector connector,
FlowConstruct flowConstruct,
InboundEndpoint endpoint) |
MessageReceiver |
DefaultTransportServiceDescriptor.createMessageReceiver(Connector connector,
FlowConstruct flowConstruct,
InboundEndpoint endpoint) |
MessageReceiver |
TransportServiceDescriptor.createMessageReceiver(Connector connector,
FlowConstruct flowConstruct,
InboundEndpoint endpoint,
Object... args) |
MessageReceiver |
DefaultTransportServiceDescriptor.createMessageReceiver(Connector connector,
FlowConstruct flowConstruct,
InboundEndpoint endpoint,
Object... args) |
Modifier and Type | Method and Description |
---|---|
protected void |
ServletMessageReceiver.doStart() |
protected void |
ServletConnector.doStart() |
protected void |
ServletConnector.doStop() |
protected InboundEndpoint |
MuleRESTReceiverServlet.getEndpointForURI(HttpServletRequest httpServletRequest) |
protected MuleEvent |
MuleReceiverServlet.routeMessage(MessageReceiver receiver,
MuleMessage requestMessage,
HttpServletRequest request) |
Modifier and Type | Method and Description |
---|---|
Object |
JettyMessageProcessTemplate.acquireMessage() |
protected MuleMessage |
JettyMessageProcessTemplate.createMessageFromSource(Object message) |
void |
JettyMessageProcessTemplate.discardMessageOnThrottlingExceeded() |
void |
JettyContinuationsMessageProcessTemplate.discardMessageOnThrottlingExceeded() |
protected void |
JettyHttpConnector.doStart() |
protected void |
JettyHttpConnector.doStop() |
void |
JettyMessageProcessTemplate.sendFailureResponseToClient(MessagingException messagingException) |
void |
JettyContinuationsMessageProcessTemplate.sendFailureResponseToClient(MessagingException messagingException) |
void |
JettyMessageProcessTemplate.sendResponseToClient(MuleEvent muleEvent) |
void |
JettyContinuationsMessageProcessTemplate.sendResponseToClient(MuleEvent muleEvent) |
void |
JettyWebappServerAgent.start() |
void |
JettyHttpConnector.MuleReceiverConnectorHolder.start() |
void |
ConnectorHolder.start() |
void |
AbstractConnectorHolder.start() |
void |
JettyWebappServerAgent.stop() |
void |
JettyHttpConnector.MuleReceiverConnectorHolder.stop() |
void |
ConnectorHolder.stop() |
void |
AbstractConnectorHolder.stop() |
void |
JettyHttpConnector.unregisterListener(MessageReceiver receiver) |
Modifier and Type | Method and Description |
---|---|
MessageRequester |
SftpMessageRequesterFactory.create(InboundEndpoint endpoint)
Creates a new message requester instance, initialised with the passed
endpoint.
|
MessageDispatcher |
SftpMessageDispatcherFactory.create(OutboundEndpoint endpoint) |
protected void |
SftpConnector.doStart() |
protected void |
SftpConnector.doStop() |
Modifier and Type | Method and Description |
---|---|
MessageRequester |
AxisMessageRequesterFactory.create(InboundEndpoint endpoint) |
MessageDispatcher |
AxisMessageDispatcherFactory.create(OutboundEndpoint endpoint) |
void |
AxisServiceComponent.doGet(MuleEventContext context,
AxisStringWriter response) |
protected void |
AxisMessageReceiver.doStart() |
protected void |
AxisConnector.doStart()
Template method to perform any work when starting the connectoe
|
protected void |
AxisMessageReceiver.doStop() |
protected void |
AxisConnector.doStop()
Template method to perform any work when stopping the connectoe
|
static Class[] |
AxisServiceProxy.getInterfacesForComponent(Service service) |
protected Service |
AxisConnector.getOrCreateAxisComponent() |
protected void |
AxisConnector.registerReceiverWithMuleService(MessageReceiver receiver,
EndpointURI ep) |
protected void |
AxisConnector.unregisterReceiverWithMuleService(MessageReceiver receiver,
EndpointURI ep) |
Modifier and Type | Method and Description |
---|---|
protected OutboundEndpoint |
UniversalSender.lookupEndpoint(String uri) |
Modifier and Type | Method and Description |
---|---|
MessageDispatcher |
AxisWsdlMessageDispatcherFactory.create(OutboundEndpoint endpoint) |
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) |
MessageDispatcher |
LocalSocketTcpMessageDispatcherFactory.create(OutboundEndpoint endpoint) |
protected void |
TcpMessageReceiver.doStart() |
protected void |
TcpConnector.doStart() |
protected void |
TcpMessageReceiver.doStop() |
protected void |
TcpConnector.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 |
UdpMessageReceiver.doStart() |
protected void |
UdpConnector.doStart() |
protected void |
UdpConnector.doStop() |
Modifier and Type | Method and Description |
---|---|
MessageRequester |
VMMessageRequesterFactory.create(InboundEndpoint endpoint) |
MessageDispatcher |
VMMessageDispatcherFactory.create(OutboundEndpoint endpoint) |
protected <T> T |
VMConnector.createOperationResource(ImmutableEndpoint endpoint) |
protected void |
VMConnector.doStart() |
protected void |
VMConnector.doStop() |
MuleMessage |
VMMessageReceiver.onCall(MuleMessage message) |
void |
VMMessageReceiver.onMessage(MuleMessage message) |
Modifier and Type | Method and Description |
---|---|
MessageRequester |
XmppMessageRequesterFactory.create(InboundEndpoint endpoint) |
MessageDispatcher |
XmppMessageDispatcherFactory.create(OutboundEndpoint endpoint) |
protected void |
XmppMessageReceiver.doStart() |
protected void |
XmppConnector.doStart() |
protected void |
XmppMessageReceiver.doStop() |
protected void |
XmppConnector.doStop() |
protected void |
XmppPollingMessageReceiver.processMessage(org.jivesoftware.smack.packet.Message xmppMessage) |
Modifier and Type | Method and Description |
---|---|
void |
DefaultLifecycleEnabledObjectPool.start() |
void |
DefaultLifecycleEnabledObjectPool.stop() |
Modifier and Type | Method and Description |
---|---|
void |
TransactionAwareQueueStore.dispose() |
void |
Queue.dispose()
Disposes this queue by releasing it's storage and associated memory and
storage.
|
void |
TransactionalQueueManager.start() |
void |
DelegateQueueManager.start() |
void |
TransactionalQueueManager.stop() |
void |
DelegateQueueManager.stop() |
Modifier and Type | Method and Description |
---|---|
protected void |
TransactionalQueueManager.disposeQueue(Queue queue)
Deprecated.
|
Modifier and Type | Class and Description |
---|---|
class |
ResourceManagerException |
class |
ResourceManagerSystemException |
Modifier and Type | Method and Description |
---|---|
MuleEvent |
ProcessingMuleEventWork.getResult(long timeout,
TimeUnit timeUnit)
This method is useful for having a thread other than the one executing this
work waiting for the result being available.
|
void |
SerialWorkManager.start() |
void |
MuleWorkManager.start() |
Copyright © 2003–2015 MuleSoft, Inc.. All rights reserved.