Package com.tibco.tibems.ufo
Class TibjmsUFOConnectionFactory
- java.lang.Object
- 
- com.tibco.tibems.ufo.TibjmsUFOConnectionFactory
 
- 
- All Implemented Interfaces:
- com.tibco.tibems.ufo.TibjmsUFOxConst,- java.io.Externalizable,- java.io.Serializable,- java.lang.Cloneable,- ConnectionFactory
 - Direct Known Subclasses:
- TibjmsUFOQueueConnectionFactory,- TibjmsUFOTopicConnectionFactory
 
 public class TibjmsUFOConnectionFactory extends java.lang.Object implements ConnectionFactory, java.io.Externalizable, com.tibco.tibems.ufo.TibjmsUFOxConst UFO Implementation of javax.jms.ConnectionFactory.- See Also:
- Serialized Form
 
- 
- 
Constructor SummaryConstructors Constructor Description TibjmsUFOConnectionFactory()Create an empty connection factory.TibjmsUFOConnectionFactory(TibjmsConnectionFactory factory)Create a UFO connection factory with the given tibjms connection factory.TibjmsUFOConnectionFactory(java.lang.String serverUrls)Create a connection factory with the given server URLs.TibjmsUFOConnectionFactory(java.lang.String serverUrls, java.lang.String clientId)Create a connection factory with the given server URLs and client id.TibjmsUFOConnectionFactory(java.lang.String serverUrls, java.lang.String clientId, java.util.Map properties)Create a connection factory with the given server URLs, client id, and properties.
 - 
