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.ActionmessageLog
: 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 interface org.frankframework.core.ITransactionalStorage
MAXCOMMENTLEN
-
Constructor Summary
Constructors -
Method Summary
Modifier and TypeMethodDescriptionvoid
Configure this component.int
void
start()
Obtains a connection and a serviceQueue.void
stop()
Releases references to serviceQueue and connection.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, 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, getMessagingSourceFactory, 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.HasPhysicalDestination
getDomain
Methods inherited from interface org.frankframework.core.IMessageBrowser
containsCorrelationId, deleteMessage, getContext, getHideMethod, getHideRegex, getIterator, getIterator, setHideMethod, setHideRegex
Methods inherited from interface org.frankframework.core.IXAEnabled
isTransacted
-
Constructor Details
-
EsbJmsTransactionalStorage
public EsbJmsTransactionalStorage()
-
-
Method Details
-
configure
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 thisIConfigurable
. 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 theconfigure()
, to improve performance.In the case of a container, this will propagate the configure signal to all components that apply.
- Specified by:
configure
in interfaceIConfigurable
- Specified by:
configure
in interfaceITransactionalStorage<S extends Serializable>
- Overrides:
configure
in classJMSFacade
- 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 interfaceITransactionalStorage<S extends Serializable>
- Specified by:
start
in interfaceorg.springframework.context.Lifecycle
- Overrides:
start
in classJMSFacade
-
stop
public void stop()Description copied from class:JMSFacade
Releases references to serviceQueue and connection.- Specified by:
stop
in interfaceITransactionalStorage<S extends Serializable>
- Specified by:
stop
in interfaceorg.springframework.context.Lifecycle
- Overrides:
stop
in classJMSFacade
-
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 interfaceITransactionalStorage<S extends Serializable>
- Overrides:
storeMessage
in classJmsTransactionalStorage<S extends Serializable>
- Throws:
SenderException
-
getMessageCount
public int getMessageCount()- Specified by:
getMessageCount
in interfaceIMessageBrowser<S extends Serializable>
- Overrides:
getMessageCount
in classAbstractJmsMessageBrowser<S extends Serializable,
jakarta.jms.ObjectMessage>
-