nl.nn.adapterframework.extensions.ibm

Class MQSender

java.lang.Object

nl.nn.adapterframework.jndi.JndiBase

nl.nn.adapterframework.jms.JMSFacade

nl.nn.adapterframework.jms.JmsSender

nl.nn.adapterframework.extensions.ibm.MQSender

All Implemented Interfaces:

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

Direct Known Subclasses:

IMSSender

public class MQSender
extends JmsSender

JMS sender which will call IBM WebSphere MQ specific setTargetClient(JMSC.MQJMS_CLIENT_NONJMS_MQ) on the destination prior to sending a message. This is needed when the MQ destination is not a JMS receiver otherwise format errors occur (e.g. dots are added after every character in the message).

See JmsSender for configuration

Author:

Jaco de Groot

Nested Class Summary

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

JmsSender.LinkMethod

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

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

Field Summary

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

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

Method Summary

Modifier and Type	Method and Description
javax.jms.MessageProducer	getMessageProducer(javax.jms.Session session, javax.jms.Destination destination)
String	send(javax.jms.Session session, javax.jms.Destination dest, javax.jms.Message message, boolean ignoreInvalidDestinationException)
String	send(javax.jms.Session session, javax.jms.Destination dest, String correlationId, Message message, String messageType, long timeToLive, int deliveryMode, int priority, boolean ignoreInvalidDestinationException)
protected String	sendByQueue(javax.jms.QueueSession session, javax.jms.Queue destination, javax.jms.Message message)
protected String	sendByTopic(javax.jms.TopicSession session, javax.jms.Topic destination, javax.jms.Message message)

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

addParameter, configure, getDestination, getParameterList, open, sendMessage, sendMessage, setDeliveryMode, setDestinationParam, setEncodingStyleURI, setLinkMethod, setMessageType, setPriority, setReplySoapHeaderSessionKey, setReplyTimeout, setReplyToName, setResponseHeadersToSessionKeys, setServiceNamespaceURI, setSoap, setSoapAction, setSoapHeaderParam, setSynchronous, 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, getMessagingSource, getMessagingSourceFactory, getPhysicalDestinationName, getPhysicalDestinationShortName, getPhysicalDestinationShortName, isSessionsArePooled, send, send, send, send, send, 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

Constructor Detail

MQSender

public MQSender()

Method Detail

getMessageProducer

public javax.jms.MessageProducer getMessageProducer(javax.jms.Session session,
                                                    javax.jms.Destination destination)
                                             throws NamingException,
                                                    javax.jms.JMSException

Overrides:

getMessageProducer in class JMSFacade

Throws:

NamingException

javax.jms.JMSException

send

public String send(javax.jms.Session session,
                   javax.jms.Destination dest,
                   String correlationId,
                   Message message,
                   String messageType,
                   long timeToLive,
                   int deliveryMode,
                   int priority,
                   boolean ignoreInvalidDestinationException)
            throws NamingException,
                   javax.jms.JMSException,
                   SenderException,
                   IOException

Overrides:

send in class JMSFacade

Throws:

NamingException

javax.jms.JMSException

SenderException

IOException

send

public String send(javax.jms.Session session,
                   javax.jms.Destination dest,
                   javax.jms.Message message,
                   boolean ignoreInvalidDestinationException)
            throws NamingException,
                   javax.jms.JMSException

Overrides:

send in class JMSFacade

Throws:

NamingException

javax.jms.JMSException

sendByQueue

protected String sendByQueue(javax.jms.QueueSession session,
                             javax.jms.Queue destination,
                             javax.jms.Message message)
                      throws NamingException,
                             javax.jms.JMSException

Overrides:

sendByQueue in class JMSFacade

Throws:

NamingException

javax.jms.JMSException

sendByTopic

protected String sendByTopic(javax.jms.TopicSession session,
                             javax.jms.Topic destination,
                             javax.jms.Message message)
                      throws NamingException,
                             javax.jms.JMSException

Overrides:

sendByTopic in class JMSFacade

Throws:

NamingException

javax.jms.JMSException