Method SummaryAll Methods Instance Methods Concrete Methods Deprecated Methods Modifier and Type Method Description java.lang.Objectclone()ConnectioncreateConnection()Creates a connection with the default user identity.ConnectioncreateConnection(java.lang.String userName, java.lang.String password)Creates a connection with the specified user identity.JMSContextcreateContext()Not supported by UFO Implementation.JMSContextcreateContext(int sessionMode)Not supported by UFO Implementation.JMSContextcreateContext(java.lang.String userName, java.lang.String password)Not supported by UFO Implementation.JMSContextcreateContext(java.lang.String userName, java.lang.String password, int sessionMode)Not supported by UFO Implementation.java.lang.StringgetCurrentUrl()java.lang.StringgetSSLProxyHost()Get the TLS proxy host from this connection factory.java.lang.StringgetSSLProxyPassword()Get the TLS proxy password from a connection factory.intgetSSLProxyPort()Get the TLS proxy port from this connection factory.java.lang.StringgetSSLProxyUser()Get the TLS proxy username from a connection factory.voidreadExternal(java.io.ObjectInput in)voidrecoverConnection(Connection connection)Recovers the given connection.voidsetBlockingOnRecovery(boolean blocking)Enable or Disable blocking on Jakarta Messaging API call when the connection is disconnected or in recoveryvoidsetClientID(java.lang.String clientID)voidsetConnAttemptCount(int attempts)voidsetConnAttemptDelay(int delay)voidsetConnAttemptTimeout(int timeout)Set the Connect Attempt timeout for a given connection.voidsetMetric(int metric)This sets the metric that will be used to select an EMS server during load balancing switchover.voidsetMulticastDaemon(java.lang.String port)Deprecated.As of release 8.3voidsetMulticastEnabled(boolean enabled)Deprecated.As of release 8.3voidsetOAuth2AccessToken(java.lang.String accessToken)Set the OAuth 2.0 access token that connections will present to the EMS server.voidsetOAuth2ClientId(java.lang.String clientId)Set the OAuth 2.0 client ID for the client to authenticate with the OAuth 2.0 authorization server.voidsetOAuth2ClientSecret(java.lang.String clientSecret)Set the OAuth 2.0 client secret for the client to authenticate with the OAuth 2.0 authorization server.voidsetOAuth2DisableVerifyHostname(boolean disableVerifyHostname)Set whether to disable client verification of the hostname in the secure OAuth 2.0 authorization server host's certificate.voidsetOAuth2ExpectedHostname(java.lang.String expectedHostname)Set the hostname that is expected to be set in the secure OAuth 2.0 authorization server host's certificate.voidsetOAuth2ServerTrustFile(byte[] serverTrustFile)Set the trust contents for verifying the identity of the secure OAuth 2.0 authorization server.voidsetOAuth2ServerTrustFile(java.lang.String serverTrustFile)Set the trust file path for verifying the identity of the secure OAuth 2.0 authorization server.voidsetOAuth2ServerUrl(java.lang.String serverUrl)Set the OAuth 2.0 authorization server URL for the client to authenticate with.voidsetOAuth2TokenFetchCallback(TibjmsOAuth2TokenFetchCallback callback)Set theTibjmsOAuth2TokenFetchCallbackobject to be invoked when the client needs to fetch an OAuth 2.0 access token.voidsetReconnAttemptCount(int attempts)voidsetReconnAttemptDelay(int delay)voidsetReconnAttemptTimeout(int timeout)Set the Reconnect Attempt timeout for a given connection Note: This timeout is per url and per reconnect_attempt.voidsetServerUrl(java.lang.String serverUrls)Connections created by this connection factory will connect to a server in the given URL list.voidsetSSLAuthOnly(java.lang.Boolean authOnly)Set client connections to use TLS only during initial connection authentication.voidsetSSLCipherSuites(java.lang.String suites)Set cipher suites to be used by TLS connections.voidsetSSLDebugTrace(java.lang.Boolean debugTrace)Enables debug tracing.voidsetSSLEnableVerifyHost(java.lang.Boolean enableVerifyHost)Set if the host certificate should be verified by the client.voidsetSSLEnableVerifyHostName(java.lang.Boolean enableVerifyHostName)Set if the name in the host certificate should be verified or not.voidsetSSLExpectedHostName(java.lang.String expectedHostName)Set the name which is expected to be set in the host certificate.voidsetSSLIdentity(byte[] identity)The client's digital certificate.voidsetSSLIdentity(java.lang.String sslIdentity)The client's digital certificate.voidsetSSLIdentityEncoding(java.lang.String sslIdentityEncoding)The encoding of the client identity specified in the setSSLIdentity() method.voidsetSSLIssuerCertificate(byte[] certificate, java.lang.String encoding)Issuer certificates are certificates that authenticate the client's certificate; the certificate authority (CA) that issued the client's certificate supplies these.voidsetSSLIssuerCertificate(java.lang.String certificate)Issuer certificates are certificates that authenticate the client's certificate; the certificate authority (CA) that issued the client's certificate supplies these.voidsetSSLIssuerCertificate(java.lang.String certificate, java.lang.String encoding)Issuer certificates are certificates that authenticate the client's certificate; the certificate authority (CA) that issued the client's certificate supplies these.voidsetSSLPassword(java.lang.String sslPassword)Set the private key password for TLS.voidsetSSLPrivateKey(byte[] sslPrivateKey)Set the private key corresponding to the identity certificate.voidsetSSLPrivateKey(java.lang.String sslPrivateKey)Set the private key corresponding to the identity certificate.voidsetSSLPrivateKeyEncoding(java.lang.String sslPrivateKeyEncoding)Set the private key corresponding to the identity certificate.voidsetSSLProxy(java.lang.String host, int port)Set the connection factory's parameters for connecting through a TLS proxy.voidsetSSLProxyAuth(java.lang.String username, java.lang.String password)Set a connection factory's username and password for connecting through a TLS proxy.voidsetSSLTrace(java.lang.Boolean trace)voidsetSSLTrustedCertificate(byte[] certificate, java.lang.String trustedEncoding)Trusted certificates are certificates that authenticate the server's certificate; the certificate authority (CA) that issued the server's certificate supplies these.voidsetSSLTrustedCertificate(java.lang.String certificate)Trusted certificates are certificates that authenticate the server's certificate; the certificate authority (CA) that issued the server's certificate supplies these.voidsetSSLTrustedCertificate(java.lang.String certificate, java.lang.String trustedEncoding)Trusted certificates are certificates that authenticate the server's certificate; the certificate authority (CA) that issued the server's certificate supplies these.voidsetSSLVendor(java.lang.String vendor)Set TLS vendor to the specified vendor.voidsetUserName(java.lang.String username)The connection object presents this user identity to the EMS server.voidsetUserPassword(java.lang.String password)The connection object authenticates the user identity with this password.java.lang.StringtoString()voidwriteExternal(java.io.ObjectOutput out)
 
- 
- 
- 
Constructor Detail- 
TibjmsUFOConnectionFactorypublic TibjmsUFOConnectionFactory() Create an empty connection factory. This call does not attempt to access the repository. Equivalent toTibjmsConnectionFactory(null, null, null).- See Also:
- TibjmsContext
 
 - 
