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.client | |
org.mule.api.endpoint |
Endpoint interfaces.
|
org.mule.api.exception | |
org.mule.api.transport |
Contains the interfaces that comprise a provider implementation.
|
org.mule.client | |
org.mule.config.endpoint | |
org.mule.config.i18n |
Internationalisation support for Mule messages and exception messages.
|
org.mule.config.processors | |
org.mule.construct | |
org.mule.construct.builder | |
org.mule.endpoint |
Implemtation of Mule endpoint uris.
|
org.mule.endpoint.inbound | |
org.mule.module.client |
Simple interface for Mule clients to send and receive events from local or remote Mule Servers.
|
org.mule.module.client.remoting | |
org.mule.module.cxf.endpoint | |
org.mule.service | |
org.mule.tck.util.endpoint | |
org.mule.transport |
Contains Abstract classes providing common functionality for all Mule providers.
|
org.mule.transport.ajax | |
org.mule.transport.ajax.container |
A AJAX transport allows Mule applications to send a receive events to the web browser.
|
org.mule.transport.ajax.embedded |
A AJAX transport allows Mule applications to send a receive events to the web browser.
|
org.mule.transport.ejb | |
org.mule.transport.email |
Provides pop3, smtp and imap connectivity for Mule.
|
org.mule.transport.file |
Provides file transport in the form of a directory listeners and file dispatchers.
|
org.mule.transport.ftp | |
org.mule.transport.http |
Provides http transport including proxy support.
|
org.mule.transport.jdbc |
Provides jdbc transport.
|
org.mule.transport.jms |
Provides Jms transport connectivity with support for all Jms features.
|
org.mule.transport.jms.redelivery | |
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.polling | |
org.mule.transport.quartz | |
org.mule.transport.quartz.config | |
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.servlet.jetty | |
org.mule.transport.sftp | |
org.mule.transport.soap.axis |
Provides an Axis soap transport for Mule.
|
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.
|
org.mule.transport.xmpp |
Modifier and Type | Method and Description |
---|---|
protected Credentials |
DefaultMuleEvent.extractCredentials(InboundEndpoint endpoint) |
protected void |
DefaultMuleEvent.fillProperties(InboundEndpoint endpoint) |
MuleMessage |
DefaultMuleEventContext.requestEvent(InboundEndpoint endpoint,
long timeout)
Requests a synchronous receive of an event on the service
|
Constructor and Description |
---|
DefaultMuleEvent(MuleMessage message,
InboundEndpoint endpoint,
FlowConstruct flowConstruct) |
DefaultMuleEvent(MuleMessage message,
InboundEndpoint endpoint,
FlowConstruct flowConstruct,
MuleSession session) |
DefaultMuleEvent(MuleMessage message,
InboundEndpoint endpoint,
FlowConstruct flowConstruct,
MuleSession session,
ReplyToHandler replyToHandler,
Object replyToDestination,
OutputStream outputStream) |
DefaultMuleEvent(MuleMessage message,
InboundEndpoint endpoint,
MuleSession session)
Deprecated.
|
DefaultMuleEvent(MuleMessage message,
InboundEndpoint endpoint,
MuleSession session,
ReplyToHandler replyToHandler,
OutputStream outputStream,
Object replyToDestination)
Deprecated.
|
Modifier and Type | Method and Description |
---|---|
InboundEndpoint |
EndpointAnnotationParser.parseInboundEndpoint(Annotation annotation,
Map metaInfo)
Creates an inbound endpoint from the annotation.
|
Modifier and Type | Method and Description |
---|---|
MuleMessage |
MuleEventContext.requestEvent(InboundEndpoint endpoint,
long timeout)
Deprecated.
|
Modifier and Type | Method and Description |
---|---|
MuleMessage |
LocalMuleClient.request(InboundEndpoint endpoint,
long timeout)
Will receive an event from an endpointUri determined by the URL.
|
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.
|
InboundEndpoint |
EndpointCache.getInboundEndpoint(String uri,
MessageExchangePattern mep) |
Modifier and Type | Method and Description |
---|---|
MessageProcessor |
EndpointMessageProcessorChainFactory.createInboundMessageProcessorChain(InboundEndpoint endpoint,
FlowConstruct flowConstruct,
MessageProcessor target) |
Constructor and Description |
---|
MessageRedeliveredException(String messageId,
int redeliveryCount,
int maxRedelivery,
InboundEndpoint endpoint,
MuleEvent event,
Message message) |
MessageRedeliveredException(String messageId,
int redeliveryCount,
int maxRedelivery,
InboundEndpoint endpoint,
MuleEvent event,
Message message,
MessageProcessor failingMessageProcessor) |
MessageRedeliveredException(String messageId,
int redeliveryCount,
int maxRedelivery,
InboundEndpoint endpoint,
MuleEvent event,
MessageProcessor failingMessageProcessor) |
Modifier and Type | Method and Description |
---|---|
InboundEndpoint |
MessageRequester.getEndpoint() |
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.
|
void |
Connector.registerListener(InboundEndpoint endpoint,
MessageProcessor listener,
FlowConstruct flowConstruct)
Registers a MessageProcessor listener which will listen to new message
received from a specific transport channel and then processed by the endpoint.
|
MuleMessage |
Connector.request(InboundEndpoint endpoint,
long timeout)
Make a specific request to the underlying transport
|
void |
MessageReceiver.setEndpoint(InboundEndpoint endpoint) |
void |
Connector.unregisterListener(InboundEndpoint endpoint,
FlowConstruct flowConstruct)
Unregisters the listener for the given endpoints.
|
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 | Method and Description |
---|---|
MuleMessage |
DefaultLocalMuleClient.request(InboundEndpoint endpoint,
long timeout) |
Modifier and Type | Method and Description |
---|---|
InboundEndpoint |
AbstractEndpointAnnotationParser.parseInboundEndpoint(Annotation annotation,
Map metaInfo) |
Modifier and Type | Method and Description |
---|---|
static Message |
CoreMessages.failedToStartInboundEndpoint(InboundEndpoint endpoint) |
static Message |
CoreMessages.failedToStopInboundEndpoint(InboundEndpoint endpoint) |
Modifier and Type | Method and Description |
---|---|
protected InboundEndpoint |
DecoratingAnnotatedServiceProcessor.tryInboundEndpointAnnotation(AnnotationMetaData metaData,
ChannelType channelType)
Deprecated.
|
Modifier and Type | Method and Description |
---|---|
void |
Flow.setEndpoint(InboundEndpoint endpoint)
Deprecated.
use setMessageSource(MessageSource) instead
|
Modifier and Type | Method and Description |
---|---|
protected InboundEndpoint |
AbstractFlowConstructWithSingleInboundEndpointBuilder.getOrBuildInboundEndpoint(MuleContext muleContext) |
Modifier and Type | Method and Description |
---|---|
T |
AbstractFlowConstructWithSingleInboundEndpointBuilder.inboundEndpoint(InboundEndpoint inboundEndpoint) |
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 | Field and Description |
---|---|
protected InboundEndpoint |
DynamicURIInboundEndpoint.endpoint |
Modifier and Type | Method and Description |
---|---|
InboundEndpoint |
AbstractEndpointBuilder.buildInboundEndpoint() |
protected InboundEndpoint |
AbstractEndpointBuilder.createInboundEndpoint(EndpointURI endpointURI,
List<MessageProcessor> mergedProcessors,
List<MessageProcessor> mergedResponseProcessors,
Connector connector) |
protected InboundEndpoint |
AbstractEndpointBuilder.doBuildInboundEndpoint() |
InboundEndpoint |
DefaultEndpointFactory.getInboundEndpoint(EndpointBuilder builder) |
InboundEndpoint |
DefaultEndpointFactory.getInboundEndpoint(EndpointURI uri) |
InboundEndpoint |
DefaultEndpointFactory.getInboundEndpoint(String uri) |
InboundEndpoint |
SimpleEndpointCache.getInboundEndpoint(String uri,
MessageExchangePattern mep) |
Modifier and Type | Method and Description |
---|---|
MessageProcessor |
DefaultEndpointMessageProcessorChainFactory.createInboundMessageProcessorChain(InboundEndpoint endpoint,
FlowConstruct flowConstruct,
MessageProcessor target) |
protected List<MessageProcessor> |
DefaultEndpointMessageProcessorChainFactory.createInboundMessageProcessors(InboundEndpoint endpoint)
Override this method to change the default MessageProcessors.
|
protected List<MessageProcessor> |
DefaultEndpointMessageProcessorChainFactory.createInboundResponseMessageProcessors(InboundEndpoint endpoint)
Override this method to change the default MessageProcessors.
|
Constructor and Description |
---|
DynamicURIInboundEndpoint(InboundEndpoint endpoint) |
DynamicURIInboundEndpoint(InboundEndpoint endpoint,
EndpointURI dynamicEndpointURI) |
Modifier and Type | Field and Description |
---|---|
protected InboundEndpoint |
InboundNotificationMessageProcessor.endpoint |
protected InboundEndpoint |
InboundLoggingMessageProcessor.endpoint |
Modifier and Type | Method and Description |
---|---|
InboundEndpoint |
InboundNotificationMessageProcessor.getInboundEndpoint() |
Constructor and Description |
---|
InboundEndpointMimeTypeCheckingMessageProcessor(InboundEndpoint endpoint) |
InboundEndpointPropertyMessageProcessor(InboundEndpoint endpoint) |
InboundLoggingMessageProcessor(InboundEndpoint endpoint) |
InboundNotificationMessageProcessor(InboundEndpoint endpoint) |
Modifier and Type | Method and Description |
---|---|
protected InboundEndpoint |
MuleClient.getDefaultClientEndpoint(Service service,
Object payload,
boolean sync) |
protected InboundEndpoint |
MuleClient.getInboundEndpoint(String uri) |
Modifier and Type | Field and Description |
---|---|
protected InboundEndpoint |
RemoteDispatcherComponent.inboundEndpoint
Deprecated.
|
Modifier and Type | Method and Description |
---|---|
InboundEndpoint |
RemoteDispatcherAgent.getEndpoint()
Deprecated.
|
Modifier and Type | Method and Description |
---|---|
static Service |
RemoteDispatcherComponent.getSerivce(InboundEndpoint endpoint,
WireFormat wireFormat,
String encoding,
int eventTimeout,
MuleContext muleContext)
Deprecated.
|
void |
RemoteDispatcherAgent.setEndpoint(InboundEndpoint endpoint)
Deprecated.
|
Constructor and Description |
---|
RemoteDispatcherComponent(InboundEndpoint inboundEndpoint,
WireFormat wireFormat,
String encoding,
int synchronousEventTimeout)
Deprecated.
|
Modifier and Type | Method and Description |
---|---|
InboundEndpoint |
WsdlCxfEndpointBuilder.buildInboundEndpoint() |
InboundEndpoint |
CxfEndpointBuilder.buildInboundEndpoint() |
Modifier and Type | Field and Description |
---|---|
protected List<InboundEndpoint> |
ServiceCompositeMessageSource.endpoints
Deprecated.
|
Modifier and Type | Method and Description |
---|---|
InboundEndpoint |
ServiceCompositeMessageSource.getEndpoint(String name)
Deprecated.
|
Modifier and Type | Method and Description |
---|---|
List<InboundEndpoint> |
ServiceCompositeMessageSource.getEndpoints()
Deprecated.
|
Modifier and Type | Class and Description |
---|---|
class |
InboundEndpointWrapper
Wraps an
InboundEndpoint enabling subclasses to override only those
methods which add extra behaviour. |
Modifier and Type | Method and Description |
---|---|
InboundEndpoint |
InboundEndpointWrapper.getDelegate() |
Constructor and Description |
---|
InboundEndpointWrapper(InboundEndpoint delegate) |
Modifier and Type | Field and Description |
---|---|
protected InboundEndpoint |
AbstractReceiverWorker.endpoint |
Modifier and Type | Method and Description |
---|---|
InboundEndpoint |
AbstractMessageReceiver.getEndpoint() |
InboundEndpoint |
AbstractMessageRequester.getEndpoint() |
protected InboundEndpoint |
AbstractTransportMessageProcessTemplate.getInboundEndpoint() |
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(FlowConstruct flowConstruct,
InboundEndpoint endpoint)
Create a Message receiver for this connector
|
void |
AbstractMessageRequesterFactory.destroy(InboundEndpoint endpoint,
MessageRequester requester) |
void |
KeyedPoolMessageRequesterFactoryAdapter.destroy(InboundEndpoint endpoint,
MessageRequester requester) |
protected void |
AbstractConnector.doUnregisterListener(FlowConstruct flowConstruct,
InboundEndpoint endpoint,
MessageReceiver receiver) |
MessageReceiver |
AbstractConnector.getReceiver(FlowConstruct flowConstruct,
InboundEndpoint endpoint) |
protected Object |
AbstractConnector.getReceiverKey(FlowConstruct flowConstruct,
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) |
void |
AbstractConnector.registerListener(InboundEndpoint endpoint,
MessageProcessor messageProcessorChain,
FlowConstruct flowConstruct) |
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(InboundEndpoint endpoint,
FlowConstruct flowConstruct) |
boolean |
AbstractMessageRequesterFactory.validate(InboundEndpoint endpoint,
MessageRequester requester) |
boolean |
KeyedPoolMessageRequesterFactoryAdapter.validate(InboundEndpoint endpoint,
MessageRequester requester) |
Constructor and Description |
---|
AbstractMessageReceiver(Connector connector,
FlowConstruct flowConstruct,
InboundEndpoint endpoint)
Creates the Message Receiver
|
AbstractMessageRequester(InboundEndpoint endpoint) |
AbstractPollingMessageReceiver(Connector connector,
FlowConstruct flowConstruct,
InboundEndpoint endpoint) |
TransactedPollingMessageReceiver(Connector connector,
FlowConstruct flowConstruct,
InboundEndpoint endpoint) |
TransactedPollingMessageReceiver(Connector connector,
FlowConstruct flowConstruct,
InboundEndpoint endpoint,
long frequency)
Deprecated.
|
UnsupportedMessageRequester(InboundEndpoint endpoint) |
Constructor and Description |
---|
AjaxMessageReceiver(Connector connector,
FlowConstruct flowConstruct,
InboundEndpoint endpoint) |
Modifier and Type | Method and Description |
---|---|
protected MessageReceiver |
AjaxServletConnector.createReceiver(FlowConstruct flowConstruct,
InboundEndpoint endpoint) |
Modifier and Type | Method and Description |
---|---|
protected MessageReceiver |
AjaxConnector.createReceiver(FlowConstruct flowConstruct,
InboundEndpoint endpoint) |
Constructor and Description |
---|
EjbMessageReceiver(Connector connector,
FlowConstruct flowConstruct,
InboundEndpoint endpoint,
long frequency) |
Modifier and Type | Method and Description |
---|---|
MessageRequester |
RetrieveMessageRequesterFactory.create(InboundEndpoint endpoint) |
MessageReceiver |
AbstractRetrieveMailConnector.createReceiver(FlowConstruct flowConstruct,
InboundEndpoint endpoint) |
MessageReceiver |
SmtpConnector.createReceiver(FlowConstruct flowConstruct,
InboundEndpoint endpoint) |
Constructor and Description |
---|
RetrieveMessageReceiver(Connector connector,
FlowConstruct flowConstruct,
InboundEndpoint endpoint,
long checkFrequency,
boolean backupEnabled,
String backupFolder) |
RetrieveMessageRequester(InboundEndpoint endpoint) |
Modifier and Type | Method and Description |
---|---|
MessageRequester |
FileMessageRequesterFactory.create(InboundEndpoint endpoint) |
MessageReceiver |
FileConnector.createReceiver(FlowConstruct flowConstruct,
InboundEndpoint endpoint)
Registers a listener for a particular directory The following properties can
be overriden in the endpoint declaration
moveToDirectory
filterPatterns
filterClass
pollingFrequency
|
protected Object |
FileConnector.getReceiverKey(FlowConstruct flowConstruct,
InboundEndpoint endpoint) |
Constructor and Description |
---|
FileMessageReceiver(Connector connector,
FlowConstruct flowConstruct,
InboundEndpoint endpoint,
String readDir,
String moveDir,
String moveToPattern,
long frequency) |
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.
|
MessageReceiver |
FtpConnector.createReceiver(FlowConstruct flowConstruct,
InboundEndpoint endpoint) |
Constructor and Description |
---|
FtpMessageReceiver(Connector connector,
FlowConstruct flowConstruct,
InboundEndpoint endpoint,
long frequency) |
FtpMessageRequester(InboundEndpoint endpoint) |
Modifier and Type | Method and Description |
---|---|
MessageRequester |
HttpClientMessageRequesterFactory.create(InboundEndpoint endpoint)
Creates a new message requester instance, initialised with the passed
endpoint.
|
MessageReceiver |
HttpConnector.getReceiver(FlowConstruct flowConstruct,
InboundEndpoint endpoint) |
protected Object |
HttpConnector.getReceiverKey(FlowConstruct flowConstruct,
InboundEndpoint endpoint)
The method determines the key used to store the receiver against.
|
void |
HttpConnector.registerListener(InboundEndpoint endpoint,
MessageProcessor listener,
FlowConstruct flowConstruct) |
Constructor and Description |
---|
HttpClientMessageRequester(InboundEndpoint endpoint) |
HttpMessageReceiver(Connector connector,
FlowConstruct flowConstruct,
InboundEndpoint endpoint) |
HttpsMessageReceiver(Connector connector,
FlowConstruct flow,
InboundEndpoint endpoint) |
OldHttpMessageReceiver(Connector connector,
FlowConstruct flowConstruct,
InboundEndpoint endpoint) |
OldHttpsMessageReceiver(Connector connector,
FlowConstruct flow,
InboundEndpoint endpoint) |
PollingHttpMessageReceiver(Connector connector,
FlowConstruct flowConstruct,
InboundEndpoint endpoint) |
PollingHttpsMessageReceiver(Connector connector,
FlowConstruct flowConstruct,
InboundEndpoint endpoint) |
Modifier and Type | Method and Description |
---|---|
MessageRequester |
JdbcMessageRequesterFactory.create(InboundEndpoint endpoint) |
MessageReceiver |
JdbcConnector.createReceiver(FlowConstruct flowConstruct,
InboundEndpoint endpoint) |
Constructor and Description |
---|
JdbcMessageReceiver(Connector connector,
FlowConstruct flowConstruct,
InboundEndpoint endpoint,
String readStmt,
String ackStmt) |
JdbcMessageRequester(InboundEndpoint endpoint) |
Modifier and Type | Method and Description |
---|---|
MessageRequester |
JmsMessageRequesterFactory.create(InboundEndpoint endpoint) |
protected Object |
JmsConnector.getReceiverKey(FlowConstruct flowConstruct,
InboundEndpoint endpoint) |
Constructor and Description |
---|
JmsMessageReceiver(Connector connector,
FlowConstruct flowConstruct,
InboundEndpoint endpoint)
Deprecated.
|
JmsMessageRequester(InboundEndpoint endpoint) |
MultiConsumerJmsMessageReceiver(Connector connector,
FlowConstruct flowConstruct,
InboundEndpoint endpoint) |
SingleJmsMessageReceiver(Connector connector,
FlowConstruct flowConstruct,
InboundEndpoint endpoint) |
TransactedSingleResourceJmsMessageReceiver(Connector connector,
FlowConstruct flowConstruct,
InboundEndpoint endpoint) |
XaTransactedJmsMessageReceiver(Connector connector,
FlowConstruct flowConstruct,
InboundEndpoint endpoint) |
Modifier and Type | Method and Description |
---|---|
void |
JmsXRedeliveryHandler.handleRedelivery(Message message,
InboundEndpoint endpoint,
FlowConstruct flow)
process the redelivered message.
|
void |
RedeliveryHandler.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) |
Constructor and Description |
---|
MessageRedeliveredException(String messageId,
int redeliveryCount,
int maxRedelivery,
InboundEndpoint endpoint,
FlowConstruct flow,
MuleMessage muleMessage) |
Constructor and Description |
---|
WebsphereTransactedJmsMessageReceiver(Connector connector,
FlowConstruct flowConstruct,
InboundEndpoint endpoint) |
Modifier and Type | Method and Description |
---|---|
protected Object |
MulticastConnector.getReceiverKey(FlowConstruct flowConstruct,
InboundEndpoint endpoint) |
Constructor and Description |
---|
MulticastMessageReceiver(AbstractConnector connector,
FlowConstruct flowConstruct,
InboundEndpoint endpoint) |
Modifier and Type | Method and Description |
---|---|
protected Object |
MessageProcessorPollingConnector.getReceiverKey(FlowConstruct flowConstruct,
InboundEndpoint endpoint) |
Constructor and Description |
---|
MessageProcessorPollingMessageReceiver(Connector connector,
FlowConstruct flowConstruct,
InboundEndpoint endpoint) |
Constructor and Description |
---|
QuartzMessageReceiver(Connector connector,
FlowConstruct flowConstruct,
InboundEndpoint endpoint) |
Modifier and Type | Method and Description |
---|---|
InboundEndpoint |
ScheduleConfigBuilder.buildScheduler() |
InboundEndpoint |
ScheduleAnnotationParser.parseInboundEndpoint(Annotation annotation,
Map metaInfo) |
Modifier and Type | Method and Description |
---|---|
MessageReceiver |
RmiConnector.createReceiver(FlowConstruct flowConstruct,
InboundEndpoint endpoint) |
Constructor and Description |
---|
RmiCallbackMessageReceiver(Connector connector,
FlowConstruct flowConstruct,
InboundEndpoint endpoint) |
RmiMessageReceiver(Connector connector,
FlowConstruct flowConstruct,
InboundEndpoint endpoint,
long frequency) |
Modifier and Type | Method and Description |
---|---|
MessageReceiver |
DefaultTransportServiceDescriptor.createMessageReceiver(Connector connector,
FlowConstruct flowConstruct,
InboundEndpoint endpoint) |
MessageReceiver |
TransportServiceDescriptor.createMessageReceiver(Connector connector,
FlowConstruct flowConstruct,
InboundEndpoint endpoint) |
MessageReceiver |
DefaultTransportServiceDescriptor.createMessageReceiver(Connector connector,
FlowConstruct flowConstruct,
InboundEndpoint endpoint,
Object... args) |
MessageReceiver |
TransportServiceDescriptor.createMessageReceiver(Connector connector,
FlowConstruct flowConstruct,
InboundEndpoint endpoint,
Object... args) |
Modifier and Type | Method and Description |
---|---|
protected InboundEndpoint |
MuleRESTReceiverServlet.getEndpointForURI(HttpServletRequest httpServletRequest) |
Modifier and Type | Method and Description |
---|---|
protected Object |
ServletConnector.getReceiverKey(FlowConstruct flowConstruct,
InboundEndpoint endpoint) |
Constructor and Description |
---|
ServletMessageReceiver(Connector connector,
FlowConstruct flowConstruct,
InboundEndpoint endpoint) |
Modifier and Type | Method and Description |
---|---|
protected ConnectorHolder |
JettyHttpConnector.createContextHolder(org.eclipse.jetty.server.Connector connector,
InboundEndpoint endpoint,
MessageReceiver receiver) |
protected MessageReceiver |
JettyHttpConnector.createReceiver(FlowConstruct flowConstruct,
InboundEndpoint endpoint) |
Constructor and Description |
---|
JettyHttpMessageReceiver(Connector connector,
FlowConstruct flowConstruct,
InboundEndpoint endpoint) |
Modifier and Type | Method and Description |
---|---|
MessageRequester |
SftpMessageRequesterFactory.create(InboundEndpoint endpoint)
Creates a new message requester instance, initialised with the passed
endpoint.
|
MessageReceiver |
SftpConnector.createReceiver(FlowConstruct flow,
InboundEndpoint endpoint) |
protected SftpReceiverRequesterUtil |
SftpMessageReceiver.createSftpReceiverRequesterUtil(InboundEndpoint endpoint) |
Constructor and Description |
---|
SftpMessageReceiver(SftpConnector connector,
FlowConstruct flow,
InboundEndpoint endpoint) |
SftpMessageReceiver(SftpConnector connector,
FlowConstruct flow,
InboundEndpoint endpoint,
long frequency) |
SftpMessageRequester(InboundEndpoint endpoint) |
Modifier and Type | Method and Description |
---|---|
MessageRequester |
AxisMessageRequesterFactory.create(InboundEndpoint endpoint) |
protected Object |
AxisConnector.getReceiverKey(FlowConstruct flowConstruct,
InboundEndpoint endpoint)
The method determines the key used to store the receiver against.
|
Constructor and Description |
---|
AxisMessageReceiver(Connector connector,
FlowConstruct flowConstruct,
InboundEndpoint endpoint) |
AxisMessageRequester(InboundEndpoint endpoint) |
Constructor and Description |
---|
SslMessageReceiver(Connector connector,
FlowConstruct flowConstruct,
InboundEndpoint endpoint) |
Modifier and Type | Method and Description |
---|---|
MessageReceiver |
StdioConnector.createReceiver(FlowConstruct flowConstruct,
InboundEndpoint endpoint) |
void |
StdioConnector.registerListener(InboundEndpoint endpoint,
MessageProcessor listener,
FlowConstruct flowConstruct) |
Constructor and Description |
---|
StdioMessageReceiver(Connector connector,
FlowConstruct flowConstruct,
InboundEndpoint endpoint,
long checkFrequency) |
Modifier and Type | Method and Description |
---|---|
MessageRequester |
TcpMessageRequesterFactory.create(InboundEndpoint endpoint) |
Constructor and Description |
---|
ExceptionReturnTcpMessageReceiver(Connector connector,
FlowConstruct flowConstruct,
InboundEndpoint endpoint) |
PollingTcpMessageReceiver(Connector connector,
FlowConstruct flowConstruct,
InboundEndpoint endpoint) |
TcpMessageReceiver(Connector connector,
FlowConstruct flowConstruct,
InboundEndpoint endpoint) |
TcpMessageRequester(InboundEndpoint endpoint) |
Modifier and Type | Method and Description |
---|---|
MessageRequester |
UdpMessageRequesterFactory.create(InboundEndpoint endpoint) |
protected Object |
UdpConnector.getReceiverKey(FlowConstruct flowConstruct,
InboundEndpoint endpoint) |
Constructor and Description |
---|
UdpMessageReceiver(Connector connector,
FlowConstruct flowConstruct,
InboundEndpoint endpoint) |
UdpMessageRequester(InboundEndpoint endpoint) |
Modifier and Type | Method and Description |
---|---|
MessageRequester |
VMMessageRequesterFactory.create(InboundEndpoint endpoint) |
MessageReceiver |
VMConnector.createReceiver(FlowConstruct flowConstruct,
InboundEndpoint endpoint) |
Constructor and Description |
---|
VMMessageReceiver(Connector connector,
FlowConstruct flowConstruct,
InboundEndpoint endpoint) |
VMMessageRequester(InboundEndpoint endpoint) |
Modifier and Type | Method and Description |
---|---|
MessageRequester |
XmppMessageRequesterFactory.create(InboundEndpoint endpoint) |
Constructor and Description |
---|
XmppMessageReceiver(AbstractConnector connector,
FlowConstruct flowConstruct,
InboundEndpoint endpoint) |
XmppMessageRequester(InboundEndpoint endpoint) |
XmppPollingMessageReceiver(Connector conn,
FlowConstruct flowConstruct,
InboundEndpoint endpoint) |
Copyright © 2003–2016 MuleSoft, Inc.. All rights reserved.