Package | Description |
---|---|
org.mule |
The Mule implementation of the Universal Message Objects(tm) API specification.
|
org.mule.api |
The Universal Message Object(tm) API provides a way for components to interact without needing to know about the protocol or delivery mechanisms of information passed between them
|
org.mule.api.endpoint |
Endpoint interfaces.
|
org.mule.api.routing |
Interfaces that define inbound and outbound routing API.
|
org.mule.api.transport |
Contains the interfaces that comprise a provider implementation.
|
org.mule.endpoint |
Implemtation of Mule endpoint uris.
|
org.mule.module.client |
Simple interface for Mule clients to send and receive events from local or remote Mule Servers.
|
org.mule.module.client.remoting | |
org.mule.routing.inbound |
Inbound router implementation as described in the Enterprise Integration Patterns book.
|
org.mule.routing.response |
Response router implementations that enable asynchronous event processing in request /response messaging requests.
|
org.mule.service | |
org.mule.transport |
Contains Abstract classes providing common functionality for all Mule providers.
|
org.mule.transport.bpm | |
org.mule.transport.ejb | |
org.mule.transport.http |
Provides http transport including proxy support.
|
org.mule.transport.jms |
Provides Jms transport connectivity with support for all Jms features.
|
org.mule.transport.jms.websphere |
Provides Jms connectivity with Websphere-specific workarounds and improvements.
|
org.mule.transport.multicast |
IP multicast connectivity for Mule.
|
org.mule.transport.quartz | |
org.mule.transport.rmi | |
org.mule.transport.service |
Provides SPI support for building mule connectors and providers using service descriptors.
|
org.mule.transport.servlet | |
org.mule.transport.ssl |
Provides tcp connectivity over Ssl for Mule.
|
org.mule.transport.stdio | |
org.mule.transport.tcp |
Provides tcp connectivity for Mule.
|
org.mule.transport.udp |
Provides Udp connectivity for Mule.
|
org.mule.transport.vm |
A connector implementation allowing events to be passed between Mule sessions via in-memory queues.
|
Modifier and Type | Method and Description |
---|---|
MuleMessage |
DefaultMuleEventContext.requestEvent(InboundEndpoint endpoint,
long timeout)
Requests a synchronous receive of an event on the service
|
MuleMessage |
DefaultMuleSession.requestEvent(InboundEndpoint endpoint,
long timeout) |
Modifier and Type | Method and Description |
---|---|
MuleMessage |
MuleEventContext.requestEvent(InboundEndpoint endpoint,
long timeout)
Requests a synchronous receive of an event on the service.
|
MuleMessage |
MuleSession.requestEvent(InboundEndpoint endpoint,
long timeout)
Requests a synchronous receive of an event on the service
|
Modifier and Type | Method and Description |
---|---|
InboundEndpoint |
EndpointBuilder.buildInboundEndpoint()
Constructs inbound endpoints
|
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.
|
Modifier and Type | Method and Description |
---|---|
InboundEndpoint |
ResponseRouterCollection.getEndpoint(String name) |
InboundEndpoint |
InboundRouterCollection.getEndpoint(String name) |
Modifier and Type | Method and Description |
---|---|
void |
ResponseRouterCollection.addEndpoint(InboundEndpoint endpoint) |
void |
InboundRouterCollection.addEndpoint(InboundEndpoint endpoint) |
boolean |
ResponseRouterCollection.removeEndpoint(InboundEndpoint endpoint) |
boolean |
InboundRouterCollection.removeEndpoint(InboundEndpoint endpoint) |
Modifier and Type | Method and Description |
---|---|
InboundEndpoint |
MessageReceiver.getEndpoint() |
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) . |
MessageRequester |
MessageRequesterFactory.create(InboundEndpoint endpoint)
Creates a new message requester instance, initialised with the passed
endpoint.
|
void |
MessageRequesterFactory.destroy(InboundEndpoint endpoint,
MessageRequester requester)
Invoked when a requester returned
false for
MessageRequesterFactory.validate(org.mule.api.endpoint.InboundEndpoint, org.mule.api.transport.MessageRequester) . |
void |
MessageRequesterFactory.passivate(InboundEndpoint endpoint,
MessageRequester requester)
Invoked immediately before the given requester is returned
to its pool.
|
MessageReceiver |
Connector.registerListener(Service service,
InboundEndpoint endpoint)
This creates a
MessageReceiver associated with this endpoint
and registers it with the connector |
MuleMessage |
Connector.request(InboundEndpoint endpoint,
long timeout)
Make a specific request to the underlying transport
|
void |
MessageReceiver.setEndpoint(InboundEndpoint endpoint) |
void |
Connector.unregisterListener(Service service,
InboundEndpoint endpoint) |
boolean |
MessageRequesterFactory.validate(InboundEndpoint endpoint,
MessageRequester requester)
Invoked after the requester is returned from a client but
before it is prepared for return to its pool via
MessageRequesterFactory.passivate(org.mule.api.endpoint.InboundEndpoint, org.mule.api.transport.MessageRequester) . |
Modifier and Type | Class and Description |
---|---|
class |
DefaultInboundEndpoint |
class |
DynamicURIInboundEndpoint
Allow's EndpointURI to be set and changed dynamically by wrapping up an immutable endpoint instance.
|
Modifier and Type | Method and Description |
---|---|
InboundEndpoint |
AbstractEndpointBuilder.buildInboundEndpoint() |
protected InboundEndpoint |
AbstractEndpointBuilder.doBuildInboundEndpoint() |
InboundEndpoint |
DefaultEndpointFactory.getInboundEndpoint(EndpointBuilder builder) |
InboundEndpoint |
DefaultEndpointFactory.getInboundEndpoint(EndpointURI uri) |
InboundEndpoint |
DefaultEndpointFactory.getInboundEndpoint(String uri) |
Constructor and Description |
---|
DynamicURIInboundEndpoint(InboundEndpoint endpoint) |
DynamicURIInboundEndpoint(InboundEndpoint endpoint,
EndpointURI dynamicEndpointURI) |
Modifier and Type | Method and Description |
---|---|
protected InboundEndpoint |
MuleClient.getInboundEndpoint(String uri) |
Modifier and Type | Method and Description |
---|---|
InboundEndpoint |
RemoteDispatcherAgent.getEndpoint() |
Modifier and Type | Method and Description |
---|---|
static Service |
RemoteDispatcherComponent.getSerivce(InboundEndpoint endpoint,
WireFormat wireFormat,
String encoding,
int eventTimeout,
MuleContext managementContext) |
void |
RemoteDispatcherAgent.setEndpoint(InboundEndpoint endpoint) |
Modifier and Type | Method and Description |
---|---|
InboundEndpoint |
DefaultInboundRouterCollection.getEndpoint(String name) |
Modifier and Type | Method and Description |
---|---|
void |
DefaultInboundRouterCollection.addEndpoint(InboundEndpoint endpoint) |
boolean |
DefaultInboundRouterCollection.removeEndpoint(InboundEndpoint endpoint) |
Modifier and Type | Method and Description |
---|---|
InboundEndpoint |
DefaultResponseRouterCollection.getEndpoint(String name) |
Modifier and Type | Method and Description |
---|---|
void |
DefaultResponseRouterCollection.addEndpoint(InboundEndpoint endpoint) |
boolean |
DefaultResponseRouterCollection.removeEndpoint(InboundEndpoint endpoint) |
Modifier and Type | Method and Description |
---|---|
protected ReplyToHandler |
AbstractService.getReplyToHandler(MuleMessage message,
InboundEndpoint endpoint) |
Modifier and Type | Field and Description |
---|---|
protected InboundEndpoint |
AbstractMessageReceiver.endpoint
The endpoint descriptor which is associated with this receiver
|
protected InboundEndpoint |
AbstractReceiverWorker.endpoint |
Modifier and Type | Method and Description |
---|---|
InboundEndpoint |
AbstractMessageReceiver.getEndpoint() |
Modifier and Type | Method and Description |
---|---|
void |
AbstractMessageRequesterFactory.activate(InboundEndpoint endpoint,
MessageRequester requester) |
void |
KeyedPoolMessageRequesterFactoryAdapter.activate(InboundEndpoint endpoint,
MessageRequester requester) |
abstract MessageRequester |
AbstractMessageRequesterFactory.create(InboundEndpoint endpoint) |
MessageRequester |
KeyedPoolMessageRequesterFactoryAdapter.create(InboundEndpoint endpoint) |
MessageRequester |
UnsupportedMessageRequesterFactory.create(InboundEndpoint endpoint) |
protected MessageReceiver |
AbstractConnector.createReceiver(Service service,
InboundEndpoint endpoint)
Create a Message receiver for this connector
|
void |
AbstractMessageRequesterFactory.destroy(InboundEndpoint endpoint,
MessageRequester requester) |
void |
KeyedPoolMessageRequesterFactoryAdapter.destroy(InboundEndpoint endpoint,
MessageRequester requester) |
void |
AbstractConnector.destroyReceiver(MessageReceiver receiver,
InboundEndpoint endpoint) |
MessageReceiver |
AbstractConnector.getReceiver(Service service,
InboundEndpoint endpoint) |
protected Object |
AbstractConnector.getReceiverKey(Service service,
InboundEndpoint endpoint)
The method determines the key used to store the receiver against.
|
void |
AbstractMessageRequesterFactory.passivate(InboundEndpoint endpoint,
MessageRequester requester) |
void |
KeyedPoolMessageRequesterFactoryAdapter.passivate(InboundEndpoint endpoint,
MessageRequester requester) |
MessageReceiver |
AbstractConnector.registerListener(Service service,
InboundEndpoint endpoint) |
MuleMessage |
AbstractConnector.request(InboundEndpoint endpoint,
long timeout) |
void |
AbstractMessageReceiver.setEndpoint(InboundEndpoint endpoint) |
protected void |
AbstractConnector.setupRequestReturn(InboundEndpoint endpoint,
MessageRequester requester,
MuleMessage result)
This method will return the requester to the pool or, if the payload is an inputstream,
replace the payload with a new DelegatingInputStream which returns the requester to
the pool when the stream is closed.
|
void |
AbstractConnector.unregisterListener(Service service,
InboundEndpoint endpoint) |
boolean |
AbstractMessageRequesterFactory.validate(InboundEndpoint endpoint,
MessageRequester requester) |
boolean |
KeyedPoolMessageRequesterFactoryAdapter.validate(InboundEndpoint endpoint,
MessageRequester requester) |
Constructor and Description |
---|
AbstractMessageReceiver(Connector connector,
Service service,
InboundEndpoint endpoint)
Creates the Message Receiver
|
AbstractMessageRequester(InboundEndpoint endpoint) |
AbstractPollingMessageReceiver(Connector connector,
Service service,
InboundEndpoint endpoint) |
TransactedPollingMessageReceiver(Connector connector,
Service service,
InboundEndpoint endpoint) |
TransactedPollingMessageReceiver(Connector connector,
Service service,
InboundEndpoint endpoint,
long frequency)
Deprecated.
please use
#TransactedPollingMessageReceiver(Connector,Service,InboundEndpoint,long,TimeUnit)
instead |
UnsupportedMessageRequester(InboundEndpoint endpoint) |
Constructor and Description |
---|
ProcessMessageReceiver(Connector connector,
Service service,
InboundEndpoint endpoint) |
Constructor and Description |
---|
EjbMessageReceiver(Connector connector,
Service service,
InboundEndpoint endpoint,
long frequency) |
Modifier and Type | Method and Description |
---|---|
MessageRequester |
HttpClientMessageRequesterFactory.create(InboundEndpoint endpoint)
Creates a new message requester instance, initialised with the passed
endpoint.
|
protected Object |
HttpConnector.getReceiverKey(Service service,
InboundEndpoint endpoint)
The method determines the key used to store the receiver against.
|
MessageReceiver |
HttpConnector.registerListener(Service service,
InboundEndpoint endpoint) |
Constructor and Description |
---|
HttpClientMessageRequester(InboundEndpoint endpoint) |
HttpMessageReceiver(Connector connector,
Service service,
InboundEndpoint endpoint) |
HttpsMessageReceiver(Connector connector,
Service service,
InboundEndpoint endpoint) |
PollingHttpMessageReceiver(Connector connector,
Service service,
InboundEndpoint endpoint) |
Modifier and Type | Method and Description |
---|---|
MessageRequester |
JmsMessageRequesterFactory.create(InboundEndpoint endpoint) |
protected Object |
JmsConnector.getReceiverKey(Service service,
InboundEndpoint endpoint) |
Constructor and Description |
---|
JmsMessageReceiver(Connector connector,
Service service,
InboundEndpoint endpoint) |
JmsMessageRequester(InboundEndpoint endpoint) |
MultiConsumerJmsMessageReceiver(Connector connector,
Service service,
InboundEndpoint endpoint) |
SingleJmsMessageReceiver(Connector connector,
Service service,
InboundEndpoint endpoint) |
TransactedSingleResourceJmsMessageReceiver(Connector connector,
Service service,
InboundEndpoint endpoint) |
XaTransactedJmsMessageReceiver(Connector umoConnector,
Service service,
InboundEndpoint endpoint) |
Constructor and Description |
---|
WebsphereTransactedJmsMessageReceiver(Connector umoConnector,
Service service,
InboundEndpoint endpoint) |
Modifier and Type | Method and Description |
---|---|
protected Object |
MulticastConnector.getReceiverKey(Service service,
InboundEndpoint endpoint) |
Constructor and Description |
---|
MulticastMessageReceiver(AbstractConnector connector,
Service service,
InboundEndpoint endpoint) |
Constructor and Description |
---|
QuartzMessageReceiver(Connector connector,
Service service,
InboundEndpoint endpoint) |
Modifier and Type | Method and Description |
---|---|
MessageReceiver |
RmiConnector.createReceiver(Service service,
InboundEndpoint endpoint) |
Constructor and Description |
---|
RmiCallbackMessageReceiver(Connector connector,
Service service,
InboundEndpoint endpoint) |
RmiMessageReceiver(Connector connector,
Service service,
InboundEndpoint endpoint,
long frequency) |
Modifier and Type | Method and Description |
---|---|
MessageReceiver |
DefaultTransportServiceDescriptor.createMessageReceiver(Connector connector,
Service service,
InboundEndpoint endpoint) |
MessageReceiver |
TransportServiceDescriptor.createMessageReceiver(Connector connector,
Service service,
InboundEndpoint endpoint) |
MessageReceiver |
DefaultTransportServiceDescriptor.createMessageReceiver(Connector connector,
Service service,
InboundEndpoint endpoint,
Object[] args) |
MessageReceiver |
TransportServiceDescriptor.createMessageReceiver(Connector connector,
Service service,
InboundEndpoint endpoint,
Object[] args) |
Modifier and Type | Method and Description |
---|---|
protected InboundEndpoint |
MuleRESTReceiverServlet.getEndpointForURI(javax.servlet.http.HttpServletRequest httpServletRequest) |
Constructor and Description |
---|
ServletMessageReceiver(Connector connector,
Service service,
InboundEndpoint endpoint) |
Constructor and Description |
---|
SslMessageReceiver(Connector connector,
Service service,
InboundEndpoint endpoint) |
Modifier and Type | Method and Description |
---|---|
MessageReceiver |
StdioConnector.createReceiver(Service service,
InboundEndpoint endpoint) |
MessageReceiver |
PromptStdioConnector.registerListener(Service service,
InboundEndpoint endpoint) |
Constructor and Description |
---|
StdioMessageReceiver(Connector connector,
Service service,
InboundEndpoint endpoint,
long checkFrequency) |
Modifier and Type | Method and Description |
---|---|
MessageRequester |
TcpMessageRequesterFactory.create(InboundEndpoint endpoint) |
Constructor and Description |
---|
TcpMessageReceiver(Connector connector,
Service service,
InboundEndpoint endpoint) |
TcpMessageRequester(InboundEndpoint endpoint) |
Modifier and Type | Method and Description |
---|---|
MessageRequester |
UdpMessageRequesterFactory.create(InboundEndpoint endpoint) |
protected Object |
UdpConnector.getReceiverKey(Service service,
InboundEndpoint endpoint) |
Constructor and Description |
---|
UdpMessageReceiver(Connector connector,
Service service,
InboundEndpoint endpoint) |
UdpMessageRequester(InboundEndpoint endpoint) |
Modifier and Type | Method and Description |
---|---|
MessageRequester |
VMMessageRequesterFactory.create(InboundEndpoint endpoint) |
MessageReceiver |
VMConnector.createReceiver(Service service,
InboundEndpoint endpoint) |
Constructor and Description |
---|
VMMessageReceiver(Connector connector,
Service service,
InboundEndpoint endpoint) |
VMMessageRequester(InboundEndpoint endpoint) |
Copyright © 2003–2013 MuleSource, Inc.. All rights reserved.