TibjmsUFOConnectionFactorypublic TibjmsUFOConnectionFactory(java.lang.String serverUrls) Create a connection factory with the given server URLs. Equivalent toTibjmsUFOConnectionFactory(serverUrls, null, null).- Parameters:
- serverUrls- Connections created by this connection factory will connect to a server in this URL list.
 
 - 
TibjmsUFOConnectionFactorypublic TibjmsUFOConnectionFactory(java.lang.String serverUrls, java.lang.String clientId)Create a connection factory with the given server URLs and client id. Equivalent toTibjmsUFOConnectionFactory(serverUrls, clientId, null).- Parameters:
- serverUrls- Connections created by this connection factory will connect to a server in this URL list.
- clientId-
 
 - 
TibjmsUFOConnectionFactorypublic TibjmsUFOConnectionFactory(java.lang.String serverUrls, java.lang.String clientId, java.util.Map properties)Create a connection factory with the given server URLs, client id, and properties.- Parameters:
- serverUrls- Connections created by this connection factory will connect to a server in this URL list.
- clientId-
- properties-
 
 - 
TibjmsUFOConnectionFactorypublic TibjmsUFOConnectionFactory(TibjmsConnectionFactory factory) throws JMSException Create a UFO connection factory with the given tibjms connection factory.- Parameters:
- factory- Connections created by this connection factory will connect to a server in this URL list.
- Throws:
- JMSException
 
 
- 
 - 
Method Detail- 
createConnectionpublic Connection createConnection() throws JMSException Description copied from interface:ConnectionFactoryCreates a connection with the default user identity. The connection is created in stopped mode. No messages will be delivered until theConnection.startmethod is explicitly called.- Specified by:
- createConnectionin interface- ConnectionFactory
- Returns:
- a newly created connection
- Throws:
- JMSException- if the Jakarta Messaging provider fails to create the connection due to some internal error.
- JMSSecurityException- if client authentication fails due to an invalid user name or password.
 
 - 
createConnectionpublic Connection createConnection(java.lang.String userName, java.lang.String password) throws JMSException Description copied from interface:ConnectionFactoryCreates a connection with the specified user identity. The connection is created in stopped mode. No messages will be delivered until theConnection.startmethod is explicitly called.- Specified by:
- createConnectionin interface- ConnectionFactory
- Parameters:
- userName- the caller's user name
- password- the caller's password
- Returns:
- a newly created connection
- Throws:
- JMSException- if the Jakarta Messaging provider fails to create the connection due to some internal error.
- JMSSecurityException- if client authentication fails due to an invalid user name or password.
 
 - 
clonepublic java.lang.Object clone() throws java.lang.CloneNotSupportedException- Throws:
- java.lang.CloneNotSupportedException
 
 - 
createContextpublic JMSContext createContext() Not supported by UFO Implementation.- Specified by:
- createContextin interface- ConnectionFactory
- Returns:
- a newly created JMSContext
- See Also:
- JMSContext.AUTO_ACKNOWLEDGE,- ConnectionFactory.createContext(int),- ConnectionFactory.createContext(java.lang.String, java.lang.String),- ConnectionFactory.createContext(java.lang.String, java.lang.String, int),- JMSContext.createContext(int)
 
 - 
createContextpublic JMSContext createContext(int sessionMode) Not supported by UFO Implementation.- Specified by:
- createContextin interface- ConnectionFactory
- Parameters:
- sessionMode- indicates which of four possible session modes will be used.- If this method is called in a Java SE environment or in the Jakarta EE application client container, the permitted
 values are JMSContext.SESSION_TRANSACTED,JMSContext.CLIENT_ACKNOWLEDGE,JMSContext.AUTO_ACKNOWLEDGEandJMSContext.DUPS_OK_ACKNOWLEDGE.
- If this method is called in the Jakarta EE web or EJB container when there is an active JTA transaction in progress then this argument is ignored.
- If this method is called in the Jakarta EE web or EJB container when there is no active JTA transaction in progress,
 the permitted values are JMSContext.AUTO_ACKNOWLEDGEandJMSContext.DUPS_OK_ACKNOWLEDGE. In this case the valuesJMSContext.TRANSACTEDandJMSContext.CLIENT_ACKNOWLEDGEare not permitted.
 
