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

public class BasicSolaceImplementation
extends UrlVendorImplementation

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

Constructors

Constructor	Description
BasicSolaceImplementation()

Method Summary

Modifier and Type	Method	Description
boolean	connectionEquals(VendorImplementationBase other)
com.solacesystems.jms.SolConnectionFactory	createConnectionFactory()
javax.jms.MessageConsumer	createConsumer(JmsDestination d, java.lang.String selector, JmsActorConfig c)
java.lang.Integer	createConsumerMaxRetries()
java.lang.Integer	createConsumerRetryWaitSeconds()
javax.jms.MessageConsumer	createQueueReceiver(java.lang.String queueName, java.lang.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(java.lang.String topicName, java.lang.String selector, java.lang.String subscriptionId, JmsActorConfig c)
java.lang.Integer	getCreateConsumerMaxRetries()	Sets the maximum amount of times to retry attempting to create the message consumer.
java.lang.Integer	getCreateConsumerRetryWaitSeconds()	Sets the amount of time in seconds to wait before each attempt to create the message consumer.
@NotNull java.lang.String	getMessageVpn()	Message VPN name.
void	prepare()
java.lang.String	retrieveBrokerDetailsForLogging()
void	setCreateConsumerMaxRetries(java.lang.Integer createConsumerMaxRetries)	Sets the maximum amount of times to retry attempting to create the message consumer.
void	setCreateConsumerRetryWaitSeconds(java.lang.Integer createConsumerRetryWaitSeconds)	Sets the amount of time in seconds to wait before each attempt to create the message consumer.
void	setMessageVpn(@NotNull java.lang.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 Detail

BasicSolaceImplementation

public BasicSolaceImplementation()

Method Detail

createConnectionFactory

public com.solacesystems.jms.SolConnectionFactory createConnectionFactory()
                                                                   throws javax.jms.JMSException

Throws:

javax.jms.JMSException

retrieveBrokerDetailsForLogging

public java.lang.String retrieveBrokerDetailsForLogging()

Specified by:

retrieveBrokerDetailsForLogging in interface VendorImplementationBase

Overrides:

retrieveBrokerDetailsForLogging in class UrlVendorImplementation

createQueueReceiver

public javax.jms.MessageConsumer createQueueReceiver(java.lang.String queueName,
                                                     java.lang.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 interface VendorImplementationBase

Overrides:

createQueueReceiver in class VendorImplementationImp

Throws:

javax.jms.JMSException

See Also:

VendorImplementationBase.createQueue(java.lang.String, JmsActorConfig)

createConsumer

public javax.jms.MessageConsumer createConsumer(JmsDestination d,
                                                java.lang.String selector,
                                                JmsActorConfig c)
                                         throws javax.jms.JMSException

Specified by:

createConsumer in interface VendorImplementationBase

Overrides:

createConsumer in class VendorImplementationImp

Throws:

javax.jms.JMSException

createTopicSubscriber

public javax.jms.MessageConsumer createTopicSubscriber(java.lang.String topicName,
                                                       java.lang.String selector,
                                                       java.lang.String subscriptionId,
                                                       JmsActorConfig c)
                                                throws javax.jms.JMSException

Specified by:

createTopicSubscriber in interface VendorImplementationBase

Overrides:

createTopicSubscriber in class VendorImplementationImp

Throws:

javax.jms.JMSException

connectionEquals

public boolean connectionEquals(VendorImplementationBase other)

Specified by:

connectionEquals in interface ConnectionComparator<VendorImplementationBase>

Overrides:

connectionEquals in class UrlVendorImplementation

prepare

public void prepare()
             throws CoreException

Specified by:

prepare in interface ComponentLifecycleExtension

Overrides:

prepare in class VendorImplementationImp

Throws:

CoreException

createConsumerRetryWaitSeconds

public java.lang.Integer createConsumerRetryWaitSeconds()

createConsumerMaxRetries

public java.lang.Integer createConsumerMaxRetries()

getCreateConsumerRetryWaitSeconds

public java.lang.Integer getCreateConsumerRetryWaitSeconds()

Sets the amount of time in seconds to wait before each attempt to create the message consumer.

setCreateConsumerRetryWaitSeconds

public void setCreateConsumerRetryWaitSeconds(java.lang.Integer createConsumerRetryWaitSeconds)

Sets the amount of time in seconds to wait before each attempt to create the message consumer.

getCreateConsumerMaxRetries

public java.lang.Integer getCreateConsumerMaxRetries()

Sets the maximum amount of times to retry attempting to create the message consumer.

A value of zero means continue trying forever

setCreateConsumerMaxRetries

public void setCreateConsumerMaxRetries(java.lang.Integer createConsumerMaxRetries)

Sets the maximum amount of times to retry attempting to create the message consumer.

A value of zero means continue trying forever

getMessageVpn

@NotNull
public @NotNull java.lang.String getMessageVpn()

Message VPN name. Default: default

setMessageVpn

public void setMessageVpn(@NotNull
                          @NotNull java.lang.String messageVpn)

Message VPN name. Default: default