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.
Modifier and Type | Class and Description |
---|---|
static class |
AdvancedActiveMqImplementation.ConnectionFactoryProperty
Non-Exhaustive list that matches various ActiveMQConnectionFactory methods.
|
log
Constructor and Description |
---|
AdvancedActiveMqImplementation() |
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.
|
createConnectionFactory
connectionEquals, getBrokerUrl, retrieveBrokerDetailsForLogging, setBrokerUrl
applyVendorSessionProperties, createConsumer, createDestination, createQueue, createQueueReceiver, createSession, createTopic, createTopicSubscriber, prepare
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
createConnection
createConsumer, createDestination, createQueue, createQueueReceiver, createQueueReceiver, createSession, createTopic, createTopicSubscriber, createTopicSubscriber, retrieveBrokerDetailsForLogging
prepare
connectionEquals
protected org.apache.activemq.ActiveMQConnectionFactory create(java.lang.String url)
create
in class BasicActiveMqImplementation
public KeyValuePairSet getConnectionFactoryProperties()
public void setConnectionFactoryProperties(KeyValuePairSet kvps)
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.
kvps
- the additional connectionFactoryProperties to setpublic BlobTransferPolicyFactory getBlobTransferPolicy()
BlobTransferPolicy
,
BlobTransferPolicyFactory
public void setBlobTransferPolicy(BlobTransferPolicyFactory f)
If not explicitly configured then the associated setter
ActiveMQConnectionFactory.setBlobTransferPolicy(org.apache.activemq.blob.BlobTransferPolicy)
is never invoked.
f
- the Blob Transfer Policy.BlobTransferPolicy
,
BlobTransferPolicyFactory
public PrefetchPolicyFactory getPrefetchPolicy()
ActiveMQPrefetchPolicy
,
PrefetchPolicyFactory
public void setPrefetchPolicy(PrefetchPolicyFactory f)
If not explicitly configured then the associated setter
ActiveMQConnectionFactory.setPrefetchPolicy(org.apache.activemq.ActiveMQPrefetchPolicy)
is never invoked.
f
- the PrefetchPolicy.ActiveMQPrefetchPolicy
,
PrefetchPolicyFactory
public RedeliveryPolicyFactory getRedeliveryPolicy()
RedeliveryPolicy
,
RedeliveryPolicyFactory
public void setRedeliveryPolicy(RedeliveryPolicyFactory f)
If not explicitly configured then the associated setter
ActiveMQConnectionFactory.setRedeliveryPolicy(org.apache.activemq.RedeliveryPolicy)
is
never invoked.
f
- the redelivery Policy.RedeliveryPolicy
,
RedeliveryPolicyFactory