|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
java.lang.Object | +--com.ibm.mq.jms.MQConnectionFactory
MQConnectionFactory is the WebSphere MQ implementation of ConnectionFactory.
A ConnectionFactory encapsulates a set of connection configuration parameters that
has been defined by an administrator.
A client uses it to create a Connection with a JMS provider.
Connection
,
QueueConnectionFactory
,
TopicConnectionFactory
,
Serialized Form
Constructor Summary | |
MQConnectionFactory()
This is the default constructor. |
Method Summary | |
javax.jms.Connection |
createConnection()
Creates a connection with the default user identity. |
javax.jms.Connection |
createConnection(java.lang.String userName,
java.lang.String password)
Creates a connection with the specified user identity. |
java.lang.String |
getBrokerCCSubQueue()
Gets the broker's queue name for nondurable connection consumers. |
java.lang.String |
getBrokerControlQueue()
Gets the broker's control queue name. |
java.lang.String |
getBrokerPubQueue()
Gets the broker's publish queue name. |
java.lang.String |
getBrokerQueueManager()
Gets the name of the broker's queue manager. |
java.lang.String |
getBrokerSubQueue()
Gets the broker's queue name for subscribers. |
int |
getBrokerVersion()
Gets the version number of the broker. |
java.net.URL |
getCCDTURL()
Gets the URL for the client channel definition table. |
int |
getCCSID()
Gets the character set of the queue manager. |
java.lang.String |
getChannel()
Gets the name of the channel that was used. |
long |
getCleanupInterval()
Gets the clean up interval. |
int |
getCleanupLevel()
Gets the clean up level. |
java.lang.String |
getClientId()
Deprecated. use getClientID instead. |
java.lang.String |
getClientID()
Gets the client ID. |
int |
getCloneSupport()
Indicates whether cloning is supported. |
byte[] |
getConnTag()
Gets the value of the queue manager connection tag. |
java.lang.String |
getDescription()
Gets the description. |
int |
getDirectAuth()
Gets the type of direct authentication that is required. |
int |
getFailIfQuiesce()
Indicates the default behavior of applications accessing a quiescing queue manager. |
java.util.Collection |
getHdrCompList()
Gets the list of header compression techniques which has been set. |
java.lang.String |
getHostName()
Gets the name of the host. |
java.lang.String |
getLocalAddress()
Gets the local address. |
boolean |
getMapNameStyle()
Allows compatibility style to be used for MapMessage element names. |
int |
getMessageRetention()
Indicates what happens to unwanted messages. |
int |
getMessageSelection()
Indicates whether the client or the broker performs message selection. |
int |
getMQConnectionOptions()
Gets the connection options. |
int |
getMsgBatchSize()
Gets the message batch size. |
java.util.Collection |
getMsgCompList()
Gets the list of message compression techniques that have been set. |
int |
getMulticast()
Gets the value of the multicast attribute. |
boolean |
getOptimisticPublication()
Indicates whether transactional publish/subscribe MessageProducers should return immediately from a send/publish call rather than wait until the message has completed delivery. |
boolean |
getOutcomeNotification()
Indicates whether the publish/subscribe MessageConsumers are informed of the outcome of acknowledge or commit calls after receiving messages. |
int |
getPollingInterval()
Gets the interval between scans of all receivers during asynchronous message delivery. |
int |
getPort()
Gets the port number. |
int |
getProcessDuration()
Indicates how promptly received messages are processed. |
java.lang.String |
getProxyHostName()
Gets the proxy host name. |
int |
getProxyPort()
Gets the port number of the proxy server. |
int |
getPubAckInterval()
Gets the number of messages that can be published before requiring acknowledgement from the broker. |
java.lang.String |
getQueueManager()
Gets the name of the queue manager. |
java.lang.String |
getReceiveExit()
Gets the description of the receive exit. |
java.lang.String |
getReceiveExitInit()
Gets the initialization string for the receive exit. |
int |
getReceiveIsolation()
Indicates whether calls by MessageConsumers are isolated from other operations. |
javax.naming.Reference |
getReference()
Creates a reference for this queue connection factory. |
int |
getRescanInterval()
Gets the interval between browse scans of a queue. |
java.lang.String |
getSecurityExit()
Gets the description of the security exit. |
java.lang.String |
getSecurityExitInit()
Gets the initialization string for the security exit. |
java.lang.String |
getSendExit()
Gets the description of the send exit. |
java.lang.String |
getSendExitInit()
Gets the initialization string for the send exit. |
boolean |
getSparseSubscriptions()
Gets the sparse subscriptions attribute. |
java.util.Collection |
getSSLCertStores()
Gets the collection of CertStore objects. |
java.lang.String |
getSSLCertStoresAsString()
Gets the collection of CertStore objects as a String. |
java.lang.String |
getSSLCipherSuite()
Gets the CipherSuite used for SSL encryption. |
boolean |
getSSLFipsRequired()
Indicates whether sslFips (FIPS) is required. |
java.lang.String |
getSSLPeerName()
Gets the distinguished name pattern used to validate the queue manager. |
int |
getSSLResetCount()
Gets the SSL reset count. |
java.lang.Object |
getSSLSocketFactory()
Gets the SSLSocketFactory used with SSL encryption. |
int |
getStatusRefreshInterval()
Gets the status refresh interval. |
int |
getSubscriptionStore()
Gets the SUBSTORE property. |
boolean |
getSyncpointAllGets()
Indicates how syncpoint is used for GET operations. |
boolean |
getTargetClientMatching()
is target client matching enabled. |
java.lang.String |
getTemporaryModel()
Gets the name of a model queue for creating temporary destinations. |
java.lang.String |
getTempQPrefix()
Gets the prefix used to form the name of a WebSphere MQ dynamic queue. |
int |
getTransportType()
Gets the transport type. |
boolean |
getUseConnectionPooling()
Indicates whether connection pooling has been selected. |
int |
getVersion()
Gets the version number. |
void |
setBrokerCCSubQueue(java.lang.String queueName)
Sets the name of the broker nondurable connection consumer subscriber queue. |
void |
setBrokerControlQueue(java.lang.String queueName)
Sets the name of the broker control queue. |
void |
setBrokerPubQueue(java.lang.String queueName)
Sets the name of the broker's publish queue. |
void |
setBrokerQueueManager(java.lang.String queueManagerName)
Sets the name of the broker's queue manager. |
void |
setBrokerSubQueue(java.lang.String queueName)
Gets the name of the broker nondurable subscriber queue. |
void |
setBrokerVersion(int version)
Sets the version of the broker. |
void |
setCCDTURL(java.net.URL url)
Sets the URL for the client channel definition table. |
void |
setCCSID(int ccsid)
Sets the character set to be used when connecting to the queue manager. |
void |
setChannel(java.lang.String channelName)
Sets the name of the channel - applies to clients only. |
void |
setCleanupInterval(long interval)
Sets the clean up interval. |
void |
setCleanupLevel(int level)
Sets the clean up level. |
void |
setClientId(java.lang.String id)
Deprecated. use setClientID() instead. |
void |
setClientID(java.lang.String id)
Sets the client ID. |
void |
setCloneSupport(int type)
Selects whether cloning is supported. |
void |
setConnTag(byte[] cTag)
Sets the value of the queue manager connection tag. |
void |
setDescription(java.lang.String desc)
Sets the description. |
void |
setDirectAuth(int authority)
Sets the type of direct authentication that is required. |
void |
setFailIfQuiesce(int fiq)
Sets the default behavior of applications accessing a quiescing queue manager. |
void |
setHdrCompList(java.util.Collection compList)
Sets the list of header compression techniques. |
void |
setHostName(java.lang.String hostname)
Sets the name of the host. |
void |
setLocalAddress(java.lang.String address)
Sets the local address. |
void |
setMapNameStyle(boolean style)
Allows compatibility style to be used for MapMessage element names. |
void |
setMessageRetention(int mRet)
Sets what happens to unwanted messages. |
void |
setMessageSelection(int selection)
Sets whether the client or the broker performs message selection. |
void |
setMQConnectionOptions(int cTagOpt)
Sets the connection options for a queue manager. |
void |
setMsgBatchSize(int size)
Sets the message batch size. |
void |
setMsgCompList(java.util.Collection compList)
Sets the list of message compression techniques. |
void |
setMulticast(int multicast)
Sets the value of the multicast attribute. |
void |
setOptimisticPublication(boolean newVal)
Determines whether the publish/subscribe MessageProducers can return immediately from a send/publish call rather than wait until the message has completed delivery. |
void |
setOutcomeNotification(boolean newVal)
Determines whether publish/subscribe MessageConsumers are informed of the outcome of acknowledge or commit calls after receiving messages. |
void |
setPollingInterval(int interval)
Sets the interval between scans of all receivers during asynchronous message delivery. |
void |
setPort(int port)
Sets the port for a client connection. |
void |
setProcessDuration(int newVal)
Sets how promptly received messages are processed. |
void |
setProxyHostName(java.lang.String hostName)
Sets the proxy host name. |
void |
setProxyPort(int proxyPort)
Sets the proxy port attribute. |
void |
setPubAckInterval(int interval)
Sets the number of messages that can be published before requiring acknowledgement from the broker. |
void |
setQueueManager(java.lang.String queueManagerName)
Sets the name of the queue manager. |
void |
setReceiveExit(java.lang.String receiveExit)
Sets the receive exit. |
void |
setReceiveExitInit(java.lang.String data)
Sets the initialization string for the receive exit. |
void |
setReceiveIsolation(int newVal)
Sets whether calls by MessageConsumers are isolated from other operations. |
void |
setRescanInterval(int interval)
Sets the interval between browsing a queue. |
void |
setSecurityExit(java.lang.String securityExit)
Sets the security exit. |
void |
setSecurityExitInit(java.lang.String data)
Sets the initialization string for the security exit. |
void |
setSendExit(java.lang.String sendExit)
Sets the send exit. |
void |
setSendExitInit(java.lang.String data)
Gets the description of the send exit. |
void |
setSparseSubscriptions(boolean sparse)
Sets whether sparse subscriptions are selected. |
void |
setSSLCertStores(java.util.Collection stores)
Provides a collection of CertStore objects used for certificate revocation list (CRL) checking. |
void |
setSSLCertStores(java.lang.String stores)
Specifies a list of LDAP servers used for certificate revocation list (CRL) checking. |
void |
setSSLCipherSuite(java.lang.String cipherSuite)
Sets the CipherSuite used for SSL encryption. |
void |
setSSLFipsRequired(boolean required)
Sets whether sslFips (FIPS) is required. |
void |
setSSLPeerName(java.lang.String peerName)
Sets a distinguished name (DN) pattern. |
void |
setSSLResetCount(int bytes)
Sets the SSL reset count. |
void |
setSSLSocketFactory(java.lang.Object sf)
Sets the SSLSocketFactory for use with SSL encryption. |
void |
setStatusRefreshInterval(int interval)
Sets the status refresh interval. |
void |
setSubscriptionStore(int flag)
Sets the SUBSTORE property. |
void |
setSyncpointAllGets(boolean flag)
Chooses whether to do all GET operations within a syncpoint. |
void |
setTargetClientMatching(boolean matchClient)
Enable or disable target client matching. |
void |
setTemporaryModel(java.lang.String queueName)
Sets the name of a model queue for creating temporary destinations. |
void |
setTempQPrefix(java.lang.String newTempQPrefix)
Sets the prefix to be used to form the name of a WebSphere MQ dynamic queue. |
void |
setTransportType(int type)
Sets the transport type. |
void |
setUseConnectionPooling(boolean usePooling)
Chooses whether to use connection pooling. |
Methods inherited from class java.lang.Object |
getClass, notify, notifyAll, toString, wait, wait, wait |
Constructor Detail |
public MQConnectionFactory()
Method Detail |
public int getVersion()
public java.lang.String getLocalAddress()
public void setLocalAddress(java.lang.String address) throws javax.jms.JMSException
address
- the local address to be used.
The format of a local address is [ip-addr][(low-port[,high-port])]
.
Here are some examples:
You can specify a host name instead of an IP address.
Specify a range of ports to allow for connections that are required internally as well as those explicitly used by an application. The number of ports required depends on the application and the facilities it uses. Typically, this is the number of sessions the application uses plus three or four additional ports. If an application is having difficulty making connections, increase the number of ports in the range.
Note that connection pooling has an effect on how quickly a port can be reused. In JMS, connection pooling is switched on by default and it might be some minutes before a port can be reused Connection errors might occur in the meantime.
For direct connections, the local address determines which of the local network interfaces is used for multicast connections. When specifying a local address for a direct connection, do not include a port number. A port number is not valid for multicast and, if specified, causes a failure at connect time.
javax.jms.JMSException
- if the format of the local address is incorrect.public java.util.Collection getHdrCompList()
public void setHdrCompList(java.util.Collection compList) throws javax.jms.JMSException
compList
- The Collection of header compression techniques to set.
The first item in the list to match the server list
becomes the current header compression technique.
javax.jms.JMSException
public java.util.Collection getMsgCompList()
public void setMsgCompList(java.util.Collection compList) throws javax.jms.JMSException
compList
- the Collection of message compression techniques to set.
The first item in the list to match the server list
becomes the current message compression technique.
javax.jms.JMSException
public byte[] getConnTag()
public void setConnTag(byte[] cTag)
cTag
- the connection tag. The value is truncated if it is longer than 128 bytes.public int getMQConnectionOptions()
public void setMQConnectionOptions(int cTagOpt) throws javax.jms.JMSException
cTagOpt
- an int representing the connection options.
Only one of the four options relating to connection tags
and any of the four options
relating to binding type can be set.
The only default option set is JMSC.MQCNO_STANDARD_BINDING.
javax.jms.JMSException
- if an option or a combination of set options is invalid.public int getFailIfQuiesce()
JMSC.MQJMS_FIQ_YES
(default)
JMSC.MQJMS_FIQ_NO
public void setFailIfQuiesce(int fiq) throws javax.jms.JMSException
fiq
- acceptable values are:
JMSC.MQJMS_FIQ_YES
(default)
JMSC.MQJMS_FIQ_NO
javax.jms.JMSException
- if fiq is neither of the above.public java.lang.String getDescription()
public void setDescription(java.lang.String desc)
desc
- the description.public int getTransportType()
public void setTransportType(int type) throws javax.jms.JMSException
type
- the transport type.
Valid types are:
javax.jms.JMSException
- if the transport is not one of the above.public java.lang.String getClientId()
public java.lang.String getClientID()
Note that this method always throws an IllegalStateException when you make a direct connection to a broker.
public void setClientId(java.lang.String id)
setClientID()
instead.
id
- the client ID.public void setClientID(java.lang.String id)
Note that this method always throws an IllegalStateException when you make a direct connection to a broker.
id
- the client ID.public java.lang.String getQueueManager()
setQueueManager(String)
public void setQueueManager(java.lang.String queueManagerName) throws javax.jms.JMSException
queueManagerName
- the queue manager which is used when selecting a channel definition.
This can be in of the following forms:
javax.jms.JMSException
- if queueManagerName is either null or too long.public void setHostName(java.lang.String hostname)
hostname
- the name of the host.public java.lang.String getHostName()
public void setPort(int port) throws javax.jms.JMSException
port
- the new value to use.
javax.jms.JMSException
- if port is not a permitted value.public int getPort()
public void setCCDTURL(java.net.URL url)
url
- the address of the client channel definition table.public java.net.URL getCCDTURL()
public void setChannel(java.lang.String channelName) throws javax.jms.JMSException
channelName
- the name of the channel.
javax.jms.JMSException
- if channelName is either null or too long.public java.lang.String getChannel()
public void setCCSID(int ccsid) throws javax.jms.JMSException
ccsid
- the CCSID.
The default value (819) is suitable in most situations.
javax.jms.JMSException
- if the value of ccsid is not permitted.public int getCCSID()
public void setReceiveExit(java.lang.String receiveExit)
receiveExit
- either the name of the class or a String in the form
library(entryPoint) where 'library' is the name of the module where the code
resides and 'entryPoint' is the entry point.public java.lang.String getReceiveExit()
public void setReceiveExitInit(java.lang.String data)
data
- the initialization string.public java.lang.String getReceiveExitInit()
public void setSecurityExit(java.lang.String securityExit)
securityExit
- either the name of the class or a String in the form
library(entryPoint) where 'library' is the name of the module where the code
resides and 'entryPoint' is the entry point.public java.lang.String getSecurityExit()
public void setSecurityExitInit(java.lang.String data)
data
- the initialization string.public java.lang.String getSecurityExitInit()
public void setSendExit(java.lang.String sendExit)
sendExit
- either the name of the class or a String in the form
library(entryPoint) where 'library' is the name of the module where the code
resides and 'entryPoint' is the entry point.public java.lang.String getSendExit()
public void setSendExitInit(java.lang.String data)
data
- either the name of the class or a String in the form
library(entryPoint) where 'library' is the name of the module where the code
resides and 'entryPoint' is the entry point.public java.lang.String getSendExitInit()
public void setSyncpointAllGets(boolean flag)
flag
- true means that all GETs are to be done under syncpoint.
The default is false which allows GET operations that are not under transaction
management to perform more quickly.public boolean getSyncpointAllGets()
public void setUseConnectionPooling(boolean usePooling)
usePooling
- true selects connection pooling.
The default, and recommended, value is true.
You can disable connection pooling if, for example, your applications run in
an environment that performs its own pooling.public boolean getUseConnectionPooling()
public void setMsgBatchSize(int size) throws javax.jms.JMSException
size
- the maximum number of messages to be taken at once when using
asynchronous delivery.
javax.jms.JMSException
public int getMsgBatchSize()
public void setPollingInterval(int interval) throws javax.jms.JMSException
interval
- the interval in milliseconds.
javax.jms.JMSException
public int getPollingInterval()
public void setRescanInterval(int interval) throws javax.jms.JMSException
interval
- the interval in milliseconds.
javax.jms.JMSException
public int getRescanInterval()
public void setMapNameStyle(boolean style)
style
- possible values are:
public boolean getMapNameStyle()
public void setSSLPeerName(java.lang.String peerName) throws javax.jms.JMSException
peerName
- the DN pattern.
If set to null (the default), no checking of the queue manager's DN pattern is performed.
This property is ignored if sslCipherSuite is null.
javax.jms.JMSException
- if the supplied pattern is not valid.public java.lang.String getSSLPeerName()
public void setSSLCipherSuite(java.lang.String cipherSuite)
cipherSuite
- the CipherSuite used for SSL encryption.
If set to null (the default), no SSL encryption is performed.public java.lang.String getSSLCipherSuite()
public void setSSLCertStores(java.util.Collection stores)
You must make sure that your Java Software Development Kit (SDK) is compatible with the CRL to use CertStore successfully with a CRL hosted on an LDAP server. Some SDKs require that the CRL conforms to RFC 2587, which defines a schema for LDAP v2. Most LDAP v3 servers use RFC 2256 instead.
stores
- the CRL - a list of CertStore objects
which contain certificates that have been revoked.
Null (the default) means that no checking of the queue manager's certificate is performed.public void setSSLCertStores(java.lang.String stores) throws javax.jms.JMSException
stores
- this String must consist of a sequence of space-delimited LDAP
URIs of the form ldap://host[:port].
If no port is specified, the LDAP default of 389 is assumed.
If set to null (the default), no checking of the queue manager's certificate is performed.
javax.jms.JMSException
- if the ConnectionFactory supplied list of LDAP URIs is not valid.setSSLCertStores(Collection)
public java.util.Collection getSSLCertStores() throws javax.jms.JMSException
setSSLCertStores()
was used to set a
collection of CertStore objects or a String specifying such a list.
javax.jms.JMSException
- if an unsupported type or bad value is encountered.public java.lang.String getSSLCertStoresAsString() throws javax.jms.JMSException
setSSLCertStores()
set it as a String in the first place.
javax.jms.JMSException
- if the CertStore objects were provided as a Collection.public void setSSLSocketFactory(java.lang.Object sf)
sf
- the SSLSocketFactory object.
If set to null (default), the JSSE default SSLSocketFactory is used when SSL encryption
is requested.
This property is ignored if sslCipherSuite is null.public java.lang.Object getSSLSocketFactory()
public void setTemporaryModel(java.lang.String queueName) throws javax.jms.JMSException
queueName
- the name of the model queue.
If it refers to a permanent dynamic model queue then you must call the
MQTemporaryQueue.delete()
method
to destroy the queue after use.
javax.jms.JMSException
- if queueName is either null or too long.public java.lang.String getTemporaryModel() throws javax.jms.JMSException
MQTemporaryQueue.delete()
method
to destroy the queue after use.
javax.jms.JMSException
- if an internal error occurs.public void setMessageRetention(int mRet) throws javax.jms.JMSException
mRet
- possible values are:
javax.jms.JMSException
- if mRet is not one of the above.public int getMessageRetention() throws javax.jms.JMSException
javax.jms.JMSException
- if an internal error occurs.public java.lang.String getTempQPrefix() throws javax.jms.JMSException
javax.jms.JMSException
- if an internal error occurs.public void setTempQPrefix(java.lang.String newTempQPrefix) throws javax.jms.JMSException
newTempQPrefix
- the prefix to be used to form the name of a WebSphere
MQ dynamic queue. This must end with the ’*’ character.
javax.jms.JMSException
- if the string is null, empty, greater than 33 characters in length,
consists solely of a single character, or ends with a character other than ’*’.public void setBrokerControlQueue(java.lang.String queueName) throws javax.jms.JMSException
queueName
- the name of the broker control queue.
javax.jms.JMSException
- if the name is either null or invalid.public java.lang.String getBrokerControlQueue() throws javax.jms.JMSException
javax.jms.JMSException
- if an internal error occurs.public void setBrokerQueueManager(java.lang.String queueManagerName) throws javax.jms.JMSException
queueManagerName
- the name of the queue manager.
javax.jms.JMSException
- if queueManagerName is either null or invalid.public java.lang.String getBrokerQueueManager() throws javax.jms.JMSException
javax.jms.JMSException
- if an internal error occurs.public void setBrokerPubQueue(java.lang.String queueName) throws javax.jms.JMSException
queueName
- the name of the publish queue.
javax.jms.JMSException
- if queueName is either null or invalid.public java.lang.String getBrokerPubQueue() throws javax.jms.JMSException
javax.jms.JMSException
- if an internal error occurs.public java.lang.String getBrokerSubQueue() throws javax.jms.JMSException
javax.jms.JMSException
- if an internal error occurs.public void setBrokerSubQueue(java.lang.String queueName) throws javax.jms.JMSException
queueName
- the name of the queue.
javax.jms.JMSException
- if queueName is either null or invalid.public java.lang.String getBrokerCCSubQueue() throws javax.jms.JMSException
javax.jms.JMSException
- if an internal error occurs.public void setBrokerCCSubQueue(java.lang.String queueName) throws javax.jms.JMSException
queueName
- the name of queue.
javax.jms.JMSException
- if queueName is either null or invalid.public int getBrokerVersion() throws javax.jms.JMSException
javax.jms.JMSException
- if an internal error occurs.public void setBrokerVersion(int version) throws javax.jms.JMSException
version
- possible values are:
javax.jms.JMSException
- if version is invalid.public int getMessageSelection() throws javax.jms.JMSException
javax.jms.JMSException
- if an internal error occurs.public void setMessageSelection(int selection) throws javax.jms.JMSException
selection
- possible values are:
javax.jms.JMSException
- if selection is not one of the above.public int getPubAckInterval() throws javax.jms.JMSException
javax.jms.JMSException
- if an internal error occurs.public void setPubAckInterval(int interval) throws javax.jms.JMSException
interval
- the number of messages to use as an interval.
The default is 25.
javax.jms.JMSException
- if an internal error occurs.public int getStatusRefreshInterval() throws javax.jms.JMSException
javax.jms.JMSException
- if an internal error occurs.public void setStatusRefreshInterval(int interval) throws javax.jms.JMSException
interval
- the time between transactions to refresh
publish/subscribe status (milliseconds).
javax.jms.JMSException
- if an internal error occurs.public void setSubscriptionStore(int flag) throws javax.jms.JMSException
flag
- an integer which represents a valid values of the SUBSTORE property:
javax.jms.JMSException
- if flag is not one of the above.public int getSubscriptionStore() throws javax.jms.JMSException
javax.jms.JMSException
- if an internal error occurs.public void setCleanupLevel(int level) throws javax.jms.JMSException
level
- permitted levels are:
javax.jms.JMSException
- if level is not as listed above.public int getCleanupLevel() throws javax.jms.JMSException
javax.jms.JMSException
- if an internal error occurs.public void setCleanupInterval(long interval) throws javax.jms.JMSException
interval
- the clean up interval (milliseconds).
javax.jms.JMSException
- if interval is either null or too long.public long getCleanupInterval() throws javax.jms.JMSException
javax.jms.JMSException
- if an internal error occurs.public void setCloneSupport(int type) throws javax.jms.JMSException
type
- supported values are:
javax.jms.JMSException
- if type is not one of the above.public int getCloneSupport() throws javax.jms.JMSException
javax.jms.JMSException
- if an internal error occurs.public void setSparseSubscriptions(boolean sparse) throws javax.jms.JMSException
sparse
- true indicates that sparse subscriptions are selected.
This might be required if an application using sparse subscriptions
fails to receive messages because of log overflow.
If you set the attribute to true, the application must be able to open the consumer
queue for browsing messages.
The default value of this attribute is false.
javax.jms.JMSException
- if an internal error occurs.public boolean getSparseSubscriptions() throws javax.jms.JMSException
javax.jms.JMSException
- if an internal error occurs.public void setMulticast(int multicast) throws javax.jms.JMSException
multicast
- the following values are possible:
javax.jms.JMSException
- if multicast does not belong to the above.public int getMulticast() throws javax.jms.JMSException
javax.jms.JMSException
- if an internal error occurs.public void setProxyHostName(java.lang.String hostName) throws javax.jms.JMSException
hostName
- the host name of the proxy server when establishing a direct
connection, or null if no proxy server is used.
javax.jms.JMSException
- if an internal error occurs.public java.lang.String getProxyHostName() throws javax.jms.JMSException
javax.jms.JMSException
- if an internal error occurs.public void setProxyPort(int proxyPort) throws javax.jms.JMSException
proxyPort
- the port number of the proxy server when establishing a direct connection.
javax.jms.JMSException
- if an internal error occurs.public int getProxyPort() throws javax.jms.JMSException
javax.jms.JMSException
- if an internal error occurs.public void setDirectAuth(int authority) throws javax.jms.JMSException
authority
- one of the following:
javax.jms.JMSException
- if authority is neither of the above.public int getDirectAuth() throws javax.jms.JMSException
javax.jms.JMSException
- if an internal error occurs.public boolean getTargetClientMatching()
setTargetClientMatching(boolean)
public void setTargetClientMatching(boolean matchClient)
If this field is set to false, then replies will always contain an RFH2 header, even though the receiver might not understand the reply.
Note that this applies only to point-to-point destinations. This field is set
to true
by default.
matchClient
- a boolean indicating whether to enable or disable target client matching.public int getReceiveIsolation() throws javax.jms.JMSException
javax.jms.JMSException
public void setReceiveIsolation(int newVal) throws javax.jms.JMSException
newVal
- one of these values:
javax.jms.JMSException
public boolean getOutcomeNotification() throws javax.jms.JMSException
javax.jms.JMSException
public void setOutcomeNotification(boolean newVal) throws javax.jms.JMSException
newVal
- true if MessageConsumers are to be informed,
false if not.
javax.jms.JMSException
public int getProcessDuration() throws javax.jms.JMSException
javax.jms.JMSException
public void setProcessDuration(int newVal) throws javax.jms.JMSException
newVal
- the process duration (milliseconds).
javax.jms.JMSException
public boolean getOptimisticPublication() throws javax.jms.JMSException
javax.jms.JMSException
public void setOptimisticPublication(boolean newVal) throws javax.jms.JMSException
newVal
- true requires the MessageProducer to wait until the message has completed delivery
false allows the send() or publish() method to return more promptly .
This is particularly useful if a MessageConsumer might be receiving uncommitted messages,
however it does mean that the MessageProducer will not be informed of a delivery failure
until it attempts to commit its sent messages.
javax.jms.JMSException
public javax.naming.Reference getReference() throws javax.naming.NamingException
getReference
in interface javax.naming.Referenceable
javax.naming.NamingException
- if there is a naming problem.public void setSSLResetCount(int bytes) throws javax.jms.JMSException
bytes
- the reset count. This must be an integer, with a value
between 0 (disabled) and 999 999 999.
javax.jms.JMSException
- if bytes is not within the valid range.public int getSSLResetCount()
public boolean getSSLFipsRequired()
public void setSSLFipsRequired(boolean required)
required
- true indicates FIPS is required.public javax.jms.Connection createConnection() throws javax.jms.JMSException
createConnection
in interface javax.jms.ConnectionFactory
javax.jms.JMSException
- if the JMS provider fails to create the
connection due to some internal error.
JMSSecurityException
- if client authentication fails
due to an invalid user name or password.public javax.jms.Connection createConnection(java.lang.String userName, java.lang.String password) throws javax.jms.JMSException
createConnection
in interface javax.jms.ConnectionFactory
userName
- the caller's user name.password
- the caller's password.
javax.jms.JMSException
- if the JMS provider fails to create the
connection due to some internal error.
JMSSecurityException
- if client authentication fails
due to an invalid user name or password.
|
(c) Copyright IBM Corp. 2005. All Rights Reserved. | |||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |