Class XmlJmsBrowserSender
- java.lang.Object
-
- nl.nn.adapterframework.senders.SenderBase
-
- nl.nn.adapterframework.senders.SenderWithParametersBase
-
- nl.nn.adapterframework.jms.XmlJmsBrowserSender
-
- All Implemented Interfaces:
IConfigurable
,IConfigurationAware
,INamedObject
,IScopeProvider
,ISender
,ISenderWithParameters
,IWithParameters
,org.springframework.beans.factory.Aware
,org.springframework.context.ApplicationContextAware
public class XmlJmsBrowserSender extends SenderWithParametersBase
Sender for browsing and removing queue messages (with input and output in a XML message).When input root element is
browse
all queue messages are returned.When input root element is
remove
all queue messages are removed.example (input):
<browse> <jmsRealm>qcf</jmsRealm> <destinationName>jms/GetPolicyDetailsRequest</destinationName> <destinationType>QUEUE</destinationType> </browse>
example (browse output):
<result> <items count="2"> <item> <timestamp>Thu Nov 20 13:36:31 CET 2014</timestamp> <messageId>ID:LPAB00000003980-61959-1416486781822-3:5:33:1:1</messageId> <correlationId>...</correlationId> <message><![CDATA[...]]></message> </item> <item> <timestamp>Thu Dec 12 11:59:22 CET 2014</timestamp> <messageId>ID:LPAB00000003980-58359-1721486799722-3:4:19:1:1</messageId> <correlationId>...</correlationId> <message><![CDATA[...]]></message> </item> </items> </result>
example (remove output):
<result> <itemsRemoved>2</itemsRemoved> </result>
- Author:
- Peter Leeuwenburgh
-
-
Field Summary
-
Fields inherited from class nl.nn.adapterframework.senders.SenderWithParametersBase
parameterNamesMustBeUnique, paramList
-
Fields inherited from class nl.nn.adapterframework.senders.SenderBase
log
-
-
Constructor Summary
Constructors Constructor Description XmlJmsBrowserSender()
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description JmsBrowser<javax.jms.Message>
createJmsBrowser()
SenderResult
sendMessage(Message message, PipeLineSession session)
Send a message to some destination (as configured in the Sender object).-
Methods inherited from class nl.nn.adapterframework.senders.SenderWithParametersBase
addParameter, checkStringAttributeOrParameter, configure, consumesSessionVariable, getParameterList, getParameterOverriddenAttributeValue, getParameterOverriddenAttributeValue, getParameterValueList
-
Methods inherited from class nl.nn.adapterframework.senders.SenderBase
close, createBean, getApplicationContext, getConfigurationClassLoader, getLogPrefix, getName, open, setApplicationContext, setName
-
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
-
Methods inherited from interface org.springframework.context.ApplicationContextAware
setApplicationContext
-
Methods inherited from interface nl.nn.adapterframework.core.IConfigurationAware
getApplicationContext, getName
-
Methods inherited from interface nl.nn.adapterframework.core.INamedObject
getName, setName
-
Methods inherited from interface nl.nn.adapterframework.core.IScopeProvider
getConfigurationClassLoader
-
Methods inherited from interface nl.nn.adapterframework.core.ISender
close, isSynchronous, open, sendMessageOrThrow
-
-
-
-
Method Detail
-
createJmsBrowser
public JmsBrowser<javax.jms.Message> createJmsBrowser()
-
sendMessage
public SenderResult sendMessage(Message message, PipeLineSession session) throws SenderException, TimeoutException
Description copied from interface:ISender
Send a message to some destination (as configured in the Sender object). This method may only be called after theconfigure()
method is called.The following table shows the difference between synchronous and a-synchronous senders:
synchronous a-synchronous ISender.isSynchronous()
returnstrue
false
return value of sendMessage()
isthe reply-message the messageId of the message sent the correlationID specified with sendMessage()
may be ignored is sent with the message a {link TimeOutException} may be thrown if a timeout occurs waiting for a reply should not be expected Multiple objects may try to call this method at the same time, from different threads. Implementations of this method should therefore be thread-safe, or
synchronized
.- Throws:
SenderException
TimeoutException
-
-