nl.nn.adapterframework.jms

Class JmsTransactionalStorage<S extends Serializable>

java.lang.Object

nl.nn.adapterframework.jndi.JndiBase

nl.nn.adapterframework.jms.JMSFacade

nl.nn.adapterframework.jms.JmsMessageBrowser<S,javax.jms.ObjectMessage>

nl.nn.adapterframework.jms.JmsTransactionalStorage<S>

All Implemented Interfaces:

HasPhysicalDestination, IConfigurable, IConfigurationAware, IMessageBrowser<S>, INamedObject, IScopeProvider, ITransactionalStorage<S>, IXAEnabled, org.springframework.beans.factory.Aware, org.springframework.context.ApplicationContextAware

Direct Known Subclasses:

EsbJmsTransactionalStorage

public class JmsTransactionalStorage<S extends Serializable>
extends JmsMessageBrowser<S,javax.jms.ObjectMessage>
implements ITransactionalStorage<S>

JMS implementation of ITransactionalStorage.

Since:

4.1

Author:

Gerrit van Brakel

Nested Class Summary

Nested classes/interfaces inherited from class nl.nn.adapterframework.jms.JMSFacade

JMSFacade.AcknowledgeMode, JMSFacade.DeliveryMode, JMSFacade.DestinationType, JMSFacade.SubscriberType

Nested classes/interfaces inherited from interface nl.nn.adapterframework.core.IMessageBrowser

IMessageBrowser.HideMethod, IMessageBrowser.SortOrder, IMessageBrowser.StorageType

Field Summary

Fields

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

Fields inherited from class nl.nn.adapterframework.jms.JMSFacade

messagingSource

Fields inherited from class nl.nn.adapterframework.jndi.JndiBase

log

Fields inherited from interface nl.nn.adapterframework.core.ITransactionalStorage

MAXCOMMENTLEN

Constructor Summary

Constructors

Constructor and Description
JmsTransactionalStorage()

Method Summary

Modifier and Type	Method and Description
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).
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.

Methods inherited from class nl.nn.adapterframework.jms.JmsMessageBrowser

browseJmsMessage, containsCorrelationId, deleteMessage, doBrowse, doBrowse, getCombinedSelector, getCombinedSelector, getContext, getIterator, getIterator, getJmsMessage, getMessageCount, setTimeOut

Methods inherited from class nl.nn.adapterframework.jms.JMSFacade

checkTransactionManagerValidity, close, closeSession, createMessage, createSession, extractMessage, extractMessageBody, getAcknowledgeModeEnum, getConnectionFactoryInfo, getConnectionFactoryName, getContext, getDestination, getDestination, getJmsMessagingSource, getLogPrefix, getManagedConnectionFactory, getMessageConsumer, getMessageConsumer, getMessageConsumerForCorrelationId, getMessageProducer, getMessagingSource, getMessagingSourceFactory, getPhysicalDestinationName, getPhysicalDestinationShortName, getPhysicalDestinationShortName, isSessionsArePooled, 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

Methods inherited from class nl.nn.adapterframework.jndi.JndiBase

configure, getContext, getJndiEnv, setAuthentication, setCredentials, setInitialContextFactoryName, setJmsRealm, setJndiAuthAlias, setJndiContextPrefix, setJndiProperties, setName, setPrincipal, setProviderURL, setSecurityProtocol, setUrlPkgPrefixes

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait

Methods inherited from interface nl.nn.adapterframework.core.ITransactionalStorage

close, configure, open

Methods inherited from interface nl.nn.adapterframework.core.IMessageBrowser

containsCorrelationId, deleteMessage, getContext, getHideMethod, getHideRegex, getIterator, getIterator, getMessageCount, setHideMethod, setHideRegex

Methods inherited from interface nl.nn.adapterframework.core.IXAEnabled

isTransacted

Methods inherited from interface nl.nn.adapterframework.core.INamedObject

getName, setName

Methods inherited from interface nl.nn.adapterframework.core.HasPhysicalDestination

getDomain

Methods inherited from interface nl.nn.adapterframework.core.IConfigurationAware

getApplicationContext, getName

Methods inherited from interface nl.nn.adapterframework.core.IScopeProvider

getConfigurationClassLoader

Methods inherited from interface org.springframework.context.ApplicationContextAware

setApplicationContext

Field Detail

FIELD_TYPE

public static final String FIELD_TYPE

See Also:

Constant Field Values

FIELD_ORIGINAL_ID

public static final String FIELD_ORIGINAL_ID

See Also:

Constant Field Values

FIELD_RECEIVED_DATE

public static final String FIELD_RECEIVED_DATE

See Also:

Constant Field Values

FIELD_COMMENTS

public static final String FIELD_COMMENTS

See Also:

Constant Field Values

FIELD_SLOTID

public static final String FIELD_SLOTID

See Also:

Constant Field Values

FIELD_HOST

public static final String FIELD_HOST

See Also:

Constant Field Values

FIELD_LABEL

public static final String FIELD_LABEL

See Also:

Constant Field Values

Constructor Detail

JmsTransactionalStorage

public JmsTransactionalStorage()

Method Detail

storeMessage

public String storeMessage(String messageId,
                           String correlationId,
                           Date receivedDate,
                           String comments,
                           String label,
                           S message)
                    throws SenderException

Description copied from interface: ITransactionalStorage

Store the message, returns storageKey. The messageId should be unique.

Specified by:

storeMessage in interface ITransactionalStorage<S extends Serializable>

Throws:

SenderException

containsMessageId

public boolean containsMessageId(String originalMessageId)
                          throws ListenerException

Description copied from interface: IMessageBrowser

Check if the storage contains message with the given original messageId (as passed to storeMessage).

Specified by:

containsMessageId in interface IMessageBrowser<S extends Serializable>

Overrides:

containsMessageId in class JmsMessageBrowser<S extends Serializable,javax.jms.ObjectMessage>

Throws:

ListenerException

browseMessage

public S browseMessage(String storageKey)
                throws ListenerException

Description copied from interface: IMessageBrowser

Retrieves the message, but does not delete.

Specified by:

browseMessage in interface IMessageBrowser<S extends Serializable>

Throws:

ListenerException

getMessage

public S getMessage(String storageKey)
             throws ListenerException

Description copied from interface: ITransactionalStorage

Retrieves and deletes the message.

Specified by:

getMessage in interface ITransactionalStorage<S extends Serializable>

Throws:

ListenerException

getSelector

public String getSelector()

setSlotId

public void setSlotId(String string)

Description copied from interface: ITransactionalStorage

Optional identifier for this storage, to be able to share the physical storage between a number of receivers and pipes.

Specified by:

setSlotId in interface ITransactionalStorage<S extends Serializable>

getSlotId

public String getSlotId()

Specified by:

getSlotId in interface ITransactionalStorage<S extends Serializable>

setType

public void setType(String string)

Description copied from interface: ITransactionalStorage

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. SenderPipe will set type to L for messageLog (when type isn't specified).
See MessageStoreSender for type M.

Specified by:

setType in interface ITransactionalStorage<S extends Serializable>

getType

public String getType()

Specified by:

getType in interface ITransactionalStorage<S extends Serializable>