Package com.adaptris.core.amqp.rabbitmq

Class AdvancedRabbitMqJmsImplementation

java.lang.Object

com.adaptris.core.jms.VendorImplementationImp

com.adaptris.core.jms.UrlVendorImplementation

com.adaptris.core.amqp.rabbitmq.BasicRabbitMqJmsImplementation

com.adaptris.core.amqp.rabbitmq.AdvancedRabbitMqJmsImplementation

All Implemented Interfaces:

ComponentLifecycleExtension, ConnectionComparator<VendorImplementationBase>, VendorImplementation, VendorImplementationBase

public class AdvancedRabbitMqJmsImplementation
extends BasicRabbitMqJmsImplementation

AMQP 0.9.1 implementation of VendorImplementation using RabbitMQ.

All available connection factory properties are exposed. If you configure a username and password on the wrapping JmsConnection in which case ConnectionFactory.createConnection(String, String) is used when creating the connection otherwise ConnectionFactory.createConnection() will be used.

The enum values from AdvancedRabbitMqJmsImplementation.ConnectionFactoryProperty are matched on a case insensitve basis against the keys in getConnectionFactoryProperties() when configuring the RMQConnectionFactory. In the event that a key does not match one the enums, an attempt will be made to invoke (via reflection) the implied setter with the configured value (e.g. DnsServer=a.b.c.d would cause setDnsServer("a.b.c.d") to be invoked if it exists as a method on RMQConnectionFactory).

Since:

3.6.0

In the adapter configuration file this class is aliased as rabbitmq-advanced-jms-implementation which is the preferred alternative to the fully qualified classname when building your configuration.

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
protected static interface	AdvancedRabbitMqJmsImplementation.Applicator
static class	AdvancedRabbitMqJmsImplementation.ConnectionFactoryProperty	Connection Properties that map to RMQConnectionFactory setters.

Nested classes/interfaces inherited from class com.adaptris.core.amqp.rabbitmq.BasicRabbitMqJmsImplementation

BasicRabbitMqJmsImplementation.RMQDestinationBuilder

Field Summary

Fields inherited from class com.adaptris.core.amqp.rabbitmq.BasicRabbitMqJmsImplementation

DEFAULT_OM_TIMEOUT

Fields inherited from class com.adaptris.core.jms.VendorImplementationImp

log

Constructor Summary

Constructors

Constructor	Description
AdvancedRabbitMqJmsImplementation()

Method Summary

Modifier and Type	Method	Description
protected BasicRabbitMqJmsImplementation.RMQDestinationBuilder	builder()
com.rabbitmq.jms.admin.RMQConnectionFactory	createConnectionFactory()
@NonNull KeyValuePairSet	getConnectionFactoryProperties()	Any additional properties that are required on the RMQConnectionFactory.
java.lang.String	getExchangeName()	If BasicRabbitMqJmsImplementation.setAmqpMode(Boolean) is set to true, then additionally set the exchange name as well when creating the RMQDestination.
java.lang.String	getRoutingKey()	If BasicRabbitMqJmsImplementation.setAmqpMode(Boolean) is set to true, then additionally set the exchange name as well when creating the RMQDestination.
void	setConnectionFactoryProperties(@NonNull KeyValuePairSet connectionFactoryProperties)	Any additional properties that are required on the RMQConnectionFactory.
void	setExchangeName(java.lang.String exchangeName)	If BasicRabbitMqJmsImplementation.setAmqpMode(Boolean) is set to true, then additionally set the exchange name as well when creating the RMQDestination.
void	setRoutingKey(java.lang.String routingKey)	If BasicRabbitMqJmsImplementation.setAmqpMode(Boolean) is set to true, then additionally set the exchange name as well when creating the RMQDestination.

Methods inherited from class com.adaptris.core.amqp.rabbitmq.BasicRabbitMqJmsImplementation

amqpMode, connectionEquals, createDestination, createQueue, createTopic, getAmqpMode, setAmqpMode, withAmqpMode

Methods inherited from class com.adaptris.core.jms.UrlVendorImplementation

getBrokerUrl, retrieveBrokerDetailsForLogging, setBrokerUrl

Methods inherited from class com.adaptris.core.jms.VendorImplementationImp

applyVendorSessionProperties, createConsumer, createDestination, createQueueReceiver, createSession, createTopicSubscriber, prepare

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

AdvancedRabbitMqJmsImplementation

public AdvancedRabbitMqJmsImplementation()

Method Detail

createConnectionFactory

public com.rabbitmq.jms.admin.RMQConnectionFactory createConnectionFactory()
                                                                    throws javax.jms.JMSException

Specified by:

createConnectionFactory in interface VendorImplementation

Overrides:

createConnectionFactory in class BasicRabbitMqJmsImplementation

Throws:

javax.jms.JMSException

builder

protected BasicRabbitMqJmsImplementation.RMQDestinationBuilder builder()

Overrides:

builder in class BasicRabbitMqJmsImplementation

getConnectionFactoryProperties

@NonNull
public @NonNull KeyValuePairSet getConnectionFactoryProperties()

Any additional properties that are required on the RMQConnectionFactory.

See Also:

AdvancedRabbitMqJmsImplementation.ConnectionFactoryProperty

setConnectionFactoryProperties

public void setConnectionFactoryProperties(@NonNull
                                           @NonNull KeyValuePairSet connectionFactoryProperties)

Any additional properties that are required on the RMQConnectionFactory.

See Also:

AdvancedRabbitMqJmsImplementation.ConnectionFactoryProperty

getExchangeName

public java.lang.String getExchangeName()

If BasicRabbitMqJmsImplementation.setAmqpMode(Boolean) is set to true, then additionally set the exchange name as well when creating the RMQDestination.

Note that no validation is done on this value, and it is passed as-is into the constructor for RMQDestination.

setExchangeName

public void setExchangeName(java.lang.String exchangeName)

If BasicRabbitMqJmsImplementation.setAmqpMode(Boolean) is set to true, then additionally set the exchange name as well when creating the RMQDestination.

Note that no validation is done on this value, and it is passed as-is into the constructor for RMQDestination.

getRoutingKey

public java.lang.String getRoutingKey()

If BasicRabbitMqJmsImplementation.setAmqpMode(Boolean) is set to true, then additionally set the exchange name as well when creating the RMQDestination.

Note that no validation is done on this value, and it is passed as-is into the constructor for RMQDestination.

setRoutingKey

public void setRoutingKey(java.lang.String routingKey)

If BasicRabbitMqJmsImplementation.setAmqpMode(Boolean) is set to true, then additionally set the exchange name as well when creating the RMQDestination.

Note that no validation is done on this value, and it is passed as-is into the constructor for RMQDestination.