public class RetrieveMessageReceiver extends AbstractPollingMessageReceiver implements MessageCountListener
DEFAULT_POLL_FREQUENCY, DEFAULT_POLL_TIMEUNIT, DEFAULT_STARTUP_DELAY, schedules
defaultInboundTransformers, defaultResponseTransformers, flowConstruct, listener, receiverKey, replyToHandler
connected, connector, defaultMessageInfoMapping, endpoint, lifecycleManager, logger, muleMessageFactory, retryTemplate
PHASE_NAME
PHASE_NAME
PHASE_NAME
PHASE_NAME
Constructor and Description |
---|
RetrieveMessageReceiver(Connector connector,
FlowConstruct flowConstruct,
InboundEndpoint endpoint,
long checkFrequency,
boolean backupEnabled,
String backupFolder) |
Modifier and Type | Method and Description |
---|---|
protected void |
doConnect() |
protected void |
doDisconnect() |
protected void |
doDispose() |
protected void |
doStart() |
protected void |
doStop() |
Folder |
getFolder() |
protected MuleMessage |
handleUnacceptedFilter(MuleMessage message) |
void |
messagesAdded(MessageCountEvent event) |
void |
messagesRemoved(MessageCountEvent event) |
void |
poll() |
protected boolean |
pollOnPrimaryInstanceOnly()
If this returns true for a transport, polling for that transport takes place only on the primary instance.
|
void |
setFolder(Folder folder) |
protected void |
storeMessage(Message msg)
Helper method for testing which stores a copy of the message locally as the
POP3
message will be deleted from the server
|
createWork, disableNativeScheduling, getBatchSize, getFrequency, getTimeUnit, performPoll, schedule, setFrequency, setTimeUnit, unschedule
applyInboundTransformers, applyResponseTransformers, connectHandler, createExecutionTemplate, createLifecycleManager, createMuleEvent, doStartHandler, getConnectEventId, getConnectionDescription, getEndpoint, getEndpointURI, getFlowConstruct, getReceiverKey, getReplyToHandler, getWorkManager, initialise, processMessage, propagateRootMessageIdProperty, routeEvent, routeMessage, routeMessage, routeMessage, routeMessage, routeMessage, setEndpoint, setListener, setReceiverKey, shouldConsumeInEveryNode, toString, warnIfMuleClientSendUsed
activate, connect, createMuleMessage, createMuleMessage, createMuleMessage, createMuleMessageFactory, createNullMuleMessage, disconnect, dispose, disposeAndLogException, doInitialise, getConnectEventId, getConnector, getLifecycleState, initializeMessageFactory, initializeRetryPolicy, isConnected, isDoThreading, isStarted, isStarting, isStopped, isStopping, passivate, setEndpoint, start, stop, validate, validateConnection
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait
createMuleMessage, createMuleMessage
connect, disconnect, isConnected, validateConnection
dispose
public RetrieveMessageReceiver(Connector connector, FlowConstruct flowConstruct, InboundEndpoint endpoint, long checkFrequency, boolean backupEnabled, String backupFolder) throws CreateException
CreateException
protected void doConnect() throws Exception
doConnect
in class AbstractTransportMessageHandler
Exception
protected void doDisconnect() throws Exception
doDisconnect
in class AbstractTransportMessageHandler
Exception
protected void doStop() throws MuleException
doStop
in class AbstractPollingMessageReceiver
MuleException
protected void doStart() throws MuleException
doStart
in class AbstractPollingMessageReceiver
MuleException
public void messagesAdded(MessageCountEvent event)
messagesAdded
in interface MessageCountListener
public void messagesRemoved(MessageCountEvent event)
messagesRemoved
in interface MessageCountListener
public Folder getFolder()
public void setFolder(Folder folder)
folder
- protected void storeMessage(Message msg) throws IOException, MessagingException
msg
- the message to storeIOException
- If a failure happens writing the messageMessagingException
- If a failure happens reading the messagepublic void poll()
poll
in class AbstractPollingMessageReceiver
protected boolean pollOnPrimaryInstanceOnly()
AbstractPollingMessageReceiver
pollOnPrimaryInstanceOnly
in class AbstractPollingMessageReceiver
protected void doDispose()
doDispose
in class AbstractMessageReceiver
protected MuleMessage handleUnacceptedFilter(MuleMessage message)
handleUnacceptedFilter
in class AbstractMessageReceiver
Copyright © 2003–2016 MuleSoft, Inc.. All rights reserved.