Package org.frankframework.extensions.esb

Class EsbJmsTransactionalStorage<S extends Serializable>

java.lang.Object

org.frankframework.jndi.JndiBase

org.frankframework.jms.JMSFacade

org.frankframework.jms.AbstractJmsMessageBrowser<S,jakarta.jms.ObjectMessage>

org.frankframework.jms.JmsTransactionalStorage<S>

org.frankframework.extensions.esb.EsbJmsTransactionalStorage<S>

All Implemented Interfaces:

HasApplicationContext, HasName, HasPhysicalDestination, IConfigurable, IMessageBrowser<S>, IScopeProvider, ITransactionalStorage<S>, IXAEnabled, NameAware, org.springframework.context.Lifecycle

@Category(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

Author:

Peter Leeuwenburgh

Nested Class Summary

Nested classes/interfaces inherited from class org.frankframework.jms.JMSFacade

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

Nested classes/interfaces inherited from interface org.frankframework.core.IMessageBrowser

IMessageBrowser.HideMethod, IMessageBrowser.SortOrder, IMessageBrowser.StorageType

Field Summary

Fields inherited from class org.frankframework.jms.JmsTransactionalStorage

FIELD_COMMENTS, FIELD_HOST, FIELD_LABEL, FIELD_ORIGINAL_ID, FIELD_RECEIVED_DATE, FIELD_SLOTID, FIELD_TYPE

Fields inherited from class org.frankframework.jms.JMSFacade

JMS_MESSAGECLASS_KEY, messagingSource

Fields inherited from class org.frankframework.jndi.JndiBase

log

Fields inherited from interface org.frankframework.core.ITransactionalStorage

MAXCOMMENTLEN

Constructor Summary

Constructors

Constructor	Description
EsbJmsTransactionalStorage()

Method Summary

Modifier and Type	Method	Description
void	configure()	Configure this component.
int	getMessageCount()
void	start()	Obtains a connection and a serviceQueue.
void	stop()	Releases references to serviceQueue and connection.
String	storeMessage(String messageId, String correlationId, Date receivedDate, String comments, String label, S message)	Store the message, returns storageKey.

Methods inherited from class org.frankframework.jms.JmsTransactionalStorage

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

Methods inherited from class org.frankframework.jms.AbstractJmsMessageBrowser

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

Methods inherited from class org.frankframework.jms.JMSFacade

checkTransactionManagerValidity, closeSession, createBytesMessage, createMessage, createMessage, createSession, createTextMessage, extractMessage, extractMessageBody, getConnectionFactoryName, getContext, getDestination, getDestination, getJmsMessagingSource, getLogPrefix, getMessageConsumer, getMessageConsumer, getMessageConsumerForCorrelationId, getMessageProducer, getMessagingSource, getPhysicalDestinationName, getPhysicalDestinationShortName, getPhysicalDestinationShortName, isRunning, isSessionsArePooled, logMessageDetails, send, send, send, send, send, send, send, sendByQueue, sendByTopic, setAcknowledgeMode, setAuthAlias, setCorrelationIdMaxLength, setCorrelationIdToHex, setCorrelationIdToHexPrefix, setDestinationName, setDestinationType, setLookupDestination, setMessageClass, setMessageCorrelationID, setMessageSelector, setMessageTimeToLive, setPersistent, setQueueConnectionFactoryName, setSubscriberType, setTopicConnectionFactoryName, setTransacted, toString

Methods inherited from class org.frankframework.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 org.frankframework.core.HasApplicationContext

getApplicationContext, getConfigurationClassLoader

Methods inherited from interface org.frankframework.core.HasName

getName

Methods inherited from interface org.frankframework.core.HasPhysicalDestination

getDomain

Methods inherited from interface org.frankframework.core.IMessageBrowser

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

Methods inherited from interface org.frankframework.core.IXAEnabled

isTransacted

Methods inherited from interface org.frankframework.core.NameAware

setName

Constructor Details

EsbJmsTransactionalStorage

public EsbJmsTransactionalStorage()

Method Details

configure

public void configure()
               throws ConfigurationException

Description copied from interface: IConfigurable

Configure this component.

configure() is called once at startup of the framework in the configure method of the owner of this IConfigurable. Purpose of this method is to check whether the static configuration of the object is correct. As much as possible class-instantiating should take place in the configure(), to improve performance.

In the case of a container, this will propagate the configure signal to all components that apply.

Specified by:

configure in interface IConfigurable

Specified by:

configure in interface ITransactionalStorage<S extends Serializable>

Overrides:

configure in class JMSFacade

Throws:

ConfigurationException - in case it was not able to configure the component.

start

public void start()

Description copied from class: JMSFacade

Obtains a connection and a serviceQueue.

Specified by:

start in interface ITransactionalStorage<S extends Serializable>

Specified by:

start in interface org.springframework.context.Lifecycle

Overrides:

start in class JMSFacade

stop

public void stop()

Description copied from class: JMSFacade

Releases references to serviceQueue and connection.

Specified by:

stop in interface ITransactionalStorage<S extends Serializable>

Specified by:

stop in interface org.springframework.context.Lifecycle

Overrides:

stop 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()

Specified by:

getMessageCount in interface IMessageBrowser<S extends Serializable>

Overrides:

getMessageCount in class AbstractJmsMessageBrowser<S extends Serializable,jakarta.jms.ObjectMessage>