public class RetrieveMessageRequester extends AbstractMessageRequester
connected, connector, defaultMessageInfoMapping, endpoint, lifecycleManager, logger, muleMessageFactory, retryTemplate
PHASE_NAME
PHASE_NAME
PHASE_NAME
PHASE_NAME
REQUEST_NO_WAIT, REQUEST_WAIT_INDEFINITELY
Constructor and Description |
---|
RetrieveMessageRequester(InboundEndpoint endpoint) |
Modifier and Type | Method and Description |
---|---|
protected void |
doConnect() |
protected void |
doDisconnect() |
protected void |
doDispatch(MuleEvent event) |
protected void |
doDispose() |
protected MuleMessage |
doRequest(long timeout)
Make a specific request to the underlying transport.
|
protected MuleMessage |
doSend(MuleEvent event) |
protected void |
ensureFolderIsOpen(Folder fldr) |
protected void |
flagMessage(Message message)
There seems to be some variation on pop3 implementation so it may be
preferrable to mark messages as seen here and also overload the getMessages
method to grab only new messages
|
protected int |
getMessageCount() |
protected Message |
getNextMessage() |
protected boolean |
hasMessages()
Optimised check to se whether to return the message count and retrieve the
messages.
|
applyInboundTransformers, createLifecycleManager, getEndpoint, getRequesterName, getWorkManager, initialise, request
activate, connect, connectHandler, createMuleMessage, createMuleMessage, createMuleMessage, createMuleMessageFactory, createNullMuleMessage, disconnect, dispose, disposeAndLogException, doInitialise, doStart, doStartHandler, doStop, getConnectEventId, getConnectionDescription, getConnector, getLifecycleState, initializeMessageFactory, initializeRetryPolicy, isConnected, isDoThreading, isStarted, isStarting, isStopped, isStopping, passivate, setEndpoint, start, stop, toString, validate, validateConnection
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait
activate, createMuleMessage, createMuleMessage, getConnector, passivate, validate
connect, disconnect, getConnectionDescription, isConnected, validateConnection
dispose
getLifecycleState
public RetrieveMessageRequester(InboundEndpoint endpoint)
protected void doConnect() throws Exception
doConnect
in class AbstractTransportMessageHandler
Exception
protected void ensureFolderIsOpen(Folder fldr)
protected void doDisconnect() throws Exception
doDisconnect
in class AbstractTransportMessageHandler
Exception
protected void doDispatch(MuleEvent event) throws Exception
event
- UnsupportedOperationException
Exception
protected MuleMessage doSend(MuleEvent event) throws Exception
event
- UnsupportedOperationException
Exception
protected MuleMessage doRequest(long timeout) throws Exception
doRequest
in class AbstractMessageRequester
timeout
- the maximum time the operation should block before returning.
The call should return immediately if there is data available. If
no data becomes available before the timeout elapses, null will be
returnedException
- if the call to the underlying protocal causes an exceptionprotected void flagMessage(Message message) throws MessagingException
MessagingException
protected Message getNextMessage() throws MessagingException
MessagingException
protected int getMessageCount() throws MessagingException
MessagingException
protected boolean hasMessages() throws MessagingException
MessagingException
protected void doDispose()
doDispose
in class AbstractTransportMessageHandler
Copyright © 2003–2016 MuleSoft, Inc.. All rights reserved.