public class FileSystemMessageBrowser<F,FS extends IBasicFileSystem<F>> extends Object implements IMessageBrowser<F>
IMessageBrowser.HideMethod, IMessageBrowser.SortOrder, IMessageBrowser.StorageType
Modifier and Type | Field and Description |
---|---|
protected org.apache.logging.log4j.Logger |
log |
Constructor and Description |
---|
FileSystemMessageBrowser(FS fileSystem,
String folder,
String messageIdPropertyKey) |
Modifier and Type | Method and Description |
---|---|
RawMessageWrapper<F> |
browseMessage(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.
|
IMessageBrowsingIteratorItem |
getContext(String storageKey)
Retrieves the message context as an iteratorItem.
|
IMessageBrowsingIterator |
getIterator()
Gets an enumeration of messages.
|
IMessageBrowsingIterator |
getIterator(Date startTime,
Date endTime,
IMessageBrowser.SortOrder order) |
int |
getMessageCount() |
boolean |
isTransacted()
indicates implementing object is under transaction control, using XA-transactions
|
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
getHideMethod, getHideRegex, setHideMethod, setHideRegex
public boolean isTransacted()
IXAEnabled
isTransacted
in interface IXAEnabled
public IMessageBrowsingIterator getIterator() throws ListenerException
IMessageBrowser
getIterator
in interface IMessageBrowser<F>
ListenerException
public IMessageBrowsingIterator getIterator(Date startTime, Date endTime, IMessageBrowser.SortOrder order) throws ListenerException
getIterator
in interface IMessageBrowser<F>
ListenerException
public IMessageBrowsingIteratorItem getContext(String storageKey) throws ListenerException
IMessageBrowser
getContext
in interface IMessageBrowser<F>
ListenerException
protected boolean contains(String value, ThrowingFunction<IMessageBrowsingIteratorItem,String,ListenerException> field) throws ListenerException
ListenerException
public boolean containsMessageId(String originalMessageId) throws ListenerException
IMessageBrowser
containsMessageId
in interface IMessageBrowser<F>
ListenerException
public boolean containsCorrelationId(String correlationId) throws ListenerException
containsCorrelationId
in interface IMessageBrowser<F>
ListenerException
public RawMessageWrapper<F> browseMessage(String storageKey) throws ListenerException
IMessageBrowser
browseMessage
in interface IMessageBrowser<F>
ListenerException
public void deleteMessage(String storageKey) throws ListenerException
IMessageBrowser
deleteMessage
in interface IMessageBrowser<F>
ListenerException
public int getMessageCount() throws ListenerException
getMessageCount
in interface IMessageBrowser<F>
ListenerException
Copyright © 2023 Frank!Framework. All rights reserved.