Package org.apache.activemq.ra
Class ActiveMQActivationSpec
java.lang.Object
org.apache.activemq.ra.ActiveMQActivationSpec
- All Implemented Interfaces:
jakarta.resource.spi.ActivationSpec,jakarta.resource.spi.ResourceAdapterAssociation,Serializable,MessageActivationSpec
Configures the inbound JMS consumer specification using ActiveMQ
- See Also:
-
Field Summary
FieldsModifier and TypeFieldDescriptionstatic final StringAuto-acknowledge constant foracknowledgeModeproperty *static final StringDups-ok-acknowledge constant foracknowledgeModeproperty *static final StringDurable constant forsubscriptionDurabilityproperty *static final intstatic final StringNonDurable constant forsubscriptionDurabilityproperty * -
Constructor Summary
Constructors -
Method Summary
Modifier and TypeMethodDescriptionorg.apache.activemq.command.ActiveMQDestinationintdoublebooleanlongintlongintintintbooleanjakarta.resource.spi.ResourceAdapterbooleanbooleanbooleanbooleanbooleanbooleanisValidAcknowledgeMode(List<String> errorMessages) booleanisValidClientId(List<String> errorMessages) booleanisValidDestination(List<String> errorMessages) booleanisValidDestinationType(List<String> errorMessages) booleanisValidEnableBatch(List<String> errorMessages) booleanisValidMaxMessagesPerBatch(List<String> errorMessages) booleanisValidMaxMessagesPerSessions(List<String> errorMessages) booleanisValidMaxSessions(List<String> errorMessages) booleanisValidMessageSelector(List<String> errorMessages) booleanisValidNoLocal(List<String> errorMessages) booleanisValidSubscriptionDurability(List<String> errorMessages) booleanisValidSubscriptionName(List<String> errorMessages) booleanisValidUseRAManagedTransaction(List<String> errorMessages) org.apache.activemq.RedeliveryPolicyorg.apache.activemq.RedeliveryPolicyvoidsetAcknowledgeMode(String acknowledgeMode) voidsetActiveMQDestination(org.apache.activemq.command.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 POJOvoidsetBackOffMultiplier(double backOffMultiplier) voidsetClientId(String clientId) voidsetDestination(String destination) voidsetDestinationType(String destinationType) voidsetEnableBatch(String enableBatch) voidsetInitialRedeliveryDelay(long initialRedeliveryDelay) voidsetKeyStore(String keyStore) voidsetKeyStoreKeyPassword(String keyStoreKeyPassword) voidsetKeyStorePassword(String keyStorePassword) voidsetMaximumRedeliveries(int maximumRedeliveries) voidsetMaximumRedeliveryDelay(long maximumRedeliveryDelay) voidsetMaxMessagesPerBatch(String maxMessagesPerBatch) voidsetMaxMessagesPerSessions(String maxMessagesPerSessions) voidsetMaxSessions(String maxSessions) voidsetMessageSelector(String messageSelector) voidsetNoLocal(String noLocal) voidsetPassword(String password) voidsetResourceAdapter(jakarta.resource.spi.ResourceAdapter resourceAdapter) voidsetSubscriptionDurability(String subscriptionDurability) voidsetSubscriptionName(String subscriptionName) voidsetTrustStore(String trustStore) voidsetTrustStorePassword(String trustStorePassword) voidsetUseExponentialBackOff(boolean useExponentialBackOff) voidsetUseJndi(boolean useJndi) voidsetUseRAManagedTransaction(String useRAManagedTransaction) voidsetUserName(String userName) toString()voidvalidate()
-
Field Details
-
AUTO_ACKNOWLEDGE_MODE
Auto-acknowledge constant foracknowledgeModeproperty *- See Also:
-
DUPS_OK_ACKNOWLEDGE_MODE
Dups-ok-acknowledge constant foracknowledgeModeproperty *- See Also:
-
DURABLE_SUBSCRIPTION
Durable constant forsubscriptionDurabilityproperty *- See Also:
-
NON_DURABLE_SUBSCRIPTION
NonDurable constant forsubscriptionDurabilityproperty *- See Also:
-
INVALID_ACKNOWLEDGE_MODE
public static final int INVALID_ACKNOWLEDGE_MODE- See Also:
-
-
Constructor Details
-
ActiveMQActivationSpec
public ActiveMQActivationSpec()
-
-
Method Details
-
validate
public void validate() throws jakarta.resource.spi.InvalidPropertyException- Specified by:
validatein interfacejakarta.resource.spi.ActivationSpec- Throws:
jakarta.resource.spi.InvalidPropertyException- See Also:
-
javax.resource.spi.ActivationSpec#validate()
-
isValidUseRAManagedTransaction
- Specified by:
isValidUseRAManagedTransactionin interfaceMessageActivationSpec
-
isValidNoLocal
- Specified by:
isValidNoLocalin interfaceMessageActivationSpec
-
isValidMessageSelector
- Specified by:
isValidMessageSelectorin interfaceMessageActivationSpec
-
isValidMaxSessions
- Specified by:
isValidMaxSessionsin interfaceMessageActivationSpec
-
isValidMaxMessagesPerSessions
- Specified by:
isValidMaxMessagesPerSessionsin interfaceMessageActivationSpec
-
isValidMaxMessagesPerBatch
- Specified by:
isValidMaxMessagesPerBatchin interfaceMessageActivationSpec
-
isValidEnableBatch
- Specified by:
isValidEnableBatchin interfaceMessageActivationSpec
-
getResourceAdapter
public jakarta.resource.spi.ResourceAdapter getResourceAdapter()- Specified by:
getResourceAdapterin interfaceMessageActivationSpec- Specified by:
getResourceAdapterin interfacejakarta.resource.spi.ResourceAdapterAssociation- See Also:
-
javax.resource.spi.ResourceAdapterAssociation#getResourceAdapter()
-
setResourceAdapter
public void setResourceAdapter(jakarta.resource.spi.ResourceAdapter resourceAdapter) throws jakarta.resource.ResourceException - Specified by:
setResourceAdapterin interfacejakarta.resource.spi.ResourceAdapterAssociation- Throws:
jakarta.resource.ResourceException- See Also:
-
javax.resource.spi.ResourceAdapterAssociation#setResourceAdapter(javax.resource.spi.ResourceAdapter)
-
getDestinationType
- Specified by:
getDestinationTypein interfaceMessageActivationSpec- Returns:
- Returns the destinationType.
-
setDestinationType
- Parameters:
destinationType- The destinationType to set.
-
getPassword
- Specified by:
getPasswordin interfaceMessageActivationSpec
-
setPassword
-
getUserName
- Specified by:
getUserNamein interfaceMessageActivationSpec
-
setUserName
-
getMessageSelector
- Specified by:
getMessageSelectorin interfaceMessageActivationSpec- Returns:
- Returns the messageSelector.
-
setMessageSelector
- Parameters:
messageSelector- The messageSelector to set.
-
getNoLocal
- Specified by:
getNoLocalin interfaceMessageActivationSpec- Returns:
- Returns the noLocal.
-
setNoLocal
- Parameters:
noLocal- The noLocal to set.
-
getAcknowledgeMode
- Specified by:
getAcknowledgeModein interfaceMessageActivationSpec
-
setAcknowledgeMode
-
getClientId
- Specified by:
getClientIdin interfaceMessageActivationSpec
-
setClientId
-
getDestination
- Specified by:
getDestinationin interfaceMessageActivationSpec
-
setDestination
-
getSubscriptionDurability
- Specified by:
getSubscriptionDurabilityin interfaceMessageActivationSpec
-
setSubscriptionDurability
-
getSubscriptionName
- Specified by:
getSubscriptionNamein interfaceMessageActivationSpec
-
setSubscriptionName
-
isValidSubscriptionName
- Specified by:
isValidSubscriptionNamein interfaceMessageActivationSpec
-
isValidClientId
- Specified by:
isValidClientIdin interfaceMessageActivationSpec
-
isDurableSubscription
public boolean isDurableSubscription()- Specified by:
isDurableSubscriptionin interfaceMessageActivationSpec
-
isValidSubscriptionDurability
- Specified by:
isValidSubscriptionDurabilityin interfaceMessageActivationSpec
-
isValidAcknowledgeMode
- Specified by:
isValidAcknowledgeModein interfaceMessageActivationSpec
-
isValidDestinationType
- Specified by:
isValidDestinationTypein interfaceMessageActivationSpec
-
isValidDestination
- Specified by:
isValidDestinationin interfaceMessageActivationSpec
-
isEmpty
- Specified by:
isEmptyin interfaceMessageActivationSpec
-
toString
-
getAcknowledgeModeForSession
public int getAcknowledgeModeForSession()- Specified by:
getAcknowledgeModeForSessionin interfaceMessageActivationSpec
-
setActiveMQDestination
public void setActiveMQDestination(org.apache.activemq.command.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 org.apache.activemq.command.ActiveMQDestination createDestination() -
getMaxMessagesPerSessions
- Specified by:
getMaxMessagesPerSessionsin interfaceMessageActivationSpec
-
setMaxMessagesPerSessions
-
getMaxSessions
- Specified by:
getMaxSessionsin interfaceMessageActivationSpec
-
setMaxSessions
-
getUseRAManagedTransaction
- Specified by:
getUseRAManagedTransactionin interfaceMessageActivationSpec
-
setUseRAManagedTransaction
-
getMaxMessagesPerSessionsIntValue
public int getMaxMessagesPerSessionsIntValue()- Specified by:
getMaxMessagesPerSessionsIntValuein interfaceMessageActivationSpec
-
getMaxSessionsIntValue
public int getMaxSessionsIntValue()- Specified by:
getMaxSessionsIntValuein interfaceMessageActivationSpec
-
isUseRAManagedTransactionEnabled
public boolean isUseRAManagedTransactionEnabled()- Specified by:
isUseRAManagedTransactionEnabledin interfaceMessageActivationSpec
-
getNoLocalBooleanValue
public boolean getNoLocalBooleanValue()- Specified by:
getNoLocalBooleanValuein interfaceMessageActivationSpec
-
getEnableBatch
- Specified by:
getEnableBatchin interfaceMessageActivationSpec
-
setEnableBatch
-
getEnableBatchBooleanValue
public boolean getEnableBatchBooleanValue()- Specified by:
getEnableBatchBooleanValuein interfaceMessageActivationSpec
-
getMaxMessagesPerBatchIntValue
public int getMaxMessagesPerBatchIntValue()- Specified by:
getMaxMessagesPerBatchIntValuein interfaceMessageActivationSpec
-
getMaxMessagesPerBatch
- Specified by:
getMaxMessagesPerBatchin interfaceMessageActivationSpec
-
setMaxMessagesPerBatch
-
getBackOffMultiplier
public double getBackOffMultiplier()- Specified by:
getBackOffMultiplierin interfaceMessageActivationSpec
-
getInitialRedeliveryDelay
public long getInitialRedeliveryDelay()- Specified by:
getInitialRedeliveryDelayin interfaceMessageActivationSpec
-
getMaximumRedeliveries
public int getMaximumRedeliveries()- Specified by:
getMaximumRedeliveriesin interfaceMessageActivationSpec
-
isUseExponentialBackOff
public boolean isUseExponentialBackOff()- Specified by:
isUseExponentialBackOffin interfaceMessageActivationSpec
-
setBackOffMultiplier
public void setBackOffMultiplier(double backOffMultiplier) -
getMaximumRedeliveryDelay
public long getMaximumRedeliveryDelay()- Specified by:
getMaximumRedeliveryDelayin interfaceMessageActivationSpec
-
setMaximumRedeliveryDelay
public void setMaximumRedeliveryDelay(long maximumRedeliveryDelay) -
setInitialRedeliveryDelay
public void setInitialRedeliveryDelay(long initialRedeliveryDelay) -
setMaximumRedeliveries
public void setMaximumRedeliveries(int maximumRedeliveries) -
setUseExponentialBackOff
public void setUseExponentialBackOff(boolean useExponentialBackOff) -
redeliveryPolicy
public org.apache.activemq.RedeliveryPolicy redeliveryPolicy()- Specified by:
redeliveryPolicyin interfaceMessageActivationSpec
-
lazyCreateRedeliveryPolicy
public org.apache.activemq.RedeliveryPolicy lazyCreateRedeliveryPolicy()- Specified by:
lazyCreateRedeliveryPolicyin interfaceMessageActivationSpec
-
setUseJndi
public void setUseJndi(boolean useJndi) -
isUseJndi
public boolean isUseJndi()- Specified by:
isUseJndiin interfaceMessageActivationSpec
-
getTrustStore
- Specified by:
getTrustStorein interfaceMessageActivationSpec
-
setTrustStore
-
getTrustStorePassword
- Specified by:
getTrustStorePasswordin interfaceMessageActivationSpec
-
setTrustStorePassword
-
getKeyStore
- Specified by:
getKeyStorein interfaceMessageActivationSpec
-
setKeyStore
-
getKeyStorePassword
- Specified by:
getKeyStorePasswordin interfaceMessageActivationSpec
-
setKeyStorePassword
-
getKeyStoreKeyPassword
- Specified by:
getKeyStoreKeyPasswordin interfaceMessageActivationSpec
-
setKeyStoreKeyPassword
-