public class MQSender extends JmsSender
See JmsSender
for configuration
JmsSender.LinkMethod
JMSFacade.AcknowledgeMode, JMSFacade.DeliveryMode, JMSFacade.DestinationType, JMSFacade.SubscriberType
messagingSource
Constructor and Description |
---|
MQSender() |
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) |
addParameter, configure, getDestination, getParameterList, open, sendMessage, sendMessage, setDeliveryMode, setDestinationParam, setEncodingStyleURI, setLinkMethod, setMessageType, setPriority, setReplySoapHeaderSessionKey, setReplyTimeout, setReplyToName, setResponseHeadersToSessionKeys, setServiceNamespaceURI, setSoap, setSoapAction, setSoapHeaderParam, setSynchronous, toString
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
getContext, getJndiEnv, setAuthentication, setCredentials, setInitialContextFactoryName, setJmsRealm, setJndiAuthAlias, setJndiContextPrefix, setJndiProperties, setName, setPrincipal, setProviderURL, setSecurityProtocol, setUrlPkgPrefixes
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait
consumesSessionVariable
close, isSynchronous, sendMessageOrThrow
getName, setName
getApplicationContext, getName
getConfigurationClassLoader
setApplicationContext
getDomain
isTransacted
public javax.jms.MessageProducer getMessageProducer(javax.jms.Session session, javax.jms.Destination destination) throws NamingException, javax.jms.JMSException
getMessageProducer
in class JMSFacade
NamingException
javax.jms.JMSException
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
send
in class JMSFacade
NamingException
javax.jms.JMSException
SenderException
IOException
public String send(javax.jms.Session session, javax.jms.Destination dest, javax.jms.Message message, boolean ignoreInvalidDestinationException) throws NamingException, javax.jms.JMSException
send
in class JMSFacade
NamingException
javax.jms.JMSException
protected String sendByQueue(javax.jms.QueueSession session, javax.jms.Queue destination, javax.jms.Message message) throws NamingException, javax.jms.JMSException
sendByQueue
in class JMSFacade
NamingException
javax.jms.JMSException
protected String sendByTopic(javax.jms.TopicSession session, javax.jms.Topic destination, javax.jms.Message message) throws NamingException, javax.jms.JMSException
sendByTopic
in class JMSFacade
NamingException
javax.jms.JMSException
Copyright © 2023 Frank!Framework. All rights reserved.