Class MQTopicConnectionFactory
java.lang.Object
com.ibm.msg.client.jakarta.jms.internal.JmsReadablePropertyContextImpl
com.ibm.msg.client.jakarta.jms.internal.JmsPropertyContextImpl
com.ibm.msg.client.jakarta.jms.admin.JmsConnectionFactoryImpl
com.ibm.msg.client.jakarta.jms.admin.JmsJndiConnectionFactoryImpl
com.ibm.mq.jakarta.jms.MQConnectionFactory
com.ibm.mq.jakarta.jms.MQTopicConnectionFactory
- All Implemented Interfaces:
JmsConnectionFactory, JmsPropertyContext, JmsReadablePropertyContext, JmsTopicConnectionFactory, com.ibm.msg.client.jakarta.provider.ProviderPropertyContextCallback, jakarta.jms.ConnectionFactory, jakarta.jms.TopicConnectionFactory, Serializable, Map<String,Object>, Referenceable
- Direct Known Subclasses:
MQXATopicConnectionFactory
public class MQTopicConnectionFactory
extends MQConnectionFactory
implements jakarta.jms.TopicConnectionFactory, JmsTopicConnectionFactory, Referenceable, Serializable
A client uses an MQTopicConnectionFactory object to create TopicConnection
objects with a publish/subscribe JMS provider.
- See Also:
-
Nested Class Summary
Nested classes/interfaces inherited from class MQConnectionFactory
MQConnectionFactory.ConnectionFactoryProperty -
Field Summary
Fields inherited from class MQConnectionFactory
MQ_JMSADMIN_KEYFILE -
Constructor Summary
Constructors -
Method Summary
Modifier and TypeMethodDescriptionjakarta.jms.TopicConnectionCreates a topic connection with default user identity.jakarta.jms.TopicConnectioncreateTopicConnection(String userid, String password) Creates a topic connection with the specified user identity.Methods inherited from class MQConnectionFactory
createConnection, createConnection, getAppName, getAppType, getAsyncExceptions, getBalancingApplicationType, getBalancingOptions, getBalancingTimeout, getBrokerCCSubQueue, getBrokerControlQueue, getBrokerPubQueue, getBrokerQueueManager, getBrokerSubQueue, getBrokerVersion, getCCDTHttpsCertValidationPolicy, getCCDTSSLSocketFactory, getCCDTURL, getCCSID, getCertificateValPolicy, getChannel, getCleanupInterval, getCleanupLevel, getClientId, getClientID, getClientReconnectOptions, getClientReconnectTimeout, getConnectionNameList, getConnTag, getDescription, getDirectAuth, getFailIfQuiesce, getFileFromURL, getHdrCompList, getHostName, getLocalAddress, getMapNameStyle, getMaxBufferSize, getMessageRetention, getMessageSelection, getMQConnectionOptions, getMsgBatchSize, getMsgCompList, getMulticast, getPollingInterval, getPort, getProviderVersion, getProxyHostName, getProxyPort, getPubAckInterval, getQueueManager, getReceiveExit, getReceiveExitInit, getReference, getRescanInterval, getSecurityExit, getSecurityExitInit, getSendCheckCount, getSendExit, getSendExitInit, getShareConvAllowed, getSparseSubscriptions, getSSLCertStores, getSSLCertStoresAsString, getSSLCipherSuite, getSSLFipsRequired, getSSLPeerName, getSSLResetCount, getSSLSocketFactory, getStatusRefreshInterval, getSubscriptionStore, getSyncpointAllGets, getTargetClientMatching, getTemporaryModel, getTempQPrefix, getTempTopicPrefix, getTokenClientId, getTokenClientSecret, getTokenEndpoint, getTokenHttpsCertValidationPolicy, getTokenSSLSocketFactory, getTransportType, getUseConnectionPooling, getUserAuthenticationMQCSP, getVersion, getWildcardFormat, setAppName, setAsyncExceptions, setBalancingApplicationType, setBalancingOptions, setBalancingTimeout, setBrokerCCSubQueue, setBrokerControlQueue, setBrokerPubQueue, setBrokerQueueManager, setBrokerSubQueue, setBrokerVersion, setCCDTHttpsCertValidationPolicy, setCCDTSSLSocketFactory, setCCDTURL, setCCSID, setCertificateValPolicy, setChannel, setCleanupInterval, setCleanupLevel, setClientId, setClientID, setClientReconnectOptions, setClientReconnectTimeout, setConnectionNameList, setConnTag, setDescription, setDirectAuth, setFailIfQuiesce, setHdrCompList, setHostName, setLocalAddress, setMapNameStyle, setMaxBufferSize, setMessageRetention, setMessageSelection, setMQConnectionOptions, setMsgBatchSize, setMsgCompList, setMulticast, setPollingInterval, setPort, setProviderVersion, setProxyHostName, setProxyPort, setPubAckInterval, setQueueManager, setReceiveExit, setReceiveExitInit, setRescanInterval, setSecurityExit, setSecurityExitInit, setSendCheckCount, setSendExit, setSendExitInit, setShareConvAllowed, setSparseSubscriptions, setSSLCertStores, setSSLCertStores, setSSLCipherSuite, setSSLFipsRequired, setSSLPeerName, setSSLResetCount, setSSLSocketFactory, setStatusRefreshInterval, setSubscriptionStore, setSyncpointAllGets, setTargetClientMatching, setTemporaryModel, setTempQPrefix, setTempTopicPrefix, setTokenClientId, setTokenClientSecret, setTokenEndpoint, setTokenHttpsCertValidationPolicy, setTokenSSLSocketFactory, setTransportType, setUseConnectionPooling, setUserAuthenticationMQCSP, setWildcardFormatMethods inherited from class com.ibm.msg.client.jakarta.jms.admin.JmsConnectionFactoryImpl
createContext, createContext, createContext, createContext, equals, hashCodeMethods inherited from class com.ibm.msg.client.jakarta.jms.internal.JmsPropertyContextImpl
clear, containsKey, containsValue, entrySet, get, getObjectProperty, isEmpty, keySet, propertyExists, put, putAll, remove, setBatchProperties, setBooleanProperty, setByteProperty, setBytesProperty, setCharProperty, setDoubleProperty, setFloatProperty, setIntProperty, setLongProperty, setObjectProperty, setProviderPropertyContext, setShortProperty, setStringProperty, size, valuesMethods inherited from class com.ibm.msg.client.jakarta.jms.internal.JmsReadablePropertyContextImpl
dump, getBooleanProperty, getByteProperty, getBytesProperty, getCharProperty, getDoubleProperty, getFloatProperty, getIntProperty, getLongProperty, getPropertyNames, getShortProperty, getStringProperty, propertyAppExists, toStringMethods inherited from interface jakarta.jms.ConnectionFactory
createConnection, createConnection, createContext, createContext, createContext, createContextMethods inherited from interface JmsPropertyContext
setBatchProperties, setBooleanProperty, setByteProperty, setBytesProperty, setCharProperty, setDoubleProperty, setFloatProperty, setIntProperty, setLongProperty, setObjectProperty, setShortProperty, setStringProperty, toJsonMethods inherited from interface JmsReadablePropertyContext
getBooleanProperty, getByteProperty, getBytesProperty, getCharProperty, getDoubleProperty, getFloatProperty, getIntProperty, getLongProperty, getObjectProperty, getPropertyNames, getShortProperty, getStringProperty, propertyExists, stringifyMeMethods inherited from interface Map
clear, compute, computeIfAbsent, computeIfPresent, containsKey, containsValue, entrySet, equals, forEach, get, getOrDefault, hashCode, isEmpty, keySet, merge, put, putAll, putIfAbsent, remove, remove, replace, replace, replaceAll, size, valuesMethods inherited from interface Referenceable
getReference
-
Constructor Details
-
MQTopicConnectionFactory
public MQTopicConnectionFactory()The default constructor
-
-
Method Details
-
createTopicConnection
public jakarta.jms.TopicConnection createTopicConnection() throws jakarta.jms.JMSExceptionCreates a topic connection with default user identity.- Specified by:
createTopicConnectionin interfacejakarta.jms.TopicConnectionFactory- Returns:
- a newly created queue connection
- Throws:
jakarta.jms.JMSException- if the JMS provider fails to create a topic connection due to some internal errorjakarta.jms.JMSSecurityException- if client authentication fails due to invalid user name or password- See Also:
-
createTopicConnection
public jakarta.jms.TopicConnection createTopicConnection(String userid, String password) throws jakarta.jms.JMSException Creates a topic connection with the specified user identity. If a null or empty userid is provided, the password parameter will be interpreted as an authentication token to be provided to the queue manager in place of userid and password.- Specified by:
createTopicConnectionin interfacejakarta.jms.TopicConnectionFactory- Parameters:
userid- the user name of the caller.password- the password of the caller.- Returns:
- a newly created topic connection
- Throws:
jakarta.jms.JMSException- if the JMS provider fails to create a topic connection due to some internal errorjakarta.jms.JMSSecurityException- if client authentication fails due to invalid user name or password- See Also:
-