Class ActiveMQDestination

java.lang.Object
org.apache.activemq.artemis.jndi.JNDIStorable
org.apache.activemq.artemis.jms.client.ActiveMQDestination
All Implemented Interfaces:
jakarta.jms.Destination, Serializable, Referenceable
Direct Known Subclasses:
ActiveMQQueue, ActiveMQTopic
public class ActiveMQDestination extends JNDIStorable implements jakarta.jms.Destination, Serializable
Apache Artemis implementation of a JMS Destination.
See Also:

  • Field Details

  • Constructor Details

  • Method Details

    • createDestination

      public static ActiveMQDestination createDestination(org.apache.activemq.artemis.api.core.RoutingType routingType, org.apache.activemq.artemis.api.core.SimpleString address)

    • createDestination

      public static ActiveMQDestination createDestination(String name, ActiveMQDestination.TYPE defaultType)
      Static helper method for working with destinations.

    • fromPrefixedName

      public static ActiveMQDestination fromPrefixedName(String name)

    • fromPrefixedName

      public static ActiveMQDestination fromPrefixedName(String addr, String name)

    • fromPrefixed1XName

      public static jakarta.jms.Destination fromPrefixed1XName(String addr, String name)

    • createQueueNameForSubscription

      public static org.apache.activemq.artemis.api.core.SimpleString createQueueNameForSubscription(boolean isDurable, String clientID, String subscriptionName)

    • createQueueNameForSharedSubscription

      public static String createQueueNameForSharedSubscription(boolean isDurable, String clientID, String subscriptionName)

    • decomposeQueueNameForDurableSubscription

      public static org.apache.activemq.artemis.api.core.Pair<String,String> decomposeQueueNameForDurableSubscription(String queueName)

    • createQueueAddressFromName

      public static org.apache.activemq.artemis.api.core.SimpleString createQueueAddressFromName(String name)

    • createTopicAddressFromName

      public static org.apache.activemq.artemis.api.core.SimpleString createTopicAddressFromName(String name)

    • createQueue

      public static ActiveMQQueue createQueue(String address)

    • createQueue

      public static ActiveMQQueue createQueue(org.apache.activemq.artemis.api.core.SimpleString address)

    • createQueue

      public static ActiveMQQueue createQueue(String address, String name)

    • createTopic

      public static ActiveMQTopic createTopic(String address)

    • createTopic

      public static ActiveMQTopic createTopic(org.apache.activemq.artemis.api.core.SimpleString address)

    • createTopic

      public static ActiveMQTopic createTopic(String address, String name)

    • createTemporaryQueue

      public static ActiveMQTemporaryQueue createTemporaryQueue(String address, ActiveMQSession session)

    • createTemporaryQueue

      public static ActiveMQTemporaryQueue createTemporaryQueue(String address)

    • createTemporaryQueue

      public static ActiveMQTemporaryQueue createTemporaryQueue(ActiveMQSession session)

    • createTemporaryTopic

      public static ActiveMQTemporaryTopic createTemporaryTopic(ActiveMQSession session)

    • createTemporaryQueue

      public static ActiveMQTemporaryQueue createTemporaryQueue(ActiveMQSession session, String prefix)

    • createTemporaryTopic

      public static ActiveMQTemporaryTopic createTemporaryTopic(ActiveMQSession session, String prefix)

    • createTemporaryTopic

      public static ActiveMQTemporaryTopic createTemporaryTopic(String address, ActiveMQSession session)

    • createTemporaryTopic

      public static ActiveMQTemporaryTopic createTemporaryTopic(String address)

    • setAddress

      public void setAddress(String address)

    • toString

      public String toString()
      Overrides:
      toString in class Object

    • setSimpleAddress

      public void setSimpleAddress(org.apache.activemq.artemis.api.core.SimpleString address)

    • setSimpleAddress

      public void setSimpleAddress(String address)

    • delete

      public void delete() throws jakarta.jms.JMSException
      Throws:
      jakarta.jms.JMSException

    • isQueue

      public boolean isQueue()

    • getAddress

      public String getAddress()

    • getSimpleAddress

      public org.apache.activemq.artemis.api.core.SimpleString getSimpleAddress()

    • getQueueAttributes

      @Deprecated public org.apache.activemq.artemis.api.core.QueueAttributes getQueueAttributes()
      Deprecated.

    • getQueueConfiguration

      public org.apache.activemq.artemis.api.core.QueueConfiguration getQueueConfiguration()

    • getName

      public String getName()

    • isTemporary

      public boolean isTemporary()

    • getCreated

      public boolean getCreated()

    • isCreated

      public boolean isCreated()

    • setCreated

      public void setCreated(boolean created)

    • setCreated

      public void setCreated(String created)

    • getType

      public ActiveMQDestination.TYPE getType()

    • equals

      public boolean equals(Object obj)
      Overrides:
      equals in class Object

    • hashCode

      public int hashCode()
      Overrides:
      hashCode in class Object

    • buildFromProperties

      protected void buildFromProperties(Properties props)
      Description copied from class: JNDIStorable
      Set the properties that will represent the instance in JNDI
      Specified by:
      buildFromProperties in class JNDIStorable
      Parameters:
      props - The properties to use when building the new isntance.

    • populateProperties

      protected void populateProperties(Properties props)
      Description copied from class: JNDIStorable
      Initialize the instance from properties stored in JNDI
      Specified by:
      populateProperties in class JNDIStorable
      Parameters:
      props - The properties to use when initializing the new instance.