Modifier and Type | Method and Description |
---|---|
FlowConstruct |
DefaultMuleEventContext.getFlowConstruct() |
FlowConstruct |
DefaultMuleEvent.getFlowConstruct()
Gets the recipient service of this event
|
FlowConstruct |
VoidMuleEvent.getFlowConstruct() |
Constructor and Description |
---|
DefaultMuleEvent(MuleEvent rewriteEvent,
FlowConstruct flowConstruct) |
DefaultMuleEvent(MuleEvent rewriteEvent,
FlowConstruct flowConstruct,
ReplyToHandler replyToHandler,
Object replyToDestination) |
DefaultMuleEvent(MuleEvent rewriteEvent,
FlowConstruct flowConstruct,
ReplyToHandler replyToHandler,
Object replyToDestination,
boolean synchronous) |
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,
MessageExchangePattern exchangePattern,
FlowConstruct flowConstruct)
Constructor used to create an event with no message source with minimal arguments
|
DefaultMuleEvent(MuleMessage message,
MessageExchangePattern exchangePattern,
FlowConstruct flowConstruct,
MuleSession session)
Constructor used to create an event with no message source with minimal arguments and a
MuleSession |
DefaultMuleEvent(MuleMessage message,
MessageExchangePattern exchangePattern,
FlowConstruct flowConstruct,
MuleSession session,
int timeout,
Credentials credentials,
OutputStream outputStream)
Constructor used to create an event with no message source with all additional arguments
|
DefaultMuleEvent(MuleMessage message,
MessageExchangePattern exchangePattern,
FlowConstruct flowConstruct,
MuleSession session,
OutputStream outputStream)
Constructor used to create an event with no message source with minimal arguments and
OutputStream
|
DefaultMuleEvent(MuleMessage message,
MessageExchangePattern exchangePattern,
ReplyToHandler replyToHandler,
FlowConstruct flowConstruct)
Constructor used to create an event with no message source with minimal arguments and a
ReplyToHandler |
DefaultMuleEvent(MuleMessage message,
MuleEvent rewriteEvent,
FlowConstruct flowConstruct,
MuleSession session,
boolean synchronous) |
DefaultMuleEvent(MuleMessage message,
MuleEvent rewriteEvent,
FlowConstruct flowConstruct,
MuleSession session,
boolean synchronous,
boolean shareFlowVars,
MessageExchangePattern messageExchangePattern) |
DefaultMuleEvent(MuleMessage message,
MuleEvent rewriteEvent,
FlowConstruct flowConstruct,
MuleSession session,
boolean synchronous,
ReplyToHandler replyToHandler,
Object replyToDestination,
boolean shareFlowVars,
MessageExchangePattern messageExchangePattern) |
DefaultMuleEvent(MuleMessage message,
URI messageSourceURI,
MessageExchangePattern exchangePattern,
FlowConstruct flowConstruct,
MuleSession session)
Constructor used to create an event with a uri that idendifies the message source with minimal
arguments
|
DefaultMuleEvent(MuleMessage message,
URI messageSourceURI,
MessageExchangePattern exchangePattern,
FlowConstruct flowConstruct,
MuleSession session,
int timeout,
Credentials credentials,
OutputStream outputStream)
Constructor used to create an event with a identifiable message source with all additional arguments except
a
ReplyToHandler |
DefaultMuleEvent(MuleMessage message,
URI messageSourceURI,
MessageExchangePattern exchangePattern,
FlowConstruct flowConstruct,
MuleSession session,
int timeout,
Credentials credentials,
OutputStream outputStream,
ReplyToHandler replyToHandler)
Constructor used to create an event with a identifiable message source with all additional arguments
|
DefaultMuleEvent(MuleMessage message,
URI messageSourceURI,
MessageExchangePattern exchangePattern,
FlowConstruct flowConstruct,
MuleSession session,
OutputStream outputStream)
Constructor used to create an event with a uri that idendifies the message source with minimal
arguments and OutputStream
|
DefaultMuleEvent(MuleMessage message,
URI messageSourceURI,
String messageSourceName,
MessageExchangePattern exchangePattern,
FlowConstruct flowConstruct,
MuleSession session,
int timeout,
Credentials credentials,
OutputStream outputStream,
String encoding,
boolean transacted,
boolean synchronous,
Object replyToDestination,
ReplyToHandler replyToHandler) |
Modifier and Type | Method and Description |
---|---|
FlowConstruct |
MuleEvent.getFlowConstruct()
Retrieves the service for the current event
|
FlowConstruct |
MuleEventContext.getFlowConstruct() |
FlowConstruct |
MuleSession.getFlowConstruct()
Deprecated.
|
Modifier and Type | Method and Description |
---|---|
void |
MuleSession.setFlowConstruct(FlowConstruct flowConstruct)
Deprecated.
|
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
|
Modifier and Type | Method and Description |
---|---|
LifecycleAdapter |
LifecycleAdapterFactory.create(Object pojoService,
JavaComponent component,
FlowConstruct flowConstruct,
EntryPointResolverSet resolver,
MuleContext muleContext) |
Modifier and Type | Interface and Description |
---|---|
interface |
Pipeline
A pipeline has an ordered list of
MessageProcessor 's that are invoked in order to processor new
messages received from it's MessageSource |
Modifier and Type | Method and Description |
---|---|
void |
FlowConstructAware.setFlowConstruct(FlowConstruct flowConstruct) |
Constructor and Description |
---|
FlowConstructInvalidException(Message message,
FlowConstruct flowConstruct) |
Modifier and Type | Method and Description |
---|---|
MessageProcessor |
EndpointMessageProcessorChainFactory.createInboundMessageProcessorChain(InboundEndpoint endpoint,
FlowConstruct flowConstruct,
MessageProcessor target) |
Modifier and Type | Method and Description |
---|---|
FlowConstruct |
MuleRegistry.lookupFlowConstruct(String name) |
Modifier and Type | Method and Description |
---|---|
Collection<FlowConstruct> |
MuleRegistry.lookupFlowConstructs() |
Modifier and Type | Method and Description |
---|---|
void |
MuleRegistry.registerFlowConstruct(FlowConstruct flowConstruct) |
Modifier and Type | Interface and Description |
---|---|
interface |
Service
Deprecated.
|
Modifier and Type | Method and Description |
---|---|
FlowConstruct |
MessageReceiver.getFlowConstruct() |
Modifier and Type | Method and Description |
---|---|
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.
|
void |
Connector.unregisterListener(InboundEndpoint endpoint,
FlowConstruct flowConstruct)
Unregisters the listener for the given endpoints.
|
Modifier and Type | Class and Description |
---|---|
static class |
DefaultLocalMuleClient.MuleClientFlowConstruct
Placeholder class which makes the default exception handler available.
|
Modifier and Type | Field and Description |
---|---|
protected FlowConstruct |
AbstractComponent.flowConstruct |
protected FlowConstruct |
DefaultComponentLifecycleAdapter.flowConstruct |
Modifier and Type | Method and Description |
---|---|
FlowConstruct |
AbstractComponent.getFlowConstruct() |
Modifier and Type | Method and Description |
---|---|
LifecycleAdapter |
DefaultComponentLifecycleAdapterFactory.create(Object pojoService,
JavaComponent component,
FlowConstruct flowConstruct,
EntryPointResolverSet resolver,
MuleContext muleContext) |
void |
AbstractComponent.setFlowConstruct(FlowConstruct flowConstruct) |
void |
AbstractJavaComponent.setFlowConstruct(FlowConstruct flowConstruct) |
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 |
---|---|
FlowConstruct |
AbstractFlowConstructFactoryBean.getObject() |
Modifier and Type | Method and Description |
---|---|
protected MessageProcessor |
FlowRefFactoryBean.getReferencedFlow(String name,
FlowConstruct flowConstruct) |
Modifier and Type | Class and Description |
---|---|
class |
AbstractConfigurationPattern
A template class for configuration patterns, which takes care of setting common message processors and
optional transformers defined on the pattern.
|
class |
AbstractFlowConstruct
Abstract implementation of
FlowConstruct that:
Is constructed with unique name and MuleContext . |
class |
AbstractPipeline
Abstract implementation of
AbstractFlowConstruct that allows a list of MessageProcessor s
that will be used to process messages to be configured. |
class |
Bridge
A simple bridge between a single inbound endpoint and a single outbound endpoint.
|
class |
Flow
This implementation of
AbstractPipeline adds the following functionality:
Rejects inbound events when Flow is not started
Gathers statistics and processing time data
Implements MessagePorcessor allowing direct invocation of the pipeline
Supports the optional configuration of a ProcessingStrategy that determines how message
processors are processed. |
class |
SimpleService
In-out SOA-style simple service, with no outbound router.
|
class |
Validator |
Modifier and Type | Method and Description |
---|---|
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) |
Constructor and Description |
---|
FlowConstructLifecycleManager(FlowConstruct flowConstruct,
MuleContext muleContext) |
Modifier and Type | Field and Description |
---|---|
protected FlowConstruct |
FlowConstructStatisticsMessageProcessor.flowConstruct |
Modifier and Type | Method and Description |
---|---|
void |
FlowConstructStatisticsMessageProcessor.setFlowConstruct(FlowConstruct flowConstruct) |
Modifier and Type | Field and Description |
---|---|
protected FlowConstruct |
ComponentMessageNotification.flowConstruct |
Modifier and Type | Method and Description |
---|---|
FlowConstruct |
ComponentMessageNotification.getFlowConstruct() |
FlowConstruct |
BaseConnectorMessageNotification.getFlowConstruct() |
Modifier and Type | Method and Description |
---|---|
void |
NotificationHelper.fireNotification(MuleEvent event,
String uri,
FlowConstruct flowConstruct,
int action)
Fires a
ConnectorMessageNotification for the given arguments
using the ServerNotificationHandler associated to the given event |
void |
NotificationHelper.fireNotification(MuleMessage message,
String uri,
FlowConstruct flowConstruct,
int action)
Deprecated.
as of 3.7.2. Use
NotificationHelper.fireNotification(MuleEvent, String, FlowConstruct, int) instead |
Modifier and Type | Field and Description |
---|---|
protected FlowConstruct |
DevkitBasedMessageProcessor.flowConstruct
Flow Construct
|
Modifier and Type | Method and Description |
---|---|
FlowConstruct |
DevkitBasedMessageProcessor.getFlowConstruct()
Retrieves flowConstruct
|
Modifier and Type | Method and Description |
---|---|
void |
DevkitBasedMessageProcessor.setFlowConstruct(FlowConstruct value)
Sets flowConstruct
|
Constructor and Description |
---|
EventVariableResolverFactory.FlowContext(FlowConstruct flowConstruct) |
Modifier and Type | Method and Description |
---|---|
FlowConstruct |
DefaultInboundEndpoint.getFlowConstruct() |
Modifier and Type | Method and Description |
---|---|
MessageProcessor |
DefaultEndpointMessageProcessorChainFactory.createInboundMessageProcessorChain(InboundEndpoint endpoint,
FlowConstruct flowConstruct,
MessageProcessor target) |
MessageProcessor |
DefaultInboundEndpoint.createMessageProcessorChain(FlowConstruct flowContruct) |
protected abstract MessageProcessor |
AbstractEndpoint.createMessageProcessorChain(FlowConstruct flowContruct) |
protected MessageProcessor |
DefaultOutboundEndpoint.createMessageProcessorChain(FlowConstruct flowContruct) |
MessageProcessor |
AbstractEndpoint.getMessageProcessorChain(FlowConstruct flowContruct) |
void |
DefaultInboundEndpoint.setFlowConstruct(FlowConstruct flowConstruct) |
void |
DynamicURIInboundEndpoint.setFlowConstruct(FlowConstruct flowConstruct) |
Constructor and Description |
---|
EndpointMessageProcessorChainBuilder(ImmutableEndpoint endpoint,
FlowConstruct flowConstruct) |
OutboundEndpointMessageProcessorChainBuilder(ImmutableEndpoint endpoint,
FlowConstruct flowConstruct) |
Modifier and Type | Method and Description |
---|---|
protected FlowConstructStatistics |
DefaultServiceExceptionStrategy.getFlowConstructStatistics(FlowConstruct flowConstruct)
Deprecated.
|
protected ServiceStatistics |
DefaultServiceExceptionStrategy.getServiceStatistics(FlowConstruct flowConstruct)
Deprecated.
|
void |
RedeliveryExceeded.setFlowConstruct(FlowConstruct flowConstruct) |
protected void |
AbstractMessagingExceptionStrategy.stopFlow(FlowConstruct flow) |
Modifier and Type | Method and Description |
---|---|
FlowConstruct |
MessageProcessContext.getFlowConstruct() |
Modifier and Type | Field and Description |
---|---|
protected FlowConstruct |
AbstractEnvelopeInterceptor.flowConstruct |
Modifier and Type | Method and Description |
---|---|
void |
AbstractEnvelopeInterceptor.setFlowConstruct(FlowConstruct flowConstruct) |
Constructor and Description |
---|
ProcessingTimeInterceptor(MessageProcessor next,
FlowConstruct fc) |
Modifier and Type | Class and Description |
---|---|
class |
SedaService
Deprecated.
|
Constructor and Description |
---|
Process(BPMS bpms,
String name,
String resource,
FlowConstruct flowConstruct,
MuleContext muleContext) |
Process(BPMS bpms,
String name,
String resource,
String processIdField,
FlowConstruct flowConstruct,
MuleContext muleContext) |
Rules(RulesEngine rulesEngine,
String resource,
Object configuration,
String entryPoint,
Collection initialFacts,
boolean stateless,
boolean cepMode,
FlowConstruct flowConstruct,
MuleContext muleContext) |
Modifier and Type | Method and Description |
---|---|
void |
WebServiceMessageProcessorBuilder.setFlowConstruct(FlowConstruct flowConstruct) |
Modifier and Type | Method and Description |
---|---|
void |
FlowConfiguringMessageProcessor.setFlowConstruct(FlowConstruct flowConstruct) |
Modifier and Type | Method and Description |
---|---|
FlowConstruct |
HttpMessageProcessContext.getFlowConstruct() |
Modifier and Type | Method and Description |
---|---|
void |
DefaultHttpListener.setFlowConstruct(FlowConstruct flowConstruct) |
static MuleEvent |
HttpRequestToMuleEvent.transform(HttpRequestContext requestContext,
MuleContext muleContext,
FlowConstruct flowConstruct,
Boolean parseRequest,
ListenerPath listenerPath) |
Modifier and Type | Method and Description |
---|---|
void |
DefaultHttpRequester.setFlowConstruct(FlowConstruct flowConstruct) |
Modifier and Type | Class and Description |
---|---|
class |
WSProxy
This class is implemented to act as a Proxy for a Web Service.
|
Modifier and Type | Field and Description |
---|---|
protected FlowConstruct |
AbstractObjectFactory.flowConstruct |
Modifier and Type | Method and Description |
---|---|
void |
AbstractObjectFactory.setFlowConstruct(FlowConstruct flowConstruct) |
Modifier and Type | Field and Description |
---|---|
protected FlowConstruct |
ResponseMessageProcessorAdapter.flowConstruct |
protected FlowConstruct |
AbstractRedeliveryPolicy.flowConstruct |
protected FlowConstruct |
AbstractMuleObjectOwner.flowConstruct |
Modifier and Type | Method and Description |
---|---|
FlowConstruct |
AbstractMuleObjectOwner.getFlowConstruct() |
Modifier and Type | Method and Description |
---|---|
void |
ResponseMessageProcessorAdapter.setFlowConstruct(FlowConstruct flowConstruct) |
void |
AbstractRedeliveryPolicy.setFlowConstruct(FlowConstruct flowConstruct) |
void |
AbstractMuleObjectOwner.setFlowConstruct(FlowConstruct flowConstruct) |
Modifier and Type | Field and Description |
---|---|
protected FlowConstruct |
AbstractMessageProcessorChain.flowConstruct |
protected FlowConstruct |
AbstractMessageProcessorChainBuilder.flowConstruct |
Modifier and Type | Method and Description |
---|---|
void |
AbstractMessageProcessorChain.setFlowConstruct(FlowConstruct flowConstruct) |
Constructor and Description |
---|
AbstractMessageProcessorChainBuilder(FlowConstruct flowConstruct) |
DefaultMessageProcessorChainBuilder(FlowConstruct flowConstruct) |
SimpleMessageProcessorChainBuilder(FlowConstruct flowConstruct) |
Modifier and Type | Method and Description |
---|---|
WorkManager |
NonBlockingProcessingStrategy.createWorkManager(FlowConstruct flowConstruct) |
Modifier and Type | Method and Description |
---|---|
FlowConstruct |
MuleRegistryHelper.lookupFlowConstruct(String name) |
Modifier and Type | Method and Description |
---|---|
Collection<FlowConstruct> |
MuleRegistryHelper.lookupFlowConstructs() |
Modifier and Type | Method and Description |
---|---|
void |
MuleRegistryHelper.registerFlowConstruct(FlowConstruct flowConstruct) |
Modifier and Type | Field and Description |
---|---|
protected FlowConstruct |
AbstractAggregator.flowConstruct |
protected FlowConstruct |
IdempotentMessageFilter.flowConstruct |
Modifier and Type | Method and Description |
---|---|
FlowConstruct |
UntilSuccessfulConfiguration.getFlowConstruct() |
Modifier and Type | Method and Description |
---|---|
void |
AbstractAggregator.setFlowConstruct(FlowConstruct flowConstruct) |
void |
AbstractSelectiveRouter.setFlowConstruct(FlowConstruct flowConstruct) |
void |
MessageProcessorFilterPair.setFlowConstruct(FlowConstruct flowConstruct) |
void |
MessageFilter.setFlowConstruct(FlowConstruct flowConstruct) |
void |
IdempotentMessageFilter.setFlowConstruct(FlowConstruct flowConstruct) |
Constructor and Description |
---|
EventCorrelator(EventCorrelatorCallback callback,
MessageProcessor timeoutMessageProcessor,
MessageInfoMapping messageInfoMapping,
MuleContext muleContext,
FlowConstruct flowConstruct,
PartitionableObjectStore correlatorStore,
String storePrefix,
ObjectStore<Long> processedGroups) |
Modifier and Type | Method and Description |
---|---|
protected void |
AbstractOutboundRouter.setMessageProperties(FlowConstruct service,
MuleMessage message,
MessageProcessor route) |
Modifier and Type | Field and Description |
---|---|
protected FlowConstruct |
AbstractAsyncRequestReplyRequester.flowConstruct |
Modifier and Type | Method and Description |
---|---|
void |
AbstractAsyncRequestReplyRequester.setFlowConstruct(FlowConstruct flowConstruct) |
Modifier and Type | Field and Description |
---|---|
protected FlowConstruct |
BaseOAuth2Manager.flowConstruct
Flow Construct
|
Modifier and Type | Method and Description |
---|---|
FlowConstruct |
BaseOAuth2Manager.getFlowConstruct()
Retrieves flowConstruct
|
Modifier and Type | Method and Description |
---|---|
void |
BaseOAuth2Manager.setFlowConstruct(FlowConstruct flowConstruct) |
Modifier and Type | Method and Description |
---|---|
HttpCallback |
DefaultHttpCallbackFactory.createCallback(HttpCallbackAdapter adapter,
String authCodeRegex,
FetchAccessTokenMessageProcessor fetchAccessTokenMessageProcessor,
MessageProcessor listener,
MuleContext muleContext,
FlowConstruct flowConstruct) |
Modifier and Type | Class and Description |
---|---|
class |
AbstractService
Deprecated.
|
Modifier and Type | Method and Description |
---|---|
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.
|
Constructor and Description |
---|
ServiceLifecycleManager(FlowConstruct service,
MuleContext muleContext)
Deprecated.
|
Modifier and Type | Method and Description |
---|---|
FlowConstruct |
DefaultMuleSession.getFlowConstruct() |
Modifier and Type | Method and Description |
---|---|
void |
DefaultMuleSession.setFlowConstruct(FlowConstruct flowConstruct) |
Constructor and Description |
---|
DefaultMuleSession(FlowConstruct flowConstruct,
MuleContext muleContext)
Deprecated.
|
DefaultMuleSession(MuleSession source,
FlowConstruct flowConstruct)
Deprecated.
|
Modifier and Type | Field and Description |
---|---|
protected FlowConstruct |
StartableCompositeMessageSource.flowConstruct |
Modifier and Type | Method and Description |
---|---|
void |
ClusterizableMessageSourceWrapper.setFlowConstruct(FlowConstruct flowConstruct) |
void |
StartableCompositeMessageSource.setFlowConstruct(FlowConstruct pattern) |
Constructor and Description |
---|
ClusterizableMessageSourceWrapper(MuleContext muleContext,
ClusterizableMessageSource messageSource,
FlowConstruct flowConstruct) |
Modifier and Type | Method and Description |
---|---|
protected FlowConstruct |
FunctionalTestCase.getFlowConstruct(String name)
Deprecated.
|
Modifier and Type | Method and Description |
---|---|
protected Object |
FunctionalTestCase.getComponent(FlowConstruct flowConstruct)
Deprecated.
Returns an instance of the service's component object.
|
Modifier and Type | Field and Description |
---|---|
protected FlowConstruct |
AssertionMessageProcessor.flowConstruct |
Modifier and Type | Method and Description |
---|---|
void |
AssertionMessageProcessor.setFlowConstruct(FlowConstruct flowConstruct) |
Modifier and Type | Method and Description |
---|---|
protected FlowConstruct |
FunctionalTestCase.getFlowConstruct(String flowName) |
Modifier and Type | Method and Description |
---|---|
protected Object |
FunctionalTestCase.getComponent(FlowConstruct flowConstruct)
Returns an instance of the service's component object.
|
Modifier and Type | Method and Description |
---|---|
void |
InboundEndpointWrapper.setFlowConstruct(FlowConstruct flowConstruct) |
Modifier and Type | Field and Description |
---|---|
protected FlowConstruct |
AbstractMessageReceiver.flowConstruct
The Service with which this receiver is associated with
|
Modifier and Type | Method and Description |
---|---|
FlowConstruct |
AbstractMessageReceiver.getFlowConstruct() |
FlowConstruct |
TransportMessageProcessContext.getFlowConstruct() |
FlowConstruct |
AbstractTransportMessageProcessTemplate.getFlowConstruct() |
Modifier and Type | Method and Description |
---|---|
protected MessageReceiver |
AbstractConnector.createReceiver(FlowConstruct flowConstruct,
InboundEndpoint endpoint)
Create a Message receiver for this connector
|
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 |
AbstractConnector.registerListener(InboundEndpoint endpoint,
MessageProcessor messageProcessorChain,
FlowConstruct flowConstruct) |
void |
AbstractConnector.unregisterListener(InboundEndpoint endpoint,
FlowConstruct flowConstruct) |
Constructor and Description |
---|
AbstractMessageReceiver(Connector connector,
FlowConstruct flowConstruct,
InboundEndpoint endpoint)
Creates the Message Receiver
|
AbstractPollingMessageReceiver(Connector connector,
FlowConstruct flowConstruct,
InboundEndpoint endpoint) |
TransactedPollingMessageReceiver(Connector connector,
FlowConstruct flowConstruct,
InboundEndpoint endpoint) |
TransactedPollingMessageReceiver(Connector connector,
FlowConstruct flowConstruct,
InboundEndpoint endpoint,
long frequency)
Deprecated.
|
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 |
---|---|
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) |
Modifier and Type | Method and Description |
---|---|
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) |
Modifier and Type | Method and Description |
---|---|
MessageReceiver |
FtpConnector.createReceiver(FlowConstruct flowConstruct,
InboundEndpoint endpoint) |
Constructor and Description |
---|
FtpMessageReceiver(Connector connector,
FlowConstruct flowConstruct,
InboundEndpoint endpoint,
long frequency) |
Modifier and Type | Method and Description |
---|---|
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 |
---|
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 | Class and Description |
---|---|
class |
HttpProxy
A simple HTTP proxy that supports transformation and caching.
|
Modifier and Type | Method and Description |
---|---|
MessageReceiver |
JdbcConnector.createReceiver(FlowConstruct flowConstruct,
InboundEndpoint endpoint) |
Constructor and Description |
---|
JdbcMessageReceiver(Connector connector,
FlowConstruct flowConstruct,
InboundEndpoint endpoint,
String readStmt,
String ackStmt) |
Modifier and Type | Method and Description |
---|---|
protected Object |
JmsConnector.getReceiverKey(FlowConstruct flowConstruct,
InboundEndpoint endpoint) |
Constructor and Description |
---|
JmsMessageReceiver(Connector connector,
FlowConstruct flowConstruct,
InboundEndpoint endpoint)
Deprecated.
|
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 |
---|---|
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 Object |
ServletConnector.getReceiverKey(FlowConstruct flowConstruct,
InboundEndpoint endpoint) |
Constructor and Description |
---|
ServletMessageReceiver(Connector connector,
FlowConstruct flowConstruct,
InboundEndpoint endpoint) |
Modifier and Type | Method and Description |
---|---|
protected MessageReceiver |
JettyHttpConnector.createReceiver(FlowConstruct flowConstruct,
InboundEndpoint endpoint) |
Constructor and Description |
---|
JettyHttpMessageReceiver(Connector connector,
FlowConstruct flowConstruct,
InboundEndpoint endpoint) |
Modifier and Type | Method and Description |
---|---|
MessageReceiver |
SftpConnector.createReceiver(FlowConstruct flow,
InboundEndpoint endpoint) |
Constructor and Description |
---|
SftpMessageReceiver(SftpConnector connector,
FlowConstruct flow,
InboundEndpoint endpoint) |
SftpMessageReceiver(SftpConnector connector,
FlowConstruct flow,
InboundEndpoint endpoint,
long frequency) |
Modifier and Type | Method and Description |
---|---|
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) |
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) |
Constructor and Description |
---|
ExceptionReturnTcpMessageReceiver(Connector connector,
FlowConstruct flowConstruct,
InboundEndpoint endpoint) |
PollingTcpMessageReceiver(Connector connector,
FlowConstruct flowConstruct,
InboundEndpoint endpoint) |
TcpMessageReceiver(Connector connector,
FlowConstruct flowConstruct,
InboundEndpoint endpoint) |
Modifier and Type | Method and Description |
---|---|
protected Object |
UdpConnector.getReceiverKey(FlowConstruct flowConstruct,
InboundEndpoint endpoint) |
Constructor and Description |
---|
UdpMessageReceiver(Connector connector,
FlowConstruct flowConstruct,
InboundEndpoint endpoint) |
Modifier and Type | Method and Description |
---|---|
MessageReceiver |
VMConnector.createReceiver(FlowConstruct flowConstruct,
InboundEndpoint endpoint) |
Constructor and Description |
---|
VMMessageReceiver(Connector connector,
FlowConstruct flowConstruct,
InboundEndpoint endpoint) |
Constructor and Description |
---|
XmppMessageReceiver(AbstractConnector connector,
FlowConstruct flowConstruct,
InboundEndpoint endpoint) |
XmppPollingMessageReceiver(Connector conn,
FlowConstruct flowConstruct,
InboundEndpoint endpoint) |
Copyright © 2003–2016 MuleSoft, Inc.. All rights reserved.