public static class FileAgeAndPollingFrequencyInteractionTestCase.TestFileMessageReceiver extends FileMessageReceiver
COMPARATOR_CLASS_NAME_PROPERTY, COMPARATOR_REVERSE_ORDER_PROPERTY, MULE_TRANSPORT_FILE_SINGLEPOLLINSTANCE
DEFAULT_POLL_FREQUENCY, DEFAULT_POLL_TIMEUNIT, DEFAULT_STARTUP_DELAY, schedules
defaultInboundTransformers, defaultResponseTransformers, flowConstruct, listener, receiverKey, replyToHandler
connected, connector, endpoint, lifecycleManager, logger, muleMessageFactory, retryTemplate
PHASE_NAME
PHASE_NAME
PHASE_NAME
PHASE_NAME
Constructor and Description |
---|
FileAgeAndPollingFrequencyInteractionTestCase.TestFileMessageReceiver(Connector connector,
FlowConstruct flowConstruct,
InboundEndpoint endpoint,
String readDir,
String moveDir,
String moveToPattern,
long frequency) |
Modifier and Type | Method and Description |
---|---|
void |
poll() |
attemptFileLock, basicListFiles, checkMustForceSync, createReceiverFileInputStream, createReceiverFileInputStream, doConnect, doDisconnect, doDispose, doInitialise, getComparator, isAgedFile, pollOnPrimaryInstanceOnly, processFile, rollbackFileMove
createWork, disableNativeScheduling, doStart, doStop, getBatchSize, getFrequency, getTimeUnit, performPoll, schedule, setFrequency, setTimeUnit, unschedule
applyInboundTransformers, applyResponseTransformers, connectHandler, createExecutionTemplate, createLifecycleManager, createMuleEvent, doStartHandler, getConnectEventId, getConnectionDescription, getEndpoint, getEndpointURI, getFlowConstruct, getReceiverKey, getReplyToHandler, getWorkManager, handleUnacceptedFilter, 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, 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 FileAgeAndPollingFrequencyInteractionTestCase.TestFileMessageReceiver(Connector connector, FlowConstruct flowConstruct, InboundEndpoint endpoint, String readDir, String moveDir, String moveToPattern, long frequency) throws CreateException
CreateException
public void poll()
poll
in class FileMessageReceiver
Copyright © 2003–2015 MuleSoft, Inc.. All rights reserved.