Package org.frankframework.filesystem
Class FileSystemMessageBrowser<F,FS extends IBasicFileSystem<F>>
java.lang.Object
org.frankframework.filesystem.FileSystemMessageBrowser<F,FS>
- All Implemented Interfaces:
IMessageBrowser<F>
,IXAEnabled
public class FileSystemMessageBrowser<F,FS extends IBasicFileSystem<F>>
extends Object
implements IMessageBrowser<F>
-
Nested Class Summary
Nested classes/interfaces inherited from interface org.frankframework.core.IMessageBrowser
IMessageBrowser.HideMethod, IMessageBrowser.SortOrder, IMessageBrowser.StorageType
-
Field Summary
Fields -
Constructor Summary
ConstructorsConstructorDescriptionFileSystemMessageBrowser
(FS fileSystem, String folder, String messageIdPropertyKey) -
Method Summary
Modifier and TypeMethodDescriptionbrowseMessage
(String storageKey) Retrieves the message, but does not delete.protected boolean
contains
(String value, ThrowingFunction<IMessageBrowsingIteratorItem, String, ListenerException> field) boolean
containsCorrelationId
(String correlationId) boolean
containsMessageId
(String originalMessageId) Check if the storage contains message with the given original messageId (as passed to storeMessage).void
deleteMessage
(String storageKey) Deletes the message.getContext
(String storageKey) Retrieves the message context as an iteratorItem.Gets an enumeration of messages.getIterator
(Date startTime, Date endTime, IMessageBrowser.SortOrder order) int
boolean
indicates implementing object is under transaction control, using XA-transactionsMethods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
Methods inherited from interface org.frankframework.core.IMessageBrowser
getHideMethod, getHideRegex, setHideMethod, setHideRegex
-
Field Details
-
log
protected org.apache.logging.log4j.Logger log
-
-
Constructor Details
-
FileSystemMessageBrowser
-
-
Method Details
-
isTransacted
public boolean isTransacted()Description copied from interface:IXAEnabled
indicates implementing object is under transaction control, using XA-transactions- Specified by:
isTransacted
in interfaceIXAEnabled
-
getIterator
Description copied from interface:IMessageBrowser
Gets an enumeration of messages. This includes setting up connections, sessions etc.- Specified by:
getIterator
in interfaceIMessageBrowser<F>
- Throws:
ListenerException
-
getIterator
public IMessageBrowsingIterator getIterator(Date startTime, Date endTime, IMessageBrowser.SortOrder order) throws ListenerException - Specified by:
getIterator
in interfaceIMessageBrowser<F>
- Throws:
ListenerException
-
getContext
Description copied from interface:IMessageBrowser
Retrieves the message context as an iteratorItem. The result can be used in the methods above that use an iteratorItem. Use this method as try-with-resources to close the connections.- Specified by:
getContext
in interfaceIMessageBrowser<F>
- Throws:
ListenerException
-
contains
protected boolean contains(String value, ThrowingFunction<IMessageBrowsingIteratorItem, String, throws ListenerExceptionListenerException> field) - Throws:
ListenerException
-
containsMessageId
Description copied from interface:IMessageBrowser
Check if the storage contains message with the given original messageId (as passed to storeMessage).- Specified by:
containsMessageId
in interfaceIMessageBrowser<F>
- Throws:
ListenerException
-
containsCorrelationId
- Specified by:
containsCorrelationId
in interfaceIMessageBrowser<F>
- Throws:
ListenerException
-
browseMessage
Description copied from interface:IMessageBrowser
Retrieves the message, but does not delete.- Specified by:
browseMessage
in interfaceIMessageBrowser<F>
- Throws:
ListenerException
-
deleteMessage
Description copied from interface:IMessageBrowser
Deletes the message.- Specified by:
deleteMessage
in interfaceIMessageBrowser<F>
- Throws:
ListenerException
-
getMessageCount
- Specified by:
getMessageCount
in interfaceIMessageBrowser<F>
- Throws:
ListenerException
-