Package com.adaptris.core.jms.solace
Class BasicSolaceImplementation
java.lang.Object
com.adaptris.core.jms.VendorImplementationImp
com.adaptris.core.jms.UrlVendorImplementation
com.adaptris.core.jms.solace.BasicSolaceImplementation
- All Implemented Interfaces:
ComponentLifecycleExtension
,ConnectionComparator<VendorImplementationBase>
,VendorImplementation
,VendorImplementationBase
- Direct Known Subclasses:
AdvancedSolaceImplementation
Solace implementation of VendorImplementation
.
This vendor implementation is the minimal adapter interface to Solace.
This was built against Solace 10.6.0
In the adapter configuration file this class is aliased as basic-solace-implementation which is the preferred alternative to the fully qualified classname when building your configuration.
License Required: BASIC
-
Field Summary
Fields inherited from class com.adaptris.core.jms.VendorImplementationImp
log
-
Constructor Summary
-
Method Summary
Modifier and TypeMethodDescriptionboolean
com.solacesystems.jms.SolConnectionFactory
javax.jms.MessageConsumer
createConsumer
(JmsDestination d, String selector, JmsActorConfig c) javax.jms.MessageConsumer
createQueueReceiver
(String queueName, String selector, JmsActorConfig c) If a Solace queue has been shutdown, we should wait for it to come back up before we continue.javax.jms.MessageConsumer
createTopicSubscriber
(String topicName, String selector, String subscriptionId, JmsActorConfig c) Sets the maximum amount of times to retry attempting to create the message consumer.Sets the amount of time in seconds to wait before each attempt to create the message consumer.Message VPN name.void
prepare()
void
setCreateConsumerMaxRetries
(Integer createConsumerMaxRetries) Sets the maximum amount of times to retry attempting to create the message consumer.void
setCreateConsumerRetryWaitSeconds
(Integer createConsumerRetryWaitSeconds) Sets the amount of time in seconds to wait before each attempt to create the message consumer.void
setMessageVpn
(String messageVpn) Message VPN name.Methods inherited from class com.adaptris.core.jms.UrlVendorImplementation
getBrokerUrl, setBrokerUrl
Methods inherited from class com.adaptris.core.jms.VendorImplementationImp
applyVendorSessionProperties, createDestination, createQueue, createSession, createTopic
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
Methods inherited from interface com.adaptris.core.jms.VendorImplementation
createConnection
-
Constructor Details
-
BasicSolaceImplementation
public BasicSolaceImplementation()
-
-
Method Details
-
createConnectionFactory
public com.solacesystems.jms.SolConnectionFactory createConnectionFactory() throws javax.jms.JMSException- Throws:
javax.jms.JMSException
-
retrieveBrokerDetailsForLogging
- Specified by:
retrieveBrokerDetailsForLogging
in interfaceVendorImplementationBase
- Overrides:
retrieveBrokerDetailsForLogging
in classUrlVendorImplementation
-
createQueueReceiver
public javax.jms.MessageConsumer createQueueReceiver(String queueName, String selector, JmsActorConfig c) throws javax.jms.JMSException If a Solace queue has been shutdown, we should wait for it to come back up before we continue.
- Specified by:
createQueueReceiver
in interfaceVendorImplementationBase
- Overrides:
createQueueReceiver
in classVendorImplementationImp
- Throws:
javax.jms.JMSException
- See Also:
-
createConsumer
public javax.jms.MessageConsumer createConsumer(JmsDestination d, String selector, JmsActorConfig c) throws javax.jms.JMSException - Specified by:
createConsumer
in interfaceVendorImplementationBase
- Overrides:
createConsumer
in classVendorImplementationImp
- Throws:
javax.jms.JMSException
-
createTopicSubscriber
public javax.jms.MessageConsumer createTopicSubscriber(String topicName, String selector, String subscriptionId, JmsActorConfig c) throws javax.jms.JMSException - Specified by:
createTopicSubscriber
in interfaceVendorImplementationBase
- Overrides:
createTopicSubscriber
in classVendorImplementationImp
- Throws:
javax.jms.JMSException
-
connectionEquals
- Specified by:
connectionEquals
in interfaceConnectionComparator<VendorImplementationBase>
- Overrides:
connectionEquals
in classUrlVendorImplementation
-
prepare
- Specified by:
prepare
in interfaceComponentLifecycleExtension
- Overrides:
prepare
in classVendorImplementationImp
- Throws:
CoreException
-
createConsumerRetryWaitSeconds
-
createConsumerMaxRetries
-
getCreateConsumerRetryWaitSeconds
Sets the amount of time in seconds to wait before each attempt to create the message consumer. -
setCreateConsumerRetryWaitSeconds
Sets the amount of time in seconds to wait before each attempt to create the message consumer. -
getCreateConsumerMaxRetries
Sets the maximum amount of times to retry attempting to create the message consumer.
A value of zero means continue trying forever
-
setCreateConsumerMaxRetries
Sets the maximum amount of times to retry attempting to create the message consumer.
A value of zero means continue trying forever
-
getMessageVpn
Message VPN name. Default: default -
setMessageVpn
Message VPN name. Default: default
-