public class RetrieveMessageReceiverPollCounter extends RetrieveMessageReceiver
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 |
---|
RetrieveMessageReceiverPollCounter(Connector connector,
FlowConstruct flowConstruct,
InboundEndpoint endpoint,
long checkFrequency,
boolean backupEnabled,
String backupFolder) |
Modifier and Type | Method and Description |
---|---|
int |
getNumberOfMadePolls() |
void |
messagesAdded(MessageCountEvent event) |
boolean |
pollNumbersGreaterThan(int n) |
doConnect, doDisconnect, doDispose, doStart, doStop, getFolder, handleUnacceptedFilter, messagesRemoved, poll, pollOnPrimaryInstanceOnly, setFolder, storeMessage
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 RetrieveMessageReceiverPollCounter(Connector connector, FlowConstruct flowConstruct, InboundEndpoint endpoint, long checkFrequency, boolean backupEnabled, String backupFolder) throws CreateException
CreateException
public void messagesAdded(MessageCountEvent event)
messagesAdded
in interface MessageCountListener
messagesAdded
in class RetrieveMessageReceiver
public boolean pollNumbersGreaterThan(int n)
public int getNumberOfMadePolls()
Copyright © 2003–2016 MuleSoft, Inc.. All rights reserved.