Package org.frankframework.extensions.ibm

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, org.springframework.beans.factory.Aware, org.springframework.context.ApplicationContextAware, org.springframework.context.Lifecycle

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 org.frankframework.jms.JmsSender

JmsSender.LinkMethod

Nested classes/interfaces inherited from class org.frankframework.jms.JMSFacade

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

Field Summary

Fields inherited from class org.frankframework.jms.JmsSender

paramList

Fields inherited from class org.frankframework.jms.JMSFacade

JMS_MESSAGECLASS_KEY, messagingSource

Fields inherited from class org.frankframework.jndi.JndiBase

log

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)
String	send(jakarta.jms.Session session, jakarta.jms.Destination dest, String correlationId, Message message, String messageType, long timeToLive, int deliveryMode, int priority, 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 org.frankframework.jms.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 org.frankframework.jms.JMSFacade

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

Methods inherited from class org.frankframework.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 org.springframework.context.ApplicationContextAware

setApplicationContext

Methods inherited from interface org.frankframework.core.HasApplicationContext

getApplicationContext, getConfigurationClassLoader

Methods inherited from interface org.frankframework.core.HasName

getName

Methods inherited from interface org.frankframework.core.HasPhysicalDestination

getDomain

Methods inherited from interface org.frankframework.core.ISender

isSynchronous, sendMessageOrThrow, stop

Methods inherited from interface org.frankframework.core.ISenderWithParameters

consumesSessionVariable

Methods inherited from interface org.frankframework.core.IXAEnabled

isTransacted

Methods inherited from interface org.frankframework.core.NameAware

setName

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,
 String correlationId,
 Message message,
 String messageType,
 long timeToLive,
 int deliveryMode,
 int priority,
 boolean ignoreInvalidDestinationException)
            throws jakarta.jms.JMSException,
SenderException,
IOException

Overrides:

send in class JMSFacade

Throws:

jakarta.jms.JMSException

SenderException

IOException

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