org.apache.activemq.ra
Class ActiveMQActivationSpec

java.lang.Object
  extended by org.apache.activemq.ra.ActiveMQActivationSpec
All Implemented Interfaces:
java.io.Serializable, javax.resource.spi.ActivationSpec, javax.resource.spi.ResourceAdapterAssociation

public class ActiveMQActivationSpec
extends java.lang.Object
implements javax.resource.spi.ActivationSpec, java.io.Serializable

Configures the inbound JMS consumer specification using ActiveMQ

Version:
$Revision$ $Date$
See Also:
Serialized Form

Field Summary
static java.lang.String AUTO_ACKNOWLEDGE_MODE
          Auto-acknowledge constant for acknowledgeMode property
static java.lang.String DUPS_OK_ACKNOWLEDGE_MODE
          Dups-ok-acknowledge constant for acknowledgeMode property *
static java.lang.String DURABLE_SUBSCRIPTION
          Durable constant for subscriptionDurability property *
static int INVALID_ACKNOWLEDGE_MODE
           
static java.lang.String NON_DURABLE_SUBSCRIPTION
          NonDurable constant for subscriptionDurability property *
 
Constructor Summary
ActiveMQActivationSpec()
           
 
Method Summary
 ActiveMQDestination createDestination()
           
 java.lang.String getAcknowledgeMode()
           
 int getAcknowledgeModeForSession()
           
 short getBackOffMultiplier()
           
 java.lang.String getClientId()
           
 java.lang.String getDestination()
           
 java.lang.String getDestinationType()
           
 java.lang.String getEnableBatch()
           
 boolean getEnableBatchBooleanValue()
           
 long getInitialRedeliveryDelay()
           
 int getMaximumRedeliveries()
           
 java.lang.String getMaxMessagesPerBatch()
           
 int getMaxMessagesPerBatchIntValue()
           
 java.lang.String getMaxMessagesPerSessions()
           
 int getMaxMessagesPerSessionsIntValue()
           
 java.lang.String getMaxSessions()
           
 int getMaxSessionsIntValue()
           
 java.lang.String getMessageSelector()
           
 java.lang.String getNoLocal()
           
 boolean getNoLocalBooleanValue()
           
 java.lang.String getPassword()
           
 javax.resource.spi.ResourceAdapter getResourceAdapter()
           
 java.lang.String getSubscriptionDurability()
           
 java.lang.String getSubscriptionName()
           
 java.lang.String getUseRAManagedTransaction()
           
 java.lang.String getUserName()
           
 boolean isDurableSubscription()
           
 boolean isUseExponentialBackOff()
           
 boolean isUseRAManagedTransactionEnabled()
           
protected  RedeliveryPolicy lazyCreateRedeliveryPolicy()
           
 RedeliveryPolicy redeliveryPolicy()
           
 void setAcknowledgeMode(java.lang.String acknowledgeMode)
           
 void setActiveMQDestination(ActiveMQDestination destination)
          A helper method mostly for use in Dependency Injection containers which allows you to customize the destination and destinationType properties from a single ActiveMQDestination POJO
 void setBackOffMultiplier(short backOffMultiplier)
           
 void setClientId(java.lang.String clientId)
           
 void setDestination(java.lang.String destination)
           
 void setDestinationType(java.lang.String destinationType)
           
 void setEnableBatch(java.lang.String enableBatch)
           
 void setInitialRedeliveryDelay(long initialRedeliveryDelay)
           
 void setMaximumRedeliveries(int maximumRedeliveries)
           
 void setMaxMessagesPerBatch(java.lang.String maxMessagesPerBatch)
           
 void setMaxMessagesPerSessions(java.lang.String maxMessagesPerSessions)
           
 void setMaxSessions(java.lang.String maxSessions)
           
 void setMessageSelector(java.lang.String messageSelector)
           
 void setNoLocal(java.lang.String noLocal)
           
 void setPassword(java.lang.String password)
           
 void setResourceAdapter(javax.resource.spi.ResourceAdapter resourceAdapter)
           
 void setSubscriptionDurability(java.lang.String subscriptionDurability)
           
 void setSubscriptionName(java.lang.String subscriptionName)
           
 void setUseExponentialBackOff(boolean useExponentialBackOff)
           
 void setUseRAManagedTransaction(java.lang.String useRAManagedTransaction)
           
 void setUserName(java.lang.String userName)
           
 java.lang.String toString()
           
 void validate()
           
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait
 

Field Detail

AUTO_ACKNOWLEDGE_MODE

public static final java.lang.String AUTO_ACKNOWLEDGE_MODE
Auto-acknowledge constant for acknowledgeMode property

See Also:
Constant Field Values

DUPS_OK_ACKNOWLEDGE_MODE

public static final java.lang.String DUPS_OK_ACKNOWLEDGE_MODE
Dups-ok-acknowledge constant for acknowledgeMode property *

See Also:
Constant Field Values

DURABLE_SUBSCRIPTION

public static final java.lang.String DURABLE_SUBSCRIPTION
Durable constant for subscriptionDurability property *

See Also:
Constant Field Values

NON_DURABLE_SUBSCRIPTION

public static final java.lang.String NON_DURABLE_SUBSCRIPTION
NonDurable constant for subscriptionDurability property *

See Also:
Constant Field Values

INVALID_ACKNOWLEDGE_MODE

public static final int INVALID_ACKNOWLEDGE_MODE
See Also:
Constant Field Values
Constructor Detail

