ifs.fnd.connect.readers

Class NolistConnectReader<C extends ConnectorReadersConfig>

java.lang.Object

ifs.fnd.connect.readers.ConnectReader<C>

ifs.fnd.connect.readers.NolistConnectReader<C>

Type Parameters:

C - subclass extending ConnectorReadersConfig

All Implemented Interfaces:

java.lang.AutoCloseable

Direct Known Subclasses:

JmsConnectReader, MailConnectReader

public abstract class NolistConnectReader<C extends ConnectorReadersConfig>
extends ConnectReader<C>

Super class for readers that cannot create message listing without reading messages at the same time. This type of readers override nativeLoop() instead of nativeList(), nativeRead() and nativeDelete(). Even initialization is done in one method, nativeInit(), instead of being split between nativeInitReader() and nativeInitMessage().

Author:

japase

See Also:

ConnectorReadersConfig

Nested Class Summary

Nested classes/interfaces inherited from class ifs.fnd.connect.readers.ConnectReader

ConnectReader.DeleteFailureTest, ConnectReader.Message, ConnectReader.PermanentFailureException, ConnectReader.ReaderFailureException, ConnectReader.ReadFailureTest, ConnectReader.TemporaryFailureException

Field Summary

Fields inherited from class ifs.fnd.connect.readers.ConnectReader

config, log, readerContext, readerProcessor

Constructor Summary

Constructors

Constructor and Description
NolistConnectReader()

Method Summary

Modifier and Type	Method and Description
void	nativeDelete() Called by the Reader framework.
protected abstract void	nativeInit() Initialization of resources used by the reader.
void	nativeInitMessage(java.lang.String messageId) Called by the Reader framework.
void	nativeInitReader() Called by the Reader framework.
java.util.List<java.lang.String>	nativeList() Called by the Reader framework.
protected abstract void	nativeLoop() Loop over all messages available at the native source.
ConnectReader.Message	nativeRead() Called by the Reader framework.
protected void	processMessage(ConnectReader.Message msg) Callback method to be called from nativeLoop() for processing of the read message.

Methods inherited from class ifs.fnd.connect.readers.ConnectReader

canList, close, closeMessage, createResponse, deleteMessage, getExecutionMode, getLocation, getMaxRetries, getName, getOrigin, getReader, getTimeout, initMessage, initReader, listMessages, nativeClose, nativeCloseMessage, performLoggerThreadCheck, readMessage, selectMessage, setOrigin

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

NolistConnectReader

public NolistConnectReader()

Method Detail

nativeInitReader

public final void nativeInitReader()
                            throws ConnectReader.ReaderFailureException

Called by the Reader framework.

Specified by:

nativeInitReader in class ConnectReader<C extends ConnectorReadersConfig>

Throws:

ConnectReader.ReaderFailureException

See Also:

ConnectReader.nativeClose()

nativeInitMessage

public final void nativeInitMessage(java.lang.String messageId)
                             throws ConnectReader.ReaderFailureException

Called by the Reader framework.

Specified by:

nativeInitMessage in class ConnectReader<C extends ConnectorReadersConfig>

Parameters:

messageId -

Throws:

ConnectReader.ReaderFailureException

See Also:

ConnectReader.nativeCloseMessage()

nativeList

public final java.util.List<java.lang.String> nativeList()
                                                  throws ConnectReader.ReaderFailureException

Called by the Reader framework.

Specified by:

nativeList in class ConnectReader<C extends ConnectorReadersConfig>

Returns:

Throws:

ConnectReader.ReaderFailureException

nativeRead

public final ConnectReader.Message nativeRead()

Called by the Reader framework.

Specified by:

nativeRead in class ConnectReader<C extends ConnectorReadersConfig>

Returns:

See Also:

ConnectReader.nativeInitMessage(String)

nativeDelete

public final void nativeDelete()

Called by the Reader framework.

Specified by:

nativeDelete in class ConnectReader<C extends ConnectorReadersConfig>

See Also:

ConnectReader.nativeInitMessage(String), ConnectReader.nativeRead()

processMessage

protected final void processMessage(ConnectReader.Message msg)
                             throws ConnectReader.ReaderFailureException

Callback method to be called from nativeLoop() for processing of the read message.

Parameters:

msg -

Throws:

ConnectReader.ReaderFailureException

nativeInit

protected abstract void nativeInit()
                            throws ConnectReader.ReaderFailureException

Initialization of resources used by the reader. The reader implements the AutoCloseable interface, so all resources initiated/open here have to be released/closed in the nativeClose() method.

Throws:

ConnectReader.ReaderFailureException

See Also:

ConnectReader.nativeClose()

nativeLoop

protected abstract void nativeLoop()
                            throws ConnectReader.ReaderFailureException

Loop over all messages available at the native source. For each read message create an instance of Message, call setData() on it and then call the callback method processMessage(). Then, after message has been processed, it is ok to delete it from the native source.

Throws:

ConnectReader.ReaderFailureException

See Also:

ConnectReader.Message