- If this method is called in a Java SE environment or in the Jakarta EE application client container, the permitted
 values are 
- Returns:
- a newly created JMSContext
- See Also:
- JMSContext.SESSION_TRANSACTED,- JMSContext.CLIENT_ACKNOWLEDGE,- JMSContext.AUTO_ACKNOWLEDGE,- JMSContext.DUPS_OK_ACKNOWLEDGE,- ConnectionFactory.createContext(),- ConnectionFactory.createContext(java.lang.String, java.lang.String),- ConnectionFactory.createContext(java.lang.String, java.lang.String, int),- JMSContext.createContext(int)
 
 - 
createContextpublic JMSContext createContext(java.lang.String userName, java.lang.String password, int sessionMode) Not supported by UFO Implementation.- Specified by:
- createContextin interface- ConnectionFactory
- Parameters:
- userName- the caller's user name
- password- the caller's password
- sessionMode- indicates which of four possible session modes will be used.- If this method is called in a Java SE environment or in the Jakarta EE application client container, the permitted
 values are JMSContext.SESSION_TRANSACTED,JMSContext.CLIENT_ACKNOWLEDGE,JMSContext.AUTO_ACKNOWLEDGEandJMSContext.DUPS_OK_ACKNOWLEDGE.
- If this method is called in the Jakarta EE web or EJB container when there is an active JTA transaction in progress then this argument is ignored.
- If this method is called in the Jakarta EE web or EJB container when there is no active JTA transaction in progress,
 the permitted values are JMSContext.AUTO_ACKNOWLEDGEandJMSContext.DUPS_OK_ACKNOWLEDGE. In this case the valuesJMSContext.TRANSACTEDandJMSContext.CLIENT_ACKNOWLEDGEare not permitted.
 
- If this method is called in a Java SE environment or in the Jakarta EE application client container, the permitted
 values are 
- Returns:
- a newly created JMSContext
- See Also:
- JMSContext.SESSION_TRANSACTED,- JMSContext.CLIENT_ACKNOWLEDGE,- JMSContext.AUTO_ACKNOWLEDGE,- JMSContext.DUPS_OK_ACKNOWLEDGE,- ConnectionFactory.createContext(),- ConnectionFactory.createContext(int),- ConnectionFactory.createContext(java.lang.String, java.lang.String),- JMSContext.createContext(int)
 
 - 
createContextpublic JMSContext createContext(java.lang.String userName, java.lang.String password) Not supported by UFO Implementation.- Specified by:
- createContextin interface- ConnectionFactory
- Parameters:
- userName- the caller's user name
- password- the caller's password
- Returns:
- a newly created JMSContext
- See Also:
- JMSContext.AUTO_ACKNOWLEDGE,- ConnectionFactory.createContext(),- ConnectionFactory.createContext(int),- ConnectionFactory.createContext(java.lang.String, java.lang.String, int),- JMSContext.createContext(int)
 
 - 
setServerUrlpublic void setServerUrl(java.lang.String serverUrls) throws JMSExceptionConnections created by this connection factory will connect to a server in the given URL list.- Parameters:
- serverUrls-
- Throws:
- JMSException
 
 - 
setClientIDpublic void setClientID(java.lang.String clientID) throws JMSException- Parameters:
- clientID- The clientID that will be sent to the server when a Connection is created.
- Throws:
- JMSException
 
 - 
setMetricpublic void setMetric(int metric) throws JMSExceptionThis sets the metric that will be used to select an EMS server during load balancing switchover. Allowed values are defined in the Tibjms class, with names like FACTORY_LOAD_BALANCE_METRIC_*- Parameters:
- metric- The metric to use during load balancing switchover.
- Throws:
- JMSException
- See Also:
- Tibjms
 
 - 
setConnAttemptCountpublic void setConnAttemptCount(int attempts) - Parameters:
- attempts- The number of times the connection object attempts to establish a connection to the server list. Note: the attempt is per list. A single attempt means that the connection object tries to connect to a server in the list until it either successes or fails on all servers in the list.
 
 - 
setConnAttemptDelaypublic void setConnAttemptDelay(int delay) - Parameters:
- delay- The delay time between successive attempts to establish a connection to the server list. Its value is the time (in milliseconds) between connection attempts.
 
 - 
setReconnAttemptCountpublic void setReconnAttemptCount(int attempts) - Parameters:
- attempts- The number of times that a connection object attempts to recover a connection to the server list.
 
 - 
