nl.nn.adapterframework.jms

Class JmsSender

java.lang.Object

nl.nn.adapterframework.jndi.JndiBase

nl.nn.adapterframework.jms.JMSFacade

nl.nn.adapterframework.jms.JmsSender

All Implemented Interfaces:

HasPhysicalDestination, IConfigurable, IConfigurationAware, INamedObject, IScopeProvider, ISender, ISenderWithParameters, IWithParameters, IXAEnabled, org.springframework.beans.factory.Aware, org.springframework.context.ApplicationContextAware

Direct Known Subclasses:

BisJmsSender, EsbJmsSender, IfsaSimulatorJmsSender, MQSender, TibcoSender

public class JmsSender
extends JMSFacade
implements ISenderWithParameters

This class sends messages with JMS.

Author:

Gerrit van Brakel

Parameters

All parameters present are set as message-properties.

Specific parameters

SoapAction Automatically filled from attribute soapAction

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	JmsSender.LinkMethod

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

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

Field Summary

Fields

Modifier and Type	Field and Description
protected ParameterList	paramList

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

messagingSource

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

log

Constructor Summary

Constructors

Constructor and Description
JmsSender()

Method Summary

Modifier and Type	Method and Description
void	addParameter(Parameter p)
void	configure() Configures the sender
javax.jms.Destination	getDestination(PipeLineSession session, ParameterValueList pvl)
ParameterList	getParameterList()
void	open() Starts the sender
SenderResult	sendMessage(Message message, PipeLineSession session) Send a message to some destination (as configured in the Sender object).
Message	sendMessage(Message message, PipeLineSession session, String soapHeader)
void	setDeliveryMode(JMSFacade.DeliveryMode deliveryMode) Controls mode that messages are sent with
void	setDestinationParam(String string) Parameter that is used, if specified and not empty, to determine the destination.
void	setEncodingStyleURI(String string) SOAP encoding style URI
void	setLinkMethod(JmsSender.LinkMethod method) (Only used when synchronous=true and replyToName is set).
void	setMessageType(String string) Value of the JMSType field
void	setPriority(int i) Sets the priority that is used to deliver the message.
void	setReplySoapHeaderSessionKey(String string) session key to store SOAP header of reply
void	setReplyTimeout(int i) (Only for synchronous=true).
void	setReplyToName(String replyTo) Name of the queue the reply is expected on.
void	setResponseHeadersToSessionKeys(String responseHeaders) A list of JMS headers of the response to add to the PipeLineSession
void	setServiceNamespaceURI(String string) SOAP service namespace URI
void	setSoap(boolean b) If true, messages sent are put in a SOAP envelope
void	setSoapAction(String string) SOAPAction string sent as message property
void	setSoapHeaderParam(String string) Name of parameter containing SOAP header
void	setSynchronous(boolean synchronous) If true, the sender operates in RR mode: A reply is expected, either on the queue specified in replyToName, or on a dynamically generated temporary queue
String	toString()

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, 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, 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.ISenderWithParameters

consumesSessionVariable

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

close, isSynchronous, sendMessageOrThrow

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

getName, setName

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

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

getDomain

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

isTransacted

Field Detail

paramList

protected ParameterList paramList

Constructor Detail

JmsSender

public JmsSender()

Method Detail

configure

public void configure()
               throws ConfigurationException

Configures the sender

Specified by:

configure in interface IConfigurable

Specified by:

configure in interface ISender

Overrides:

configure in class JndiBase

Throws:

ConfigurationException

open

public void open()
          throws SenderException

Starts the sender

Specified by:

open in interface ISender

Overrides:

open in class JMSFacade

Throws:

SenderException

addParameter

public void addParameter(Parameter p)

Specified by:

addParameter in interface IWithParameters

getParameterList

public ParameterList getParameterList()

Specified by:

getParameterList in interface IWithParameters

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 the configure() method is called.

The following table shows the difference between synchronous and a-synchronous senders:

	synchronous	a-synchronous
ISender.isSynchronous() returns	true	false
return value of sendMessage() is	the 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.

Specified by:

sendMessage in interface ISender

Throws:

SenderException

TimeoutException

sendMessage

public Message sendMessage(Message message,
                           PipeLineSession session,
                           String soapHeader)
                    throws SenderException,
                           TimeoutException

Throws:

SenderException

TimeoutException

getDestination

public javax.jms.Destination getDestination(PipeLineSession session,
                                            ParameterValueList pvl)
                                     throws JmsException,
                                            NamingException,
                                            javax.jms.JMSException

Throws:

JmsException

NamingException

javax.jms.JMSException

toString

public String toString()

Overrides:

toString in class JMSFacade

setDestinationParam

public void setDestinationParam(String string)

Parameter that is used, if specified and not empty, to determine the destination. Overrides the destination attribute

setSynchronous

public void setSynchronous(boolean synchronous)

If true, the sender operates in RR mode: A reply is expected, either on the queue specified in replyToName, or on a dynamically generated temporary queue

Default value

false

setReplyToName

public void setReplyToName(String replyTo)

Name of the queue the reply is expected on. This value is sent in the JMSReplyTo-header with the message.

Default value

a dynamically generated temporary destination

setLinkMethod

public void setLinkMethod(JmsSender.LinkMethod method)

(Only used when synchronous=true and replyToName is set). Indicates whether the server uses the correlationId from the pipeline, the correlationId from the message or the messageId in the correlationId field of the reply. This requires the sender to have set the correlationId at the time of sending.

Default value

MESSAGEID

setReplyTimeout

public void setReplyTimeout(int i)

(Only for synchronous=true). Maximum time in ms to wait for a reply. 0 means no timeout.

Default value

5000

setMessageType

public void setMessageType(String string)

Value of the JMSType field

Default value

not set by application

setDeliveryMode

public void setDeliveryMode(JMSFacade.DeliveryMode deliveryMode)

Controls mode that messages are sent with

Default value

not set by application

setPriority

public void setPriority(int i)

Sets the priority that is used to deliver the message. Ranges from 0 to 9. Defaults to -1, meaning not set. Effectively the default priority is set by JMS to 4

Default value

-1

setSoap

public void setSoap(boolean b)

If true, messages sent are put in a SOAP envelope

Default value

false

setEncodingStyleURI

public void setEncodingStyleURI(String string)

SOAP encoding style URI

setServiceNamespaceURI

public void setServiceNamespaceURI(String string)

SOAP service namespace URI

setSoapAction

public void setSoapAction(String string)

SOAPAction string sent as message property

setSoapHeaderParam

public void setSoapHeaderParam(String string)

Name of parameter containing SOAP header

Default value

soapHeader

setReplySoapHeaderSessionKey

public void setReplySoapHeaderSessionKey(String string)

session key to store SOAP header of reply

Default value

replySoapHeader

setResponseHeadersToSessionKeys

public void setResponseHeadersToSessionKeys(String responseHeaders)

A list of JMS headers of the response to add to the PipeLineSession