Package org.apache.activemq.artemis.ra.inflow

Class ActiveMQActivationSpec

java.lang.Object
org.apache.activemq.artemis.ra.ConnectionFactoryProperties
org.apache.activemq.artemis.ra.inflow.ActiveMQActivationSpec
All Implemented Interfaces:
ActivationSpec, ResourceAdapterAssociation, Serializable, ConnectionFactoryOptions
public class ActiveMQActivationSpec extends ConnectionFactoryProperties implements ActivationSpec, Serializable
These properties are set on the MDB ActivationProperties
See Also:

  • Field Details

    • strConnectorClassName

      public String strConnectorClassName

    • strConnectionParameters

      public String strConnectionParameters

    • allowLocalTransactions

      protected Boolean allowLocalTransactions

  • Constructor Details

    • ActiveMQActivationSpec

      public ActiveMQActivationSpec()

  • Method Details

    • getResourceAdapter

      public ResourceAdapter getResourceAdapter()
      Description copied from interface: ResourceAdapterAssociation
      Get the associated ResourceAdapter object.
      Specified by:
      getResourceAdapter in interface ResourceAdapterAssociation
      Returns:
      the associated ResourceAdapter object.

    • isUseJNDI

      public Boolean isUseJNDI()

    • setUseJNDI

      public void setUseJNDI(Boolean value)

    • getJndiParams

      public String getJndiParams()

    • setJndiParams

      public void setJndiParams(String jndiParams)

    • getParsedJndiParams

      public Hashtable<?,?> getParsedJndiParams()

    • setResourceAdapter

      public void setResourceAdapter(ResourceAdapter ra) throws ResourceException
      Description copied from interface: ResourceAdapterAssociation
      Associate this object with a ResourceAdapter object. Note, this method must be called exactly once. That is, the association must not change during the lifetime of this object.
      Specified by:
      setResourceAdapter in interface ResourceAdapterAssociation
      Parameters:
      ra - ResourceAdapter object to be associated with.
      Throws:
      ResourceException - generic exception.
      ResourceAdapterInternalException - resource adapter related error condition.
      IllegalStateException - indicates that this object is in an illegal state for the method invocation. For example, this occurs when this method is called more than once on the same object.

    • getConnectionFactoryLookup

      public String getConnectionFactoryLookup()

    • setConnectionFactoryLookup

      public void setConnectionFactoryLookup(String value)

    • getDestination

      public String getDestination()

    • setDestination

      public void setDestination(String value)

    • getDestinationLookup

      public String getDestinationLookup()

    • setDestinationLookup

      public void setDestinationLookup(String value)

    • getDestinationType

      public String getDestinationType()

    • setDestinationType

      public void setDestinationType(String value)

    • getMessageSelector

      public String getMessageSelector()

    • setMessageSelector

      public void setMessageSelector(String value)

    • getAcknowledgeMode

      public String getAcknowledgeMode()

    • setQueuePrefix

      public void setQueuePrefix(String prefix)

    • getQueuePrefix

      public String getQueuePrefix()

    • setTopicPrefix

      public void setTopicPrefix(String prefix)

    • getTopicPrefix

      public String getTopicPrefix()

    • setAcknowledgeMode

      public void setAcknowledgeMode(String value)

    • getAcknowledgeModeInt

      public Integer getAcknowledgeModeInt()

    • getSubscriptionDurability

      public String getSubscriptionDurability()

    • setSubscriptionDurability

      public void setSubscriptionDurability(String value)

    • isSubscriptionDurable

      public Boolean isSubscriptionDurable()

    • getSubscriptionName

      public String getSubscriptionName()

    • setSubscriptionName

      public void setSubscriptionName(String value)

    • isShareSubscriptions

      public Boolean isShareSubscriptions()

    • setShareSubscriptions

      public void setShareSubscriptions(Boolean shareSubscriptions)

    • getUser

      public String getUser()

    • setUser

      public void setUser(String value)

    • getUserName

      public String getUserName()

    • setUserName

      public void setUserName(String value)

    • getPassword

      public String getPassword()

    • getOwnPassword

      public String getOwnPassword()

    • setPassword

      public void setPassword(String value) throws Exception
      Throws:
      Exception

    • getMaxSession

      public Integer getMaxSession()

    • setMaxSession

      public void setMaxSession(Integer value)

    • isSingleConnection

      public Boolean isSingleConnection()

    • setSingleConnection

      public void setSingleConnection(Boolean value)

    • getTransactionTimeout

      @Deprecated(forRemoval=true) public Integer getTransactionTimeout()
      Deprecated, for removal: This API element is subject to removal in a future version.

    • setTransactionTimeout

      @Deprecated(forRemoval=true) public void setTransactionTimeout(Integer value)
      Deprecated, for removal: This API element is subject to removal in a future version.

    • isUseLocalTx

      public Boolean isUseLocalTx()

    • setUseLocalTx

      public void setUseLocalTx(Boolean localTx)

    • getRebalanceConnections

      public Boolean getRebalanceConnections()

    • isRebalanceConnections

      public Boolean isRebalanceConnections()

    • setRebalanceConnections

      public void setRebalanceConnections(Boolean rebalanceConnections)

    • getSetupAttempts

      public Integer getSetupAttempts()

    • setSetupAttempts

      public void setSetupAttempts(Integer setupAttempts)

    • getSetupInterval

      public Long getSetupInterval()

    • setSetupInterval

      public void setSetupInterval(Long setupInterval)

    • setClientId

      public void setClientId(String clientId)

    • validate

      public void validate() throws InvalidPropertyException
      Validate
      Specified by:
      validate in interface ActivationSpec
      Throws:
      InvalidPropertyException - Thrown if a validation exception occurs

    • getConnectorClassName

      public String getConnectorClassName()

    • setConnectorClassName

      public void setConnectorClassName(String connectorClassName)

    • getConnectionParameters

      public String getConnectionParameters()

    • setConnectionParameters

      public void setConnectionParameters(String configuration)

    • toString

      public String toString()
      Overrides:
      toString in class Object

    • setUseDLQ

      public void setUseDLQ(Boolean b)

    • setDLQJNDIName

      public void setDLQJNDIName(String name)

    • setDLQHandler

      public void setDLQHandler(String handler)

    • setDLQMaxResent

      public void setDLQMaxResent(Integer maxResent)

    • setProviderAdapterJNDI

      public void setProviderAdapterJNDI(String jndi)

    • setKeepAlive

      public void setKeepAlive(Boolean keepAlive)

    • setKeepAliveMillis

      public void setKeepAliveMillis(Long keepAliveMillis)

    • setReconnectInterval

      public void setReconnectInterval(Long interval)

    • setMinSession

      public void setMinSession(Integer value)

    • setMaxMessages

      public void setMaxMessages(Integer value)

    • isAllowLocalTransactions

      public Boolean isAllowLocalTransactions()

    • setAllowLocalTransactions

      public void setAllowLocalTransactions(Boolean allowLocalTransactions)

    • equals

      public boolean equals(Object o)
      Overrides:
      equals in class ConnectionFactoryProperties

    • hashCode

      public int hashCode()
      Overrides:
      hashCode in class ConnectionFactoryProperties