setReconnAttemptDelaypublic void setReconnAttemptDelay(int delay) - Parameters:
- delay- The delay time between successive attempts to recover connection to the server list. Its value is the time (in milliseconds) between recovery attempts.
 
 - 
setUserNamepublic void setUserName(java.lang.String username) The connection object presents this user identity to the EMS server.
 When OAuth 2.0 is configured, this username is presented to the OAuth 2.0 authorization server using the resource owner password credentials grant. SeeTibjmsOAuthfor more information.- Parameters:
- username-
 
 - 
setUserPasswordpublic void setUserPassword(java.lang.String password) The connection object authenticates the user identity with this password.
 When OAuth 2.0 is configured, this password is presented to the OAuth 2.0 authorization server using the resource owner password credentials grant. SeeTibjmsOAuthfor more information.- Parameters:
- password-
 
 - 
setSSLVendorpublic void setSSLVendor(java.lang.String vendor) Set TLS vendor to the specified vendor. The vendorName parameter should be 'j2se'. After the TLS environment has been initialized, the vendor cannot be changed and calls to this methods are ignored.- Parameters:
- vendor- Specifies the TLS implementation to be used for creating TLS connections.
- See Also:
- TibjmsSSL
 
 - 
setSSLTracepublic void setSSLTrace(java.lang.Boolean trace) - Parameters:
- trace- Set true to enable tracing of TLS related operations.
 
 - 
setSSLDebugTracepublic void setSSLDebugTrace(java.lang.Boolean debugTrace) Enables debug tracing. When 'j2se' TLS vendor is used debug tracing should be enabled via javax.net.debug system property.- Parameters:
- debugTrace- Set to true to enable debug tracing.
 
 - 
setSSLEnableVerifyHostpublic void setSSLEnableVerifyHost(java.lang.Boolean enableVerifyHost) Set if the host certificate should be verified by the client. By default it is always enabled.- Parameters:
- enableVerifyHost-
 
 - 
setSSLEnableVerifyHostNamepublic void setSSLEnableVerifyHostName(java.lang.Boolean enableVerifyHostName) Set if the name in the host certificate should be verified or not. By default this is always enabled.- Parameters:
- enableVerifyHostName-
 
 - 
setSSLExpectedHostNamepublic void setSSLExpectedHostName(java.lang.String expectedHostName) Set the name which is expected to be set in the host certificate. Name in the certificate is present in the CN field of the certificate subject. By default the expected certificate name is the name of the connected host.- Parameters:
- expectedHostName-
 
 - 
setSSLAuthOnlypublic void setSSLAuthOnly(java.lang.Boolean authOnly) Set client connections to use TLS only during initial connection authentication. If parameter istruethen connections use TLS only for authentication and switch to TCP protocol for all subsequent messaging. If parameter isfalsethen TLS is used for the lifetime of the connection, which is the default mode. Connections use this setting at the time they are created. Changing this setting only affects connection created after the change. By default this parameter is disabled.- Parameters:
- authOnly- Set true to only use TLS for authentication, false to use TLS for the lifetime of the connections.
 
 - 
setSSLTrustedCertificatepublic void setSSLTrustedCertificate(java.lang.String certificate) Trusted certificates are certificates that authenticate the server's certificate; the certificate authority (CA) that issued the server's certificate supplies these. TLS clients may verify them during the TLS handshake; if your program verifies host certificates, then you must register trusted certificates as well. If the ConnectionFactory already has trusted certificates, this call adds to that set; it does not overwrite them.- Parameters:
- certificate-
 
 - 
setSSLTrustedCertificatepublic void setSSLTrustedCertificate(java.lang.String certificate, java.lang.String trustedEncoding)Trusted certificates are certificates that authenticate the server's certificate; the certificate authority (CA) that issued the server's certificate supplies these. TLS clients may verify them during the TLS handshake; if your program verifies host certificates, then you must register trusted certificates as well. If the ConnectionFactory already has trusted certificates, this call adds to that set; it does not overwrite them.- Parameters:
- certificate-
- trustedEncoding-
 
 - 
setSSLTrustedCertificatepublic void setSSLTrustedCertificate(byte[] certificate, java.lang.String trustedEncoding)Trusted certificates are certificates that authenticate the server's certificate; the certificate authority (CA) that issued the server's certificate supplies these. TLS clients may verify them during the TLS handshake; if your program verifies host certificates, then you must register trusted certificates as well. If the ConnectionFactory already has trusted certificates, this call adds to that set; it does not overwrite them.- Parameters:
- certificate- The certificate, represented as raw bytes.
- trustedEncoding-
 
 - 
