Package org.frankframework.core
Interface ITransactionalStorage<S extends Serializable>
- All Superinterfaces:
HasName,IMessageBrowser<S>,IXAEnabled,NameAware
- All Known Implementing Classes:
DummyTransactionalStorage,EsbJmsTransactionalStorage,JdbcTransactionalStorage,JmsTransactionalStorage,MessageStoreSender
@FrankDocGroup(TRANSACTIONAL_STORAGE)
public interface ITransactionalStorage<S extends Serializable>
extends IMessageBrowser<S>, NameAware, HasName
Marks an implementation as responsible for storing and retrieving-back messages under transaction control.
- Since:
- 4.1
- Author:
- Gerrit van Brakel
- See Also:
-
Nested Class Summary
Nested classes/interfaces inherited from interface org.frankframework.core.IMessageBrowser
IMessageBrowser.HideMethod, IMessageBrowser.SortOrder, IMessageBrowser.StorageType -
Field Summary
Fields -
Method Summary
Modifier and TypeMethodDescriptionvoidconsumeMessage(String storageKey) Retrieves and deletes the message.getType()voidOptional identifier for this storage, to be able to share the physical storage between a number of receivers and pipes.voidPossible values areE(error store),M(message store),L(message log for Pipe) orA(message log for Receiver).
Receiver will always set type toEfor errorStorage and always set type toAfor messageLog.voidstart()Prepares the object for operation.voidstop()storeMessage(String messageId, String correlationId, Date receivedDate, String comments, String label, S message) Store the message, returns storageKey.Methods inherited from interface org.frankframework.core.IMessageBrowser
browseMessage, containsCorrelationId, containsMessageId, deleteMessage, getContext, getHideMethod, getHideRegex, getIterator, getIterator, getMessageCount, getStorageFields, setHideMethod, setHideRegexMethods inherited from interface org.frankframework.core.IXAEnabled
isTransacted
-
Field Details
-
MAXCOMMENTLEN
static final int MAXCOMMENTLEN- See Also:
-
-
Method Details
-
start
void start()Prepares the object for operation. After this method is called the storeMessage() and retrieveMessage() methods may be called -
stop
void stop() -
configure
- Throws:
ConfigurationException
-
storeMessage
String storeMessage(String messageId, String correlationId, Date receivedDate, String comments, String label, S message) throws SenderException Store the message, returns storageKey. The messageId should be unique.- Throws:
SenderException
-
consumeMessage
Retrieves and deletes the message.- Throws:
ListenerException
-
setSlotId
Optional identifier for this storage, to be able to share the physical storage between a number of receivers and pipes. -
getSlotId
String getSlotId() -
setType
Possible values areE(error store),M(message store),L(message log for Pipe) orA(message log for Receiver).
Receiver will always set type toEfor errorStorage and always set type toAfor messageLog. SenderPipe will set type toLfor messageLog (when type isn't specified).
SeeMessageStoreSenderfor typeM.- Default value
Efor errorStorage on ReceiverAfor messageLog on ReceiverLfor messageLog on Pipe
-
getType
String getType()
-