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 JMSFacade

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

Nested classes/interfaces inherited from interface ICorrelatedSender

ICorrelatedSender.LinkMethod

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
@NonNull jakarta.jms.MessageProducer	getMessageProducer(@NonNull jakarta.jms.Session session, @Nullable jakarta.jms.Destination destination)
String	send(@NonNull jakarta.jms.Session session, @NonNull jakarta.jms.Destination dest, @NonNull jakarta.jms.Message message, boolean ignoreInvalidDestinationException)
protected String	sendByQueue(@NonNull jakarta.jms.QueueSession session, @NonNull jakarta.jms.Queue destination, @NonNull jakarta.jms.Message message)
protected String	sendByTopic(@NonNull jakarta.jms.TopicSession session, @NonNull jakarta.jms.Topic destination, @NonNull jakarta.jms.Message message)

Methods inherited from class JmsSender

addParameter, configure, createSession, enhanceMessage, 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, 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, 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 ICorrelatedSender

getLinkMethod

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 @NonNull jakarta.jms.MessageProducer getMessageProducer(@NonNull jakarta.jms.Session session,
 @Nullable jakarta.jms.Destination destination)
                                                        throws jakarta.jms.JMSException

Overrides:

getMessageProducer in class JMSFacade

Throws:

jakarta.jms.JMSException

send

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

Overrides:

send in class JMSFacade

Throws:

jakarta.jms.JMSException

sendByQueue

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

Overrides:

sendByQueue in class JMSFacade

Throws:

jakarta.jms.JMSException

sendByTopic

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

Overrides:

sendByTopic in class JMSFacade

Throws:

jakarta.jms.JMSException