com.adaptris.core.jms.activemq

Class AdvancedActiveMqImplementation

java.lang.Object

com.adaptris.core.jms.VendorImplementationImp

com.adaptris.core.jms.UrlVendorImplementation

com.adaptris.core.jms.activemq.BasicActiveMqImplementation

com.adaptris.core.jms.activemq.AdvancedActiveMqImplementation

All Implemented Interfaces:

ComponentLifecycleExtension, ConnectionComparator<VendorImplementationBase>, VendorImplementation, VendorImplementationBase

public class AdvancedActiveMqImplementation
extends BasicActiveMqImplementation

ActiveMQ implementation of VendorImplementation.

This vendor implementation class directly exposes almost all the getter and setters that are available in the ConnectionFactory for maximum flexibility in configuration.

The key from the connection-factory-properties element should match the name of the underlying ActiveMQ ConnectionFactory property.

  
   <connection-factory-properties>
     <key-value-pair>
        <key>AlwaysSessionAsync</key>
        <value>true</value>
     </key-value-pair>
   </connection-factory-properties>
 
 

will invoke ActiveMQConnectionFactory.setAlwaysSessionAsync(boolean), setting the AlwaysSessionAsync property to true.

This was built against ActiveMQ 5.9.0

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

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	AdvancedActiveMqImplementation.ConnectionFactoryProperty Non-Exhaustive list that matches various ActiveMQConnectionFactory methods.

Field Summary

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

log

Constructor Summary

Constructors

Constructor and Description
AdvancedActiveMqImplementation()

Method Summary

Modifier and Type	Method and Description
protected org.apache.activemq.ActiveMQConnectionFactory	create(java.lang.String url)
BlobTransferPolicyFactory	getBlobTransferPolicy() Get the Blob Transfer Policy.
KeyValuePairSet	getConnectionFactoryProperties()
PrefetchPolicyFactory	getPrefetchPolicy() Get the Prefetch Policy.
RedeliveryPolicyFactory	getRedeliveryPolicy() Get the Redelivery Policy.
void	setBlobTransferPolicy(BlobTransferPolicyFactory f) Set the Blob Transfer Policy.
void	setConnectionFactoryProperties(KeyValuePairSet kvps) Set any additional ActiveMQConnectionFactory properties that are required.
void	setPrefetchPolicy(PrefetchPolicyFactory f) Set the Prefetch Policy.
void	setRedeliveryPolicy(RedeliveryPolicyFactory f) Set the Redelivery Policy.

Methods inherited from class com.adaptris.core.jms.activemq.BasicActiveMqImplementation

createConnectionFactory

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

connectionEquals, getBrokerUrl, retrieveBrokerDetailsForLogging, setBrokerUrl

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

applyVendorSessionProperties, createConsumer, createDestination, createQueue, createQueueReceiver, createSession, createTopic, 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

Methods inherited from interface com.adaptris.core.jms.VendorImplementationBase

createConsumer, createDestination, createQueue, createQueueReceiver, createQueueReceiver, createSession, createTopic, createTopicSubscriber, createTopicSubscriber, retrieveBrokerDetailsForLogging

Methods inherited from interface com.adaptris.core.ComponentLifecycleExtension

prepare

Methods inherited from interface com.adaptris.core.jms.ConnectionComparator

connectionEquals

Constructor Detail

AdvancedActiveMqImplementation

public AdvancedActiveMqImplementation()

Method Detail

create

protected org.apache.activemq.ActiveMQConnectionFactory create(java.lang.String url)

Overrides:

create in class BasicActiveMqImplementation

getConnectionFactoryProperties

public KeyValuePairSet getConnectionFactoryProperties()

Returns:

The additional connection factory properties.

setConnectionFactoryProperties

public void setConnectionFactoryProperties(KeyValuePairSet kvps)

Set any additional ActiveMQConnectionFactory properties that are required.

The key from the connection-factory-properties element should match the name of the underlying ActiveMQ ConnectionFactory property.

 
   <connection-factory-properties>
     <key-value-pair>
        <key>AlwaysSessionAsync</key>
        <value>true</value>
     </key-value-pair>
   </connection-factory-properties>
 
 

will invoke ActiveMQConnectionFactory.setAlwaysSessionAsync(boolean), setting the AlwaysSessionAsync property to true. Only explicitly configured properties will invoke the associated setter method.

Parameters:

kvps - the additional connectionFactoryProperties to set

getBlobTransferPolicy

public BlobTransferPolicyFactory getBlobTransferPolicy()

Get the Blob Transfer Policy.

Returns:

the Blob Transfer Policy.

See Also:

BlobTransferPolicy, BlobTransferPolicyFactory

setBlobTransferPolicy

public void setBlobTransferPolicy(BlobTransferPolicyFactory f)

Set the Blob Transfer Policy.

If not explicitly configured then the associated setter ActiveMQConnectionFactory.setBlobTransferPolicy(org.apache.activemq.blob.BlobTransferPolicy) is never invoked.

Parameters:

f - the Blob Transfer Policy.

See Also:

BlobTransferPolicy, BlobTransferPolicyFactory

getPrefetchPolicy

public PrefetchPolicyFactory getPrefetchPolicy()

Get the Prefetch Policy.

Returns:

the PrefetchPolicy.

See Also:

ActiveMQPrefetchPolicy, PrefetchPolicyFactory

setPrefetchPolicy

public void setPrefetchPolicy(PrefetchPolicyFactory f)

Set the Prefetch Policy.

If not explicitly configured then the associated setter ActiveMQConnectionFactory.setPrefetchPolicy(org.apache.activemq.ActiveMQPrefetchPolicy) is never invoked.

Parameters:

f - the PrefetchPolicy.

See Also:

ActiveMQPrefetchPolicy, PrefetchPolicyFactory

getRedeliveryPolicy

public RedeliveryPolicyFactory getRedeliveryPolicy()

Get the Redelivery Policy.

Returns:

the redelivery Policy.

See Also:

RedeliveryPolicy, RedeliveryPolicyFactory

setRedeliveryPolicy

public void setRedeliveryPolicy(RedeliveryPolicyFactory f)

Set the Redelivery Policy.

If not explicitly configured then the associated setter ActiveMQConnectionFactory.setRedeliveryPolicy(org.apache.activemq.RedeliveryPolicy) is never invoked.

Parameters:

f - the redelivery Policy.

See Also:

RedeliveryPolicy, RedeliveryPolicyFactory