setSSLIssuerCertificatepublic void setSSLIssuerCertificate(java.lang.String certificate) Issuer certificates are certificates that authenticate the client's certificate; the certificate authority (CA) that issued the client's certificate supplies these. TLS clients must supply them during the TLS handshake, so your program must set them.- Parameters:
- certificate-
 
 - 
setSSLIssuerCertificatepublic void setSSLIssuerCertificate(java.lang.String certificate, java.lang.String encoding)Issuer certificates are certificates that authenticate the client's certificate; the certificate authority (CA) that issued the client's certificate supplies these. TLS clients must supply them during the TLS handshake, so your program must set them.- Parameters:
- certificate-
- encoding-
 
 - 
setSSLIssuerCertificatepublic void setSSLIssuerCertificate(byte[] certificate, java.lang.String encoding)Issuer certificates are certificates that authenticate the client's certificate; the certificate authority (CA) that issued the client's certificate supplies these. TLS clients must supply them during the TLS handshake, so your program must set them.- Parameters:
- certificate- The certificate as binary data
- encoding- The encoding type for this certificate
 
 - 
setSSLIdentitypublic void setSSLIdentity(java.lang.String sslIdentity) The client's digital certificate. For more information on file types for digital certificates, see "File Names for Certificates and Keys" in the EMS User Guide.- Parameters:
- sslIdentity-
 
 - 
setSSLIdentitypublic void setSSLIdentity(byte[] identity) The client's digital certificate. For more information on file types for digital certificates, see "File Names for Certificates and Keys" in the EMS User Guide.- Parameters:
- identity-
 
 - 
setSSLIdentityEncodingpublic void setSSLIdentityEncoding(java.lang.String sslIdentityEncoding) The encoding of the client identity specified in the setSSLIdentity() method.- Parameters:
- sslIdentityEncoding-
 
 - 
setSSLPrivateKeypublic void setSSLPrivateKey(java.lang.String sslPrivateKey) Set the private key corresponding to the identity certificate.- Parameters:
- sslPrivateKey-
 
 - 
setSSLPrivateKeypublic void setSSLPrivateKey(byte[] sslPrivateKey) Set the private key corresponding to the identity certificate.- Parameters:
- sslPrivateKey-
 
 - 
setSSLPrivateKeyEncodingpublic void setSSLPrivateKeyEncoding(java.lang.String sslPrivateKeyEncoding) Set the private key corresponding to the identity certificate.- Parameters:
- sslPrivateKeyEncoding-
 
 - 
setSSLPasswordpublic void setSSLPassword(java.lang.String sslPassword) Set the private key password for TLS.- Parameters:
- sslPassword-
 
 - 
setSSLCipherSuitespublic void setSSLCipherSuites(java.lang.String suites) Set cipher suites to be used by TLS connections.- Parameters:
- suites-
 
 - 
setSSLProxypublic void setSSLProxy(java.lang.String host, int port) throws JMSExceptionSet the connection factory's parameters for connecting through a TLS proxy. A TLS proxy lets an EMS application create a TLS connection to an EMS server, even though a firewall separates the application from the server. The proxy usually runs within the firewall's DMZ. A connection factory contacts the TLS proxy, requesting a TLS connection to the server. The proxy authenticates the application program, and mediates the initial TLS negotiation between application and server. After the TLS connection is established, the application and server use it to communicate directly with one another.- Parameters:
- host- the connection factory establishes TLS communication through a web proxy at this host. Supply a simple hostname, a fully qualified hostname with domain name, or an IP address (dot notation).
- port- the connection factory establishes TLS communication through a web proxy on this port.
- Throws:
- JMSException- if the proxy host is null or empty, the port is zero or the protocol of the connection factory's URL is not TLS.
 
 - 
setSSLProxyAuthpublic void setSSLProxyAuth(java.lang.String username, java.lang.String password) throws JMSExceptionSet a connection factory's username and password for connecting through a TLS proxy. When a connection factory establishes an EMS server connection through a TLS proxy host, the proxy might first require authentication before facilitating a connection. When required, use this call to set that authentication data on the connection factory. Notice that this proxy authentication data is distinct from the server authentication data, and from the TLS private key encryption password.- Parameters:
- username- the connection factory authenticates itself to the TLS proxy using this username.
- password- the connection factory authenticates itself to the TLS proxy using this password.
- Throws:
- JMSException- if the protocol of the connection factory's URL is not TLS.
 
 - 
