public class FtpConnectReader extends ConnectReader<FtpConnectorReadersConfig>
ConnectReader.DeleteFailureTest, ConnectReader.Message, ConnectReader.PermanentFailureException, ConnectReader.ReaderFailureException, ConnectReader.ReadFailureTest, ConnectReader.TemporaryFailureException
config, log, readerContext, readerProcessor
Constructor and Description |
---|
FtpConnectReader() |
Modifier and Type | Method and Description |
---|---|
void |
nativeClose()
All resources opened/initialized in nativeInitReader() should be
closed/released here.
|
void |
nativeDelete()
Deletes message with ID specified in call to nativeInitMessage().
|
void |
nativeInitMessage(java.lang.String messageId)
Initialization of resources used per message basis.
|
void |
nativeInitReader()
Initialization of resources used by the reader.
|
java.util.List<java.lang.String> |
nativeList()
Create a light ware list of all messages available at the source.
|
ConnectReader.Message |
nativeRead()
Reads message with ID specified in call to nativeInitMessage().
|
canList, close, closeMessage, createResponse, deleteMessage, getExecutionMode, getLocation, getMaxRetries, getName, getOrigin, getReader, getTimeout, initMessage, initReader, listMessages, nativeCloseMessage, performLoggerThreadCheck, readMessage, selectMessage, setOrigin
public void nativeInitReader() throws ConnectReader.ReaderFailureException
ConnectReader
nativeInitReader
in class ConnectReader<FtpConnectorReadersConfig>
ConnectReader.ReaderFailureException
ConnectReader.nativeClose()
public void nativeInitMessage(java.lang.String messageId) throws ConnectReader.ReaderFailureException
ConnectReader
nativeInitMessage
in class ConnectReader<FtpConnectorReadersConfig>
messageId
- ID of the message that has to be read, processed and deletedConnectReader.ReaderFailureException
ConnectReader.nativeCloseMessage()
public java.util.List<java.lang.String> nativeList() throws ConnectReader.ReaderFailureException
ConnectReader
nativeList
in class ConnectReader<FtpConnectorReadersConfig>
ConnectReader.ReaderFailureException
public ConnectReader.Message nativeRead() throws ConnectReader.ReaderFailureException
ConnectReader
nativeRead
in class ConnectReader<FtpConnectorReadersConfig>
ConnectReader.ReaderFailureException
ConnectReader.nativeInitMessage(String)
public void nativeDelete() throws ConnectReader.ReaderFailureException
ConnectReader
nativeDelete
in class ConnectReader<FtpConnectorReadersConfig>
ConnectReader.ReaderFailureException
ConnectReader.nativeInitMessage(String)
,
ConnectReader.nativeRead()
public void nativeClose()
ConnectReader
nativeClose
in class ConnectReader<FtpConnectorReadersConfig>
ConnectReader.nativeInitReader()