public class SonicMQVendorAdapter extends BeanVendorAdapter
Modifier and Type | Field and Description |
---|---|
static java.lang.String |
BROKER_URL
SonicConnectionFactory parameter valid for either domain. |
static java.lang.String |
CONNECT_ID
SonicConnectionFactory parameter valid for either domain. |
static java.lang.String |
CONNECTION_URLS
SonicConnectionFactory parameter valid for either domain. |
static java.lang.String |
DEFAULT_PASSWORD
SonicConnectionFactory parameter valid for either domain. |
static java.lang.String |
DEFAULT_USERNAME
SonicConnectionFactory parameter valid for either domains. |
static java.lang.String |
LOAD_BALANCING
SonicConnectionFactory parameter valid for either domain. |
static java.lang.String |
MONITOR_INTERVAL
SonicConnectionFactory parameter valid for either domain. |
static java.lang.String |
PERSISTENT_DELIVERY
SonicConnectionFactory parameter valid for either domain. |
static java.lang.String |
PING_INTERVAL
SonicConnectionFactory parameter valid for either domain. |
static java.lang.String |
PREFETCH_COUNT
SonicConnectionFactory parameter valid for the PTP domain. |
static java.lang.String |
PREFETCH_THRESHOLD
SonicConnectionFactory parameter valid for the PTP domain. |
static java.lang.String |
RECONNECT_INTERVAL
SonicConnectionFactory parameter valid for either domain. |
static java.lang.String |
RECONNECT_TIMEOUT
SonicConnectionFactory parameter valid for either domain. |
static java.lang.String |
SELECTOR_AT_BROKER
SonicConnectionFactory parameter valid for the PubSub domain. |
static java.lang.String |
SEQUENTIAL
SonicConnectionFactory parameter valid for either domain. |
CONNECTION_FACTORY_CLASS
CONNECT_ACTION, ON_EXCEPTION_ACTION, RECEIVE_ACTION, SEND_ACTION, SUBSCRIBE_ACTION
Constructor and Description |
---|
SonicMQVendorAdapter() |
Modifier and Type | Method and Description |
---|---|
void |
addVendorConnectionFactoryProperties(JMSURLHelper jmsurl,
java.util.HashMap cfProps)
Extract Sonic-specific properties from the JMS URL
|
QueueConnectionFactory |
getQueueConnectionFactory(java.util.HashMap cfConfig) |
TopicConnectionFactory |
getTopicConnectionFactory(java.util.HashMap cfConfig) |
boolean |
isConnectionDropped(JMSException jmse) |
boolean |
isMatchingConnectionFactory(javax.jms.ConnectionFactory cf,
JMSURLHelper jmsurl,
java.util.HashMap cfProps)
Check that the attributes of the candidate connection factory match the
requested connection factory properties.
|
boolean |
isRecoverable(java.lang.Throwable thrown,
int action) |
getJMSConnectionFactoryProperties, getJMSConnectorProperties, getQueue, getTopic, getVendorId, setProperties, setupApplicationProperties, setupMessageContext
public static final java.lang.String BROKER_URL
SonicConnectionFactory
parameter valid for either domain. This should
be used as a key in the environment map passed into calls to
createConnector
in JMSConnectorFactory
.
This is a required property.
The value must be a java.lang.String
See the SonicMQ documentation for information on this propertypublic static final java.lang.String DEFAULT_USERNAME
SonicConnectionFactory
parameter valid for either domains. This should
be used as a key in the environment map passed into calls to
createConnector
in JMSConnectorFactory
This is a required property for secure brokers.
The value must be a java.lang.String
See the SonicMQ documentation for information on this propertypublic static final java.lang.String DEFAULT_PASSWORD
SonicConnectionFactory
parameter valid for either domain. This should
be used as a key in the environment map passed into calls to
createConnector
in JMSConnectorFactory
This is a required property for secure brokers.
The value must be a java.lang.String
See the SonicMQ documentation for information on this propertypublic static final java.lang.String PING_INTERVAL
SonicConnectionFactory
parameter valid for either domain. This should
be used as a key in the environment map passed into calls to
createConnector
in JMSConnectorFactory
The value must be a java.lang.Long
See the SonicMQ documentation for information on this propertypublic static final java.lang.String RECONNECT_INTERVAL
SonicConnectionFactory
parameter valid for either domain. This should
be used as a key in the environment map passed into calls to
createConnector
in JMSConnectorFactory
The value must be a java.lang.Integer
See the SonicMQ documentation for information on this propertypublic static final java.lang.String RECONNECT_TIMEOUT
SonicConnectionFactory
parameter valid for either domain. This should
be used as a key in the environment map passed into calls to
createConnector
in JMSConnectorFactory
The value must be a java.lang.Integer
See the SonicMQ documentation for information on this propertypublic static final java.lang.String CONNECT_ID
SonicConnectionFactory
parameter valid for either domain. This should
be used as a key in the environment map passed into calls to
createConnector
in JMSConnectorFactory
The value must be a java.lang.String
See the SonicMQ documentation for information on this propertypublic static final java.lang.String CONNECTION_URLS
SonicConnectionFactory
parameter valid for either domain. This should
be used as a key in the environment map passed into calls to
createConnector
in JMSConnectorFactory
The value must be a java.lang.String
See the SonicMQ documentation for information on this propertypublic static final java.lang.String LOAD_BALANCING
SonicConnectionFactory
parameter valid for either domain. This should
be used as a key in the environment map passed into calls to
createConnector
in JMSConnectorFactory
The value must be a java.lang.Boolean
See the SonicMQ documentation for information on this propertypublic static final java.lang.String MONITOR_INTERVAL
SonicConnectionFactory
parameter valid for either domain. This should
be used as a key in the environment map passed into calls to
createConnector
in JMSConnectorFactory
The value must be a java.lang.Long
See the SonicMQ documentation for information on this propertypublic static final java.lang.String PERSISTENT_DELIVERY
SonicConnectionFactory
parameter valid for either domain. This should
be used as a key in the environment map passed into calls to
createConnector
in JMSConnectorFactory
The value must be a java.lang.Boolean
See the SonicMQ documentation for information on this propertypublic static final java.lang.String SEQUENTIAL
SonicConnectionFactory
parameter valid for either domain. This should
be used as a key in the environment map passed into calls to
createConnector
in JMSConnectorFactory
The value must be a java.lang.Boolean
See the SonicMQ documentation for information on this propertypublic static final java.lang.String PREFETCH_COUNT
SonicConnectionFactory
parameter valid for the PTP domain. This should
be used as a key in the environment map passed into calls to
createConnector
in JMSConnectorFactory
The value must be a java.lang.Integer
See the SonicMQ documentation for information on this propertypublic static final java.lang.String PREFETCH_THRESHOLD
SonicConnectionFactory
parameter valid for the PTP domain. This should
be used as a key in the environment map passed into calls to
createConnector
in JMSConnectorFactory
The value must be a java.lang.Integer
See the SonicMQ documentation for information on this propertypublic static final java.lang.String SELECTOR_AT_BROKER
SonicConnectionFactory
parameter valid for the PubSub domain. This should
be used as a key in the environment map passed into calls to
createConnector
in JMSConnectorFactory
The value must be a java.lang.Boolean
See the SonicMQ documentation for information on this propertypublic QueueConnectionFactory getQueueConnectionFactory(java.util.HashMap cfConfig) throws java.lang.Exception
getQueueConnectionFactory
in class BeanVendorAdapter
java.lang.Exception
public TopicConnectionFactory getTopicConnectionFactory(java.util.HashMap cfConfig) throws java.lang.Exception
getTopicConnectionFactory
in class BeanVendorAdapter
java.lang.Exception
public void addVendorConnectionFactoryProperties(JMSURLHelper jmsurl, java.util.HashMap cfProps)
addVendorConnectionFactoryProperties
in class JMSVendorAdapter
jmsurl
- The JMS URL representing the target endpoint addresscfProps
- The set of connection factory configuration propertiespublic boolean isMatchingConnectionFactory(javax.jms.ConnectionFactory cf, JMSURLHelper jmsurl, java.util.HashMap cfProps)
isMatchingConnectionFactory
in class JMSVendorAdapter
cf
- the candidate connection factoryjmsurl
- the JMS URL associated with the candidate connection factorycfProps
- the properties associated with the current requestpublic boolean isRecoverable(java.lang.Throwable thrown, int action)
isRecoverable
in class JMSVendorAdapter
public boolean isConnectionDropped(JMSException jmse)
Copyright © 2005 Apache Web Services Project. All Rights Reserved.