nl.nn.adapterframework.extensions.esb

Class EsbJmsTransactionalStorage<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>

nl.nn.adapterframework.extensions.esb.EsbJmsTransactionalStorage<S>

All Implemented Interfaces:

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

@Category(value="NN-Special")
public class EsbJmsTransactionalStorage<S extends Serializable>
extends JmsTransactionalStorage<S>

ESB (Enterprise Service Bus) extension of JmsTransactionalStorage.

Depending on the type of the TransactionalStorage one of the following messages is sent:

• errorStore: ESB.Infrastructure.US.Log.BusinessLog.2.ExceptionLog.1.Action
• messageLog: ESB.Infrastructure.US.Log.BusinessLog.2.AuditLog.1.Action

Configuration (where deviating from JmsTransactionalStorage):

attributes	description	default

Author:

Peter Leeuwenburgh

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 inherited from class nl.nn.adapterframework.jms.JmsTransactionalStorage

FIELD_COMMENTS, FIELD_HOST, FIELD_LABEL, FIELD_ORIGINAL_ID, FIELD_RECEIVED_DATE, FIELD_SLOTID, 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
EsbJmsTransactionalStorage()

Method Summary

Modifier and Type	Method and Description
void	close() Releases references to serviceQueue and connection.
void	configure()
int	getMessageCount()
void	open() Obtains a connection and a serviceQueue.
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.JmsTransactionalStorage

browseMessage, containsMessageId, getMessage, getSelector, getSlotId, getType, setSlotId, setType

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

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

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

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

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.IMessageBrowser

containsCorrelationId, deleteMessage, getContext, getHideMethod, getHideRegex, getIterator, getIterator, 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

Constructor Detail

EsbJmsTransactionalStorage

public EsbJmsTransactionalStorage()

Method Detail

configure

public void configure()
               throws ConfigurationException

Specified by:

configure in interface IConfigurable

Specified by:

configure in interface ITransactionalStorage<S extends Serializable>

Overrides:

configure in class JndiBase

Throws:

ConfigurationException

open

public void open()
          throws ListenerException

Description copied from class: JMSFacade

Obtains a connection and a serviceQueue.

Specified by:

open in interface ITransactionalStorage<S extends Serializable>

Overrides:

open in class JMSFacade

Throws:

ListenerException

close

public void close()

Description copied from class: JMSFacade

Releases references to serviceQueue and connection.

Specified by:

close in interface ITransactionalStorage<S extends Serializable>

Overrides:

close in class JMSFacade

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>

Overrides:

storeMessage in class JmsTransactionalStorage<S extends Serializable>

Throws:

SenderException

getMessageCount

public int getMessageCount()
                    throws ListenerException

Specified by:

getMessageCount in interface IMessageBrowser<S extends Serializable>

Overrides:

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

Throws:

ListenerException