public class SftpMessageReceiver extends AbstractPollingMessageReceiver
SftpMessageReceiver
polls and receives files from an sftp service
using jsch. This receiver produces an InputStream payload, which can be
materialized in a MessageDispatcher or Component.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 |
---|
SftpMessageReceiver(SftpConnector connector,
FlowConstruct flow,
InboundEndpoint endpoint) |
SftpMessageReceiver(SftpConnector connector,
FlowConstruct flow,
InboundEndpoint endpoint,
long frequency) |
Modifier and Type | Method and Description |
---|---|
protected SftpReceiverRequesterUtil |
createSftpReceiverRequesterUtil(InboundEndpoint endpoint) |
void |
doConnect() |
void |
doDisconnect() |
protected void |
doDispose() |
protected void |
doInitialise() |
protected MuleMessage |
handleUnacceptedFilter(MuleMessage message)
SFTP-35
|
void |
poll() |
protected boolean |
pollOnPrimaryInstanceOnly()
If this returns true for a transport, polling for that transport takes place only on the primary instance.
|
protected void |
routeFile(String path) |
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, 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 SftpMessageReceiver(SftpConnector connector, FlowConstruct flow, InboundEndpoint endpoint, long frequency) throws CreateException
CreateException
public SftpMessageReceiver(SftpConnector connector, FlowConstruct flow, InboundEndpoint endpoint) throws CreateException
CreateException
protected SftpReceiverRequesterUtil createSftpReceiverRequesterUtil(InboundEndpoint endpoint)
public void poll() throws Exception
poll
in class AbstractPollingMessageReceiver
Exception
protected void doInitialise() throws InitialisationException
doInitialise
in class AbstractTransportMessageHandler
InitialisationException
protected boolean pollOnPrimaryInstanceOnly()
AbstractPollingMessageReceiver
pollOnPrimaryInstanceOnly
in class AbstractPollingMessageReceiver
protected MuleMessage handleUnacceptedFilter(MuleMessage message)
handleUnacceptedFilter
in class AbstractMessageReceiver
public void doConnect() throws Exception
doConnect
in class AbstractTransportMessageHandler
Exception
public void doDisconnect() throws Exception
doDisconnect
in class AbstractTransportMessageHandler
Exception
protected void doDispose()
doDispose
in class AbstractMessageReceiver
Copyright © 2003–2015 MuleSoft, Inc.. All rights reserved.