getSSLProxyHostpublic java.lang.String getSSLProxyHost() throws JMSExceptionGet the TLS proxy host from this connection factory.- Returns:
- the host
- Throws:
- JMSException- if the protocol of the connection factory's URL is not TLS.
 
 - 
getSSLProxyPortpublic int getSSLProxyPort() throws JMSExceptionGet the TLS proxy port from this connection factory.- Returns:
- the port.
- Throws:
- JMSException- if the protocol of the connection factory's URL is not TLS.
 
 - 
getSSLProxyUserpublic java.lang.String getSSLProxyUser() throws JMSExceptionGet the TLS proxy username from a connection factory.- Returns:
- the username.
- Throws:
- JMSException- if the protocol of the connection factory's URL is not TLS.
 
 - 
getSSLProxyPasswordpublic java.lang.String getSSLProxyPassword() throws JMSExceptionGet the TLS proxy password from a connection factory.- Returns:
- the password.
- Throws:
- JMSException- if the protocol of the connection factory's URL is not TLS.
 
 - 
setOAuth2AccessTokenpublic void setOAuth2AccessToken(java.lang.String accessToken) Set the OAuth 2.0 access token that connections will present to the EMS server.- Parameters:
- accessToken-
- Since:
- 10.4.0
- See Also:
- Tibjms.PROP_OAUTH2_ACCESS_TOKEN
 
 - 
setOAuth2TokenFetchCallbackpublic void setOAuth2TokenFetchCallback(TibjmsOAuth2TokenFetchCallback callback) Set theTibjmsOAuth2TokenFetchCallbackobject to be invoked when the client needs to fetch an OAuth 2.0 access token.- Parameters:
- callback-
- Since:
- 10.4.0
- See Also:
- Tibjms.PROP_OAUTH2_TOKEN_FETCH_CALLBACK_OBJECT,- TibjmsOAuth2TokenFetchCallback
 
 - 
setOAuth2ServerUrlpublic void setOAuth2ServerUrl(java.lang.String serverUrl) Set the OAuth 2.0 authorization server URL for the client to authenticate with.- Parameters:
- serverUrl-
- Since:
- 10.4.0
- See Also:
- Tibjms.PROP_OAUTH2_SERVER_URL
 
 - 
setOAuth2ClientIdpublic void setOAuth2ClientId(java.lang.String clientId) Set the OAuth 2.0 client ID for the client to authenticate with the OAuth 2.0 authorization server.- Parameters:
- clientID-
- Since:
- 10.4.0
- See Also:
- Tibjms.PROP_OAUTH2_CLIENT_ID
 
 - 
setOAuth2ClientSecretpublic void setOAuth2ClientSecret(java.lang.String clientSecret) Set the OAuth 2.0 client secret for the client to authenticate with the OAuth 2.0 authorization server.- Parameters:
- clientSecret-
- Since:
- 10.4.0
- See Also:
- Tibjms.PROP_OAUTH2_CLIENT_SECRET
 
 - 
setOAuth2ServerTrustFilepublic void setOAuth2ServerTrustFile(java.lang.String serverTrustFile) Set the trust file path for verifying the identity of the secure OAuth 2.0 authorization server. The trust file set via this property must contain one or more PEM-encoded public certificates.- Parameters:
- serverTrustFile- The PEM-encoded certificate file path
- Since:
- 10.4.0
- See Also:
- Tibjms.PROP_OAUTH2_SERVER_TRUST_FILE
 
 - 
setOAuth2ServerTrustFilepublic void setOAuth2ServerTrustFile(byte[] serverTrustFile) Set the trust contents for verifying the identity of the secure OAuth 2.0 authorization server. The byte array set via this property must contain one or more PEM-encoded public certificates.- Parameters:
- serverTrustFile- The PEM-encoded certificate, represented as raw bytes
- Since:
- 10.4.0
- See Also:
- Tibjms.PROP_OAUTH2_SERVER_TRUST_FILE
 
 - 
