public class JmsTransactionalStorage<S extends Serializable> extends JmsMessageBrowser<S,javax.jms.ObjectMessage> implements ITransactionalStorage<S>
JmsMessageLog
) or error store (JmsErrorStorage
) that uses JMS technology.
JMSFacade.AcknowledgeMode, JMSFacade.DeliveryMode, JMSFacade.DestinationType, JMSFacade.SubscriberType
IMessageBrowser.HideMethod, IMessageBrowser.SortOrder, IMessageBrowser.StorageType
Modifier and Type | Field and Description |
---|---|
static String |
FIELD_COMMENTS |
static String |
FIELD_HOST |
static String |
FIELD_LABEL |
static String |
FIELD_ORIGINAL_ID |
static String |
FIELD_RECEIVED_DATE |
static String |
FIELD_SLOTID |
static String |
FIELD_TYPE |
messagingSource
MAXCOMMENTLEN
Constructor and Description |
---|
JmsTransactionalStorage() |
Modifier and Type | Method and Description |
---|---|
RawMessageWrapper<S> |
browseMessage(String storageKey)
Retrieves the message, but does not delete.
|
boolean |
containsMessageId(String originalMessageId)
Check if the storage contains message with the given original messageId
(as passed to storeMessage).
|
RawMessageWrapper<S> |
getMessage(String storageKey)
Retrieves and deletes the message.
|
String |
getSelector() |
String |
getSlotId() |
String |
getType() |
void |
setSlotId(String string)
Optional identifier for this storage, to be able to share the physical storage between a number of receivers and pipes.
|
void |
setType(String string)
Possible values are
E (error store), M (message store), L (message log for Pipe) or A (message log for Receiver).Receiver will always set type to E for errorStorage and always set type to A for messageLog. |
String |
storeMessage(String messageId,
String correlationId,
Date receivedDate,
String comments,
String label,
S message)
Store the message, returns storageKey.
|
browseJmsMessage, containsCorrelationId, deleteMessage, doBrowse, doBrowse, getCombinedSelector, getCombinedSelector, getContext, getIterator, getIterator, getJmsMessage, getMessageCount, setTimeOut
checkTransactionManagerValidity, close, closeSession, configure, createMessage, createSession, extractMessage, extractMessageBody, getAcknowledgeModeEnum, getConnectionFactoryInfo, getConnectionFactoryName, getContext, getDestination, getDestination, getJmsMessagingSource, getLogPrefix, getManagedConnectionFactory, getMessageConsumer, getMessageConsumer, getMessageConsumerForCorrelationId, getMessageProducer, getMessagingSource, getMessagingSourceFactory, getPhysicalDestinationName, getPhysicalDestinationShortName, getPhysicalDestinationShortName, isSessionsArePooled, logMessageDetails, open, send, send, send, send, send, send, send, sendByQueue, sendByTopic, setAckMode, setAcknowledgeMode, setAuthAlias, setCorrelationIdMaxLength, setCorrelationIdToHex, setCorrelationIdToHexPrefix, setDestinationName, setDestinationType, setJmsTransacted, setLookupDestination, setMessageCorrelationID, setMessageSelector, setMessageTimeToLive, setPersistent, setQueueConnectionFactoryName, setSubscriberType, setTopicConnectionFactoryName, setTransacted, toString, useJms102
getContext, getJndiEnv, setAuthentication, setCredentials, setInitialContextFactoryName, setJmsRealm, setJndiAuthAlias, setJndiContextPrefix, setJndiProperties, setName, setPrincipal, setProviderURL, setSecurityProtocol, setUrlPkgPrefixes
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait
close, configure, open
containsCorrelationId, deleteMessage, getContext, getHideMethod, getHideRegex, getIterator, getIterator, getMessageCount, setHideMethod, setHideRegex
isTransacted
getName, setName
getDomain
getApplicationContext, getName
getConfigurationClassLoader
public static final String FIELD_TYPE
public static final String FIELD_ORIGINAL_ID
public static final String FIELD_RECEIVED_DATE
public static final String FIELD_COMMENTS
public static final String FIELD_SLOTID
public static final String FIELD_HOST
public static final String FIELD_LABEL
public String storeMessage(String messageId, String correlationId, Date receivedDate, String comments, String label, S message) throws SenderException
ITransactionalStorage
storeMessage
in interface ITransactionalStorage<S extends Serializable>
SenderException
public boolean containsMessageId(String originalMessageId) throws ListenerException
IMessageBrowser
containsMessageId
in interface IMessageBrowser<S extends Serializable>
containsMessageId
in class JmsMessageBrowser<S extends Serializable,javax.jms.ObjectMessage>
ListenerException
public RawMessageWrapper<S> browseMessage(String storageKey) throws ListenerException
IMessageBrowser
browseMessage
in interface IMessageBrowser<S extends Serializable>
ListenerException
public RawMessageWrapper<S> getMessage(String storageKey) throws ListenerException
ITransactionalStorage
getMessage
in interface ITransactionalStorage<S extends Serializable>
ListenerException
public String getSelector()
@ReferTo(value=ITransactionalStorage.class) public void setSlotId(String string)
ITransactionalStorage
setSlotId
in interface ITransactionalStorage<S extends Serializable>
public String getSlotId()
getSlotId
in interface ITransactionalStorage<S extends Serializable>
@ReferTo(value=ITransactionalStorage.class) public void setType(String string)
ITransactionalStorage
E
(error store), M
(message store), L
(message log for Pipe) or A
(message log for Receiver).E
for errorStorage and always set type to A
for messageLog. SenderPipe will set type to L
for messageLog (when type isn't specified).MessageStoreSender
for type M
.setType
in interface ITransactionalStorage<S extends Serializable>
public String getType()
getType
in interface ITransactionalStorage<S extends Serializable>
Copyright © 2023 Frank!Framework. All rights reserved.