Class MQSender

java.lang.Object

org.frankframework.jndi.JndiBase

org.frankframework.jms.JMSFacade

org.frankframework.jms.JmsSender

org.frankframework.extensions.ibm.MQSender

All Implemented Interfaces:

FrankElement, HasApplicationContext, HasName, HasPhysicalDestination, IConfigurable, ICorrelatedSender, IScopeProvider, ISender, ISenderWithParameters, IWithParameters, IXAEnabled, NameAware, ConfigurableLifecycle, org.springframework.beans.factory.Aware, org.springframework.context.ApplicationContextAware, org.springframework.context.Lifecycle, org.springframework.context.Phased, org.springframework.context.SmartLifecycle

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).

Author:

Jaco de Groot

Nested Class Summary

Nested classes/interfaces inherited from class JmsSender

JmsSender.LinkMethod

Nested classes/interfaces inherited from class JMSFacade

JMSFacade.AcknowledgeMode, JMSFacade.DeliveryMode, JMSFacade.JmsDestinationType, JMSFacade.MessageClass, JMSFacade.SubscriberType

Field Summary

Fields inherited from class JmsSender

paramList

Fields inherited from class JMSFacade

JMS_MESSAGECLASS_KEY, log, messagingSource

Fields inherited from interface org.springframework.context.SmartLifecycle

DEFAULT_PHASE

Constructor Summary

Constructors

Constructor	Description
MQSender()

Method Summary

Modifier and Type	Method	Description
jakarta.jms.MessageProducer	getMessageProducer(jakarta.jms.Session session, jakarta.jms.Destination destination)
String	send(jakarta.jms.Session session, jakarta.jms.Destination dest, jakarta.jms.Message message, boolean ignoreInvalidDestinationException)
protected String	sendByQueue(jakarta.jms.QueueSession session, jakarta.jms.Queue destination, jakarta.jms.Message message)
protected String	sendByTopic(jakarta.jms.TopicSession session, jakarta.jms.Topic destination, jakarta.jms.Message message)

Methods inherited from class JmsSender

addParameter, configure, createSession, getDestination, getParameterList, sendMessage, sendMessage, setDeliveryMode, setDestinationParam, setEncodingStyleURI, setLinkMethod, setMessageType, setPriority, setReplySoapHeaderSessionKey, setReplyTimeout, setReplyToName, setResponseHeadersToSessionKeys, setServiceNamespaceURI, setSoap, setSoapAction, setSoapHeaderParam, setSynchronous, start, toString

Methods inherited from class JMSFacade

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

Methods inherited from class JndiBase

getContext, getJndiEnv, setAuthentication, setCredentials, setInitialContextFactoryName, setJmsRealm, setJndiAuthAlias, setJndiProperties, setPrincipal, setProviderURL, setSecurityProtocol, setUrlPkgPrefixes

Methods inherited from class Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait

Methods inherited from interface org.springframework.context.ApplicationContextAware

setApplicationContext

Methods inherited from interface ConfigurableLifecycle

getPhase, isAutoStartup, isConfigured

Methods inherited from interface FrankElement

addConfigWarning

Methods inherited from interface HasApplicationContext

getApplicationContext, getConfigurationClassLoader

Methods inherited from interface HasName

getName

Methods inherited from interface ISender

isSynchronous, sendMessageOrThrow, stop

Methods inherited from interface ISenderWithParameters

consumesSessionVariable

Methods inherited from interface IXAEnabled

isTransacted

Methods inherited from interface NameAware

setName

Methods inherited from interface org.springframework.context.SmartLifecycle

isPauseable, stop

Constructor Details

MQSender

public MQSender()

Method Details

getMessageProducer

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

Overrides:

getMessageProducer in class JMSFacade

Throws:

jakarta.jms.JMSException

send

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

Overrides:

send in class JMSFacade

Throws:

jakarta.jms.JMSException

sendByQueue

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

Overrides:

sendByQueue in class JMSFacade

Throws:

jakarta.jms.JMSException

sendByTopic

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

Overrides:

sendByTopic in class JMSFacade

Throws:

jakarta.jms.JMSException