public class PollingMessageSourceFactoryBean extends InboundEndpointFactoryBean
Modifier and Type | Field and Description |
---|---|
protected Long |
frequency |
protected MessageProcessor |
messageProcessor |
protected MessageProcessorPollingOverride |
override |
protected SchedulerFactory<Runnable> |
schedulerFactory |
logger
connector, createConnector, deleteUnacceptedMessages, disableTransportTransformer, encoding, initialState, messageExchangePattern, messageProcessors, messageProcessorsFactory, mimeType, muleContext, name, objectNameHelper, properties, PROPERTY_RESPONSE_PROPERTIES, PROPERTY_RESPONSE_TIMEOUT, redeliveryPolicy, registryId, responseMessageProcessors, responsePropertiesList, responseTimeout, responseTransformers, retryPolicyTemplate, synchronous, transactionConfig, transformers, uriBuilder
PHASE_NAME
PROPERTY_NAME
Constructor and Description |
---|
PollingMessageSourceFactoryBean() |
Modifier and Type | Method and Description |
---|---|
Object |
doGetObject() |
void |
setFrequency(Long frequency) |
void |
setMessageProcessor(MessageProcessor messageProcessor) |
void |
setOverride(MessageProcessorPollingOverride override) |
void |
setSchedulerFactory(SchedulerFactory<Runnable> schedulerFactory) |
getObjectType
getObject, initialise, isSingleton
addMessageProcessor, addResponseMessageProcessor, addResponseTransformer, addResponseTransformerProcessors, addTransformer, addTransformerProcessors, buildInboundEndpoint, buildOutboundEndpoint, checkInboundExchangePattern, clone, createInboundEndpoint, createOutboundEndpoint, doBuildInboundEndpoint, doBuildOutboundEndpoint, equal, equals, getConnector, getDefaultConnector, getDefaultDeleteUnacceptedMessages, getDefaultDisableTransportTransformer, getDefaultEndpointEncoding, getDefaultInitialState, getDefaultMessageProcessorsFactory, getDefaultResponseTimeout, getDefaultSecurityFilter, getDefaultTransactionConfig, getDeleteUnacceptedMessages, getEndpointBuilder, getEndpointEncoding, getInitialState, getMessageProcessors, getMessageProcessorsFactory, getMimeType, getName, getProperties, getRedeliveryPolicy, getResponseMessageProcessors, getResponseTimeout, getResponseTransformersFromUri, getRetryPolicyTemplate, getScheme, getSecurityFilter, getTransactionConfig, getTransformersFromUri, hashCode, initExchangePatternFromConnectorDefault, isAlwaysCreateConnector, isDisableTransportTransformer, prepareToBuildEndpoint, setConnector, setCreateConnector, setDeleteUnacceptedMessages, setDisableTransportTransformer, setEncoding, setExchangePattern, setInitialState, setMessageProcessors, setMimeType, setMuleContext, setName, setProperties, setPropertiesFromProperties, setProperty, setRedeliveryPolicy, setRegistryId, setResponseMessageProcessors, setResponseTimeout, setResponseTransformers, setRetryPolicyTemplate, setTransactionConfig, setTransformers, setURIBuilder
getAnnotation, getAnnotations, setAnnotations
protected SchedulerFactory<Runnable> schedulerFactory
protected MessageProcessor messageProcessor
protected MessageProcessorPollingOverride override
protected Long frequency
public Object doGetObject() throws Exception
doGetObject
in class InboundEndpointFactoryBean
Exception
public void setMessageProcessor(MessageProcessor messageProcessor)
public void setOverride(MessageProcessorPollingOverride override)
public void setFrequency(Long frequency)
public void setSchedulerFactory(SchedulerFactory<Runnable> schedulerFactory)
Copyright © 2003–2015 MuleSoft, Inc.. All rights reserved.