ActiveMQActivationSpec

public ActiveMQActivationSpec()
Method Detail

validate

public void validate()
              throws javax.resource.spi.InvalidPropertyException
Specified by:
validate in interface javax.resource.spi.ActivationSpec
Throws:
javax.resource.spi.InvalidPropertyException
See Also:
ActivationSpec.validate()

getResourceAdapter

public javax.resource.spi.ResourceAdapter getResourceAdapter()
Specified by:
getResourceAdapter in interface javax.resource.spi.ResourceAdapterAssociation
See Also:
ResourceAdapterAssociation.getResourceAdapter()

setResourceAdapter

public void setResourceAdapter(javax.resource.spi.ResourceAdapter resourceAdapter)
                        throws javax.resource.ResourceException
Specified by:
setResourceAdapter in interface javax.resource.spi.ResourceAdapterAssociation
Throws:
javax.resource.ResourceException
See Also:
ResourceAdapterAssociation.setResourceAdapter(javax.resource.spi.ResourceAdapter)

getDestinationType

public java.lang.String getDestinationType()
Returns:
Returns the destinationType.

setDestinationType

public void setDestinationType(java.lang.String destinationType)
Parameters:
destinationType - The destinationType to set.

getPassword

public java.lang.String getPassword()

setPassword

public void setPassword(java.lang.String password)

getUserName

public java.lang.String getUserName()

setUserName

public void setUserName(java.lang.String userName)

getMessageSelector

public java.lang.String getMessageSelector()
Returns:
Returns the messageSelector.

setMessageSelector

public void setMessageSelector(java.lang.String messageSelector)
Parameters:
messageSelector - The messageSelector to set.

getNoLocal

public java.lang.String getNoLocal()
Returns:
Returns the noLocal.

setNoLocal

public void setNoLocal(java.lang.String noLocal)
Parameters:
noLocal - The noLocal to set.

getAcknowledgeMode

public java.lang.String getAcknowledgeMode()

setAcknowledgeMode

public void setAcknowledgeMode(java.lang.String acknowledgeMode)

getClientId

public java.lang.String getClientId()

setClientId

public void setClientId(java.lang.String clientId)

getDestination

public java.lang.String getDestination()

setDestination

public void setDestination(java.lang.String destination)

getSubscriptionDurability

public java.lang.String getSubscriptionDurability()

setSubscriptionDurability

public void setSubscriptionDurability(java.lang.String subscriptionDurability)

getSubscriptionName

public java.lang.String getSubscriptionName()

setSubscriptionName

public void setSubscriptionName(java.lang.String subscriptionName)

isDurableSubscription

public boolean isDurableSubscription()

toString

public java.lang.String toString()
Overrides:
toString in class java.lang.Object

getAcknowledgeModeForSession

public int getAcknowledgeModeForSession()

setActiveMQDestination

public void setActiveMQDestination(ActiveMQDestination destination)
A helper method mostly for use in Dependency Injection containers which allows you to customize the destination and destinationType properties from a single ActiveMQDestination POJO


createDestination

public ActiveMQDestination createDestination()

getMaxMessagesPerSessions

public java.lang.String getMaxMessagesPerSessions()

setMaxMessagesPerSessions

public void setMaxMessagesPerSessions(java.lang.String maxMessagesPerSessions)

getMaxSessions

public java.lang.String getMaxSessions()

setMaxSessions

public void setMaxSessions(java.lang.String maxSessions)

getUseRAManagedTransaction

public java.lang.String getUseRAManagedTransaction()

setUseRAManagedTransaction

public void setUseRAManagedTransaction(java.lang.String useRAManagedTransaction)

getMaxMessagesPerSessionsIntValue

public int getMaxMessagesPerSessionsIntValue()

getMaxSessionsIntValue

public int getMaxSessionsIntValue()

isUseRAManagedTransactionEnabled

public boolean isUseRAManagedTransactionEnabled()

getNoLocalBooleanValue

public boolean getNoLocalBooleanValue()

getEnableBatch

public java.lang.String getEnableBatch()

setEnableBatch

public void setEnableBatch(java.lang.String enableBatch)

getEnableBatchBooleanValue

public boolean getEnableBatchBooleanValue()

getMaxMessagesPerBatchIntValue

public int getMaxMessagesPerBatchIntValue()

getMaxMessagesPerBatch

public java.lang.String getMaxMessagesPerBatch()

setMaxMessagesPerBatch

public void setMaxMessagesPerBatch(java.lang.String maxMessagesPerBatch)

getBackOffMultiplier

public short getBackOffMultiplier()

getInitialRedeliveryDelay

public long getInitialRedeliveryDelay()

getMaximumRedeliveries

public int getMaximumRedeliveries()

isUseExponentialBackOff

public boolean isUseExponentialBackOff()

setBackOffMultiplier

public void setBackOffMultiplier(short backOffMultiplier)

setInitialRedeliveryDelay

public void setInitialRedeliveryDelay(long initialRedeliveryDelay)

setMaximumRedeliveries

public void setMaximumRedeliveries(int maximumRedeliveries)

setUseExponentialBackOff

public void setUseExponentialBackOff(boolean useExponentialBackOff)

redeliveryPolicy

public RedeliveryPolicy redeliveryPolicy()

lazyCreateRedeliveryPolicy

protected RedeliveryPolicy lazyCreateRedeliveryPolicy()


Copyright © 2011 Apache Software Foundation. All Rights Reserved.