public class SonicMQVendorAdapter extends BeanVendorAdapter
Modifier and Type | Field and Description |
---|---|
static String |
BROKER_URL
SonicConnectionFactory parameter valid for either domain. |
static String |
CONNECT_ID
SonicConnectionFactory parameter valid for either domain. |
static String |
CONNECTION_URLS
SonicConnectionFactory parameter valid for either domain. |
static String |
DEFAULT_PASSWORD
SonicConnectionFactory parameter valid for either domain. |
static String |
DEFAULT_USERNAME
SonicConnectionFactory parameter valid for either domains. |
static String |
LOAD_BALANCING
SonicConnectionFactory parameter valid for either domain. |
static String |
MONITOR_INTERVAL
SonicConnectionFactory parameter valid for either domain. |
static String |
PERSISTENT_DELIVERY
SonicConnectionFactory parameter valid for either domain. |
static String |
PING_INTERVAL
SonicConnectionFactory parameter valid for either domain. |
static String |
PREFETCH_COUNT
SonicConnectionFactory parameter valid for the PTP domain. |
static String |
PREFETCH_THRESHOLD
SonicConnectionFactory parameter valid for the PTP domain. |
static String |
RECONNECT_INTERVAL
SonicConnectionFactory parameter valid for either domain. |
static String |
RECONNECT_TIMEOUT
SonicConnectionFactory parameter valid for either domain. |
static String |
SELECTOR_AT_BROKER
SonicConnectionFactory parameter valid for the PubSub domain. |
static 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,
HashMap cfProps)
Extract Sonic-specific properties from the JMS URL
|
QueueConnectionFactory |
getQueueConnectionFactory(HashMap cfConfig) |
TopicConnectionFactory |
getTopicConnectionFactory(HashMap cfConfig) |
boolean |
isConnectionDropped(JMSException jmse) |
boolean |
isMatchingConnectionFactory(ConnectionFactory cf,
JMSURLHelper jmsurl,
HashMap cfProps)
Check that the attributes of the candidate connection factory match the
requested connection factory properties.
|
boolean |
isRecoverable(Throwable thrown,
int action) |
getJMSConnectionFactoryProperties, getJMSConnectorProperties, getQueue, getTopic, getVendorId, setProperties, setupApplicationProperties, setupMessageContext
public static final 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 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 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 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 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 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 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 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 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 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 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 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 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 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 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(HashMap cfConfig) throws Exception
getQueueConnectionFactory
in class BeanVendorAdapter
Exception
public TopicConnectionFactory getTopicConnectionFactory(HashMap cfConfig) throws Exception
getTopicConnectionFactory
in class BeanVendorAdapter
Exception
public void addVendorConnectionFactoryProperties(JMSURLHelper jmsurl, HashMap cfProps)
addVendorConnectionFactoryProperties
in class JMSVendorAdapter
jmsurl
- The JMS URL representing the target endpoint addresscfProps
- The set of connection factory configuration propertiespublic boolean isMatchingConnectionFactory(ConnectionFactory cf, JMSURLHelper jmsurl, 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(Throwable thrown, int action)
isRecoverable
in class JMSVendorAdapter
public boolean isConnectionDropped(JMSException jmse)
Copyright © The Apache Software Foundation. All Rights Reserved.