setOAuth2DisableVerifyHostnamepublic void setOAuth2DisableVerifyHostname(boolean disableVerifyHostname) Set whether to disable client verification of the hostname in the secure OAuth 2.0 authorization server host's certificate.- Parameters:
- disableVerifyHostname-
- Since:
- 10.4.0
- See Also:
- Tibjms.PROP_OAUTH2_DISABLE_VERIFY_HOSTNAME
 
 - 
setOAuth2ExpectedHostnamepublic void setOAuth2ExpectedHostname(java.lang.String expectedHostname) Set the hostname that is expected to be set in the secure OAuth 2.0 authorization server host's certificate.- Parameters:
- expectedHostname-
- Since:
- 10.4.0
- See Also:
- Tibjms.PROP_OAUTH2_EXPECTED_HOSTNAME
 
 - 
setConnAttemptTimeoutpublic void setConnAttemptTimeout(int timeout) Set the Connect Attempt timeout for a given connection. Note: This timeout is per url and per connect_attempt. So if one were to specify two connect attempts for a given url then for each attempt the client will wait utmost connect attempt timeout for the connection to be established, if no connection is esablished within that time, the client's connection attempt is teared down if the client is hung either because of system resources unavailable on the server machine or because of some other error in the EMS Server NOTE: minimum value is 100 milliseconds, if value less than 100 milliseconds is specified, then during the connection establishment the minimum value of 100 milliseconds is used.- Parameters:
- timeout- the timeout is in milliseconds
 
 - 
setReconnAttemptTimeoutpublic void setReconnAttemptTimeout(int timeout) Set the Reconnect Attempt timeout for a given connection Note: This timeout is per url and per reconnect_attempt. So if one were to specify 2 reconnect attempts for a given url then for each attempt the client will wait utmost reconnect attempt timeout for the connection to be established, if no connection is established within that time, the client's reconnection attempt is teared down if the client is hung either because of system resources unavailable on the server machine or because of some other error in the EMS Server NOTE: minimum value is 100 milliseconds, if value less than 100 milliseconds is specified, then during the connection establishment the minimum value of 100 milliseconds is used.- Parameters:
- timeout- the timeout is in milliseconds
 
 - 
setMulticastEnabled@Deprecated public void setMulticastEnabled(boolean enabled) Deprecated.As of release 8.3Set whether MessageConsumers subscribed to a multicast-enabled topic will receive messages over multicast.
 
 When enabled, MessageConsumers subscribed to a multicast-enabled topic will receive messages over multicast.
 
 The default is enabled.- Parameters:
- enabled-- trueto enable multicast,- falseto disable multicast
- Since:
- EMS 5.0
 
 - 
setMulticastDaemon@Deprecated public void setMulticastDaemon(java.lang.String port) throws JMSExceptionDeprecated.As of release 8.3Set the port on which the EMS client will connect to the multicast daemon.
 
 A connection to the multicast daemon is required when multicast is enabled and a MessageConsumer is subscribed to a multicast-enabled topic.
 
 NOTE: setting the port with this method will override the default port supplied by the EMS server.- Parameters:
- port- the port of the multicast daemon
- Throws:
- JMSException
- Since:
- EMS 5.0
 
 - 
recoverConnectionpublic void recoverConnection(Connection connection) throws JMSException Recovers the given connection. This method is used to recover the broken connection on another available server. The sessions, message producers, message consumers, temporary destinations created by this broken connection are transparently recreated once the connection is recovered.- Parameters:
- connection- connection to be recovered
- Throws:
- JMSException
 
 - 
writeExternalpublic void writeExternal(java.io.ObjectOutput out) throws java.io.IOException- Specified by:
- writeExternalin interface- java.io.Externalizable
- Throws:
- java.io.IOException
 
 - 
readExternalpublic void readExternal(java.io.ObjectInput in) throws java.io.IOException, java.lang.ClassNotFoundException- Specified by:
- readExternalin interface- java.io.Externalizable
- Throws:
- java.io.IOException
- java.lang.ClassNotFoundException
 
 - 
setBlockingOnRecoverypublic void setBlockingOnRecovery(boolean blocking) Enable or Disable blocking on Jakarta Messaging API call when the connection is disconnected or in recovery- Parameters:
- blocking- true enables blocking and false disables blocking
 
 - 
toStringpublic java.lang.String toString() - Overrides:
- toStringin class- java.lang.Object
 
 - 
getCurrentUrlpublic java.lang.String getCurrentUrl() 
 
- 
 
-