M
- the payload message type as used by IMessageBrowser.J
- the physical JMS message to carry the payload.public abstract class JmsMessageBrowser<M,J extends javax.jms.Message> extends JMSFacade implements IMessageBrowser<M>
JMSFacade.AcknowledgeMode, JMSFacade.DeliveryMode, JMSFacade.DestinationType, JMSFacade.SubscriberType
IMessageBrowser.HideMethod, IMessageBrowser.SortOrder, IMessageBrowser.StorageType
messagingSource
Constructor and Description |
---|
JmsMessageBrowser() |
JmsMessageBrowser(String selector) |
Modifier and Type | Method and Description |
---|---|
J |
browseJmsMessage(String messageId) |
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 messageId)
Deletes the message.
|
protected javax.jms.Message |
doBrowse(Map<String,String> selectors) |
protected javax.jms.Message |
doBrowse(String selectorKey,
String selectorValue) |
protected String |
getCombinedSelector(Map<String,String> selectors) |
protected String |
getCombinedSelector(String messageId) |
IMessageBrowsingIteratorItem |
getContext(String messageId)
Retrieves the message context as an iteratorItem.
|
IMessageBrowsingIterator |
getIterator()
Gets an enumeration of messages.
|
IMessageBrowsingIterator |
getIterator(Date startTime,
Date endTime,
IMessageBrowser.SortOrder order) |
J |
getJmsMessage(String messageId) |
int |
getMessageCount() |
void |
setTimeOut(long newTimeOut)
Timeout in milliseconds for receiving a message from the queue
|
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
browseMessage, getHideMethod, getHideRegex, setHideMethod, setHideRegex
isTransacted
getDomain
getName
getApplicationContext, getName
getConfigurationClassLoader
public JmsMessageBrowser()
public JmsMessageBrowser(String selector)
public IMessageBrowsingIterator getIterator() throws ListenerException
IMessageBrowser
getIterator
in interface IMessageBrowser<M>
ListenerException
public IMessageBrowsingIterator getIterator(Date startTime, Date endTime, IMessageBrowser.SortOrder order) throws ListenerException
getIterator
in interface IMessageBrowser<M>
ListenerException
public boolean containsMessageId(String originalMessageId) throws ListenerException
IMessageBrowser
containsMessageId
in interface IMessageBrowser<M>
ListenerException
public boolean containsCorrelationId(String correlationId) throws ListenerException
containsCorrelationId
in interface IMessageBrowser<M>
ListenerException
public int getMessageCount() throws ListenerException
getMessageCount
in interface IMessageBrowser<M>
ListenerException
public J getJmsMessage(String messageId) throws ListenerException
ListenerException
public IMessageBrowsingIteratorItem getContext(String messageId) throws ListenerException
IMessageBrowser
getContext
in interface IMessageBrowser<M>
ListenerException
public J browseJmsMessage(String messageId) throws ListenerException
ListenerException
protected javax.jms.Message doBrowse(Map<String,String> selectors) throws ListenerException
ListenerException
protected javax.jms.Message doBrowse(String selectorKey, String selectorValue) throws ListenerException
ListenerException
public void deleteMessage(String messageId) throws ListenerException
IMessageBrowser
deleteMessage
in interface IMessageBrowser<M>
ListenerException
public void setTimeOut(long newTimeOut)
Copyright © 2023 Frank!Framework